@@ -38,6 +38,13 @@
 			<version>1.4.0</version>
 		</dependency>
 
+		<!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
+		<dependency>
+			<groupId>io.netty</groupId>
+			<artifactId>netty-all</artifactId>
+			<version>4.1.56.Final</version>
+		</dependency>
+
 
 		<dependency>
 			<groupId>com.squareup.okhttp3</groupId>
 
@@ -7,9 +7,10 @@
 import io.kimmking.rpcfx.exception.RpcfxException;
 import io.kimmking.rpcfx.param.RpcfxRequest;
 import io.kimmking.rpcfx.param.RpcfxResponse;
+import io.kimmking.rpcfx.utils.ClientUtils;
+import io.kimmking.rpcfx.utils.NettyClientUtils;
 import io.kimmking.rpcfx.utils.XStreamUtils;
 import okhttp3.MediaType;
-import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.RequestBody;
 import org.springframework.cglib.proxy.Enhancer;
@@ -19,7 +20,6 @@
 import java.io.IOException;
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Method;
-import java.lang.reflect.Proxy;
 
 public final class Rpcfx {
 
@@ -40,18 +40,36 @@ public static <T> T create(final Class<T> serviceClass, final String url) {
 
     }
 
+    public static <T> T create(final Class<T> serviceClass, final String host, final Integer port) {
+        //Gglib方式
+        Enhancer enhancer = new Enhancer();
+        //enhancer.setCallback(new RpcfxInvocationHandler(serviceClass, host, port));
+        enhancer.setSuperclass(serviceClass);
+        return (T) enhancer.create();
+        // 0. 替换动态代理 -> AOP
+        //return (T) Proxy.newProxyInstance(Rpcfx.class.getClassLoader(), new Class[]{serviceClass}, new RpcfxInvocationHandler(serviceClass, url));
+
+    }
+
     public static class RpcfxInvocationHandler implements InvocationHandler, MethodInterceptor {
 
         public static final MediaType JSONTYPE = MediaType.get("application/json; charset=utf-8");
 
         private final Class<?> serviceClass;
         private final String url;
+//        private final String host;
+//        private final Integer port;
         private final XStream stream = XStreamUtils.createToJson();
 
         public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url) {
             this.serviceClass = serviceClass;
             this.url = url;
         }
+//        public <T> RpcfxInvocationHandler(Class<T> serviceClass, String host, Integer port) {
+//            this.serviceClass = serviceClass;
+//            this.host = host;
+//            this.port = port;
+//        }
 
         // 可以尝试，自己去写对象序列化，二进制还是文本的，，，rpcfx是xml自定义序列化、反序列化，json: code.google.com/p/rpcfx
         // int byte char float double long bool
@@ -62,7 +80,7 @@ public Object invoke(Object proxy, Method method, Object[] params) throws Throwa
             return post(method, params, url);
         }
 
-        private Object post(Method method, Object[] params, String url) throws IOException, RpcfxException {
+        private Object post(Method method, Object[] params, String url) throws IOException, RpcfxException, InterruptedException {
             RpcfxRequest rpcfxRequest = new RpcfxRequest();
             rpcfxRequest.setServiceClass(this.serviceClass.getName());
             rpcfxRequest.setMethod(method.getName());
@@ -72,12 +90,14 @@ private Object post(Method method, Object[] params, String url) throws IOExcepti
 
             // 1.可以复用client
             // 2.尝试使用httpclient或者netty client
-            OkHttpClient client = new OkHttpClient();
+            //OkHttpClient client = new OkHttpClient();
             final Request request = new Request.Builder()
                     .url(url)
                     .post(RequestBody.create(JSONTYPE, reqJson))
                     .build();
-            String respJson = client.newCall(request).execute().body().string();
+            String respJson = ClientUtils.execute(request).body().string();
+            /*NettyClientUtils nettyClientUtils = new NettyClientUtils(host, port, reqJson);
+            String respJson = nettyClientUtils.start();*/
             System.out.println("resp json: " + respJson);
             RpcfxResponse response = JSON.parseObject(respJson, RpcfxResponse.class);
             // 这里判断response.status，处理异常
 
@@ -0,0 +1,36 @@
+package io.kimmking.rpcfx.handler;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandler;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+import io.netty.util.CharsetUtil;
+
+@ChannelHandler.Sharable
+public class ClientHandler extends SimpleChannelInboundHandler<ByteBuf> {
+
+    private final String req;
+
+    public ClientHandler(String req) {
+        this.req = req;
+    }
+
+    @Override
+    protected void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf) throws Exception {
+
+        System.out.println(byteBuf.toString(CharsetUtil.UTF_8));
+
+    }
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        ctx.writeAndFlush(Unpooled.copiedBuffer(req, CharsetUtil.UTF_8));
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}
@@ -0,0 +1,17 @@
+package io.kimmking.rpcfx.utils;
+
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+
+import java.io.IOException;
+
+public class ClientUtils {
+
+    private static final OkHttpClient client = new OkHttpClient();
+
+    public static Response execute(Request request) throws IOException {
+        return client.newCall(request).execute();
+    }
+
+}
@@ -0,0 +1,53 @@
+package io.kimmking.rpcfx.utils;
+
+import io.kimmking.rpcfx.handler.ClientHandler;
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.util.CharsetUtil;
+
+public class NettyClientUtils {
+
+    private final String host;
+
+    private final Integer port;
+
+    private final String req;
+
+
+    public NettyClientUtils(String host, Integer port, String req) {
+        this.host = host;
+        this.port = port;
+        this.req = req;
+    }
+
+    public String start() throws InterruptedException {
+        EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
+        String resp;
+        try {
+            Bootstrap bootstrap = new Bootstrap();
+            bootstrap.
+                    group(eventLoopGroup).
+                    channel(NioSocketChannel.class).
+                    remoteAddress(host, port).
+                    handler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel socketChannel) throws Exception {
+                            socketChannel.pipeline().addLast(new ClientHandler(req));
+                        }
+                    });
+            ChannelFuture future = bootstrap.connect().sync();
+            resp = future.channel().alloc().buffer().toString(CharsetUtil.UTF_8);
+            System.out.println(resp);
+            future.channel().closeFuture().sync();
+        } finally {
+            eventLoopGroup.shutdownGracefully();
+        }
+        return resp;
+    }
+
+}
@@ -21,10 +21,12 @@ public static void main(String[] args) {
 		// service.findById
 
 		UserService userService = Rpcfx.create(UserService.class, "http://localhost:8080/");
+		//UserService userService = Rpcfx.create(UserService.class, "127.0.0.1", 8080);
 		User user = userService.findById(1);
 		System.out.println("find user id=1 from server: " + user.getName());
 
 		OrderService orderService = Rpcfx.create(OrderService.class, "http://localhost:8080/");
+		//OrderService orderService = Rpcfx.create(OrderService.class, "127.0.0.1", 8080);
 		Order order = orderService.findOrderById(1992129);
 		System.out.println(String.format("find order name=%s, amount=%f",order.getName(),order.getAmount()));