diff --git a/02nio/nio02/pom.xml b/02nio/nio02/pom.xml
index 6cbbeffd..ccb11a54 100644
--- a/02nio/nio02/pom.xml
+++ b/02nio/nio02/pom.xml
@@ -52,6 +52,11 @@
             <artifactId>httpasyncclient</artifactId>
             <version>4.1.4</version>
         </dependency>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>3.8.1</version>
+        </dependency>
     
         <!--
         <dependency>
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/NettyRequestFilter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/NettyRequestFilter.java
new file mode 100644
index 00000000..ad12c5c7
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/NettyRequestFilter.java
@@ -0,0 +1,20 @@
+package io.github.kimmking.gateway.filter;
+
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.handler.codec.http.FullHttpRequest;
+
+public class NettyRequestFilter extends ChannelInboundHandlerAdapter implements HttpRequestFilter{
+
+    @Override
+    public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
+        fullRequest.headers().set("nio", "cyy");
+        ctx.fireChannelRead(fullRequest);
+    }
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        FullHttpRequest fullRequest = (FullHttpRequest) msg;
+        this.filter(fullRequest, ctx);
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
index 22fb2525..73e1b4f2 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundHandler.java
@@ -1,6 +1,6 @@
 package io.github.kimmking.gateway.inbound;
 
-import io.github.kimmking.gateway.outbound.httpclient4.HttpOutboundHandler;
+import io.github.kimmking.gateway.outbound.okhttp.OkhttpOutboundHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.codec.http.FullHttpRequest;
@@ -12,11 +12,11 @@ public class HttpInboundHandler extends ChannelInboundHandlerAdapter {
 
     private static Logger logger = LoggerFactory.getLogger(HttpInboundHandler.class);
     private final String proxyServer;
-    private HttpOutboundHandler handler;
+    private OkhttpOutboundHandler handler;
     
     public HttpInboundHandler(String proxyServer) {
         this.proxyServer = proxyServer;
-        handler = new HttpOutboundHandler(this.proxyServer);
+        handler = new OkhttpOutboundHandler(this.proxyServer);
     }
     
     @Override
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java
index d902b4c8..affef153 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java
@@ -1,5 +1,6 @@
 package io.github.kimmking.gateway.inbound;
 
+import io.github.kimmking.gateway.filter.NettyRequestFilter;
 import io.netty.channel.ChannelInitializer;
 import io.netty.channel.ChannelPipeline;
 import io.netty.channel.socket.SocketChannel;
@@ -23,6 +24,7 @@ public void initChannel(SocketChannel ch) {
 		p.addLast(new HttpServerCodec());
 		//p.addLast(new HttpServerExpectContinueHandler());
 		p.addLast(new HttpObjectAggregator(1024 * 1024));
+		p.addLast(new NettyRequestFilter());
 		p.addLast(new HttpInboundHandler(this.proxyServer));
 	}
 }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
index 5f194588..874dcdcf 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
@@ -1,4 +1,107 @@
 package io.github.kimmking.gateway.outbound.okhttp;
 
+import io.github.kimmking.gateway.outbound.httpclient4.NamedThreadFactory;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http.DefaultFullHttpResponse;
+import io.netty.handler.codec.http.FullHttpRequest;
+import io.netty.handler.codec.http.FullHttpResponse;
+import io.netty.handler.codec.http.HttpUtil;
+import okhttp3.Interceptor;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
+import org.apache.http.protocol.HTTP;
+
+import java.io.IOException;
+import java.util.concurrent.*;
+
+import static io.netty.handler.codec.http.HttpResponseStatus.NO_CONTENT;
+import static io.netty.handler.codec.http.HttpResponseStatus.OK;
+import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;
+
 public class OkhttpOutboundHandler {
+    private CloseableHttpAsyncClient httpclient;
+    private ExecutorService proxyService;
+    private String backendUrl;
+    private OkHttpClient client;
+
+    public OkhttpOutboundHandler(String backendUrl){
+        this.backendUrl = backendUrl.endsWith("/")?backendUrl.substring(0,backendUrl.length()-1):backendUrl;
+        int cores = Runtime.getRuntime().availableProcessors() * 2;
+        long keepAliveTime = 1000;
+        int queueSize = 2048;
+        RejectedExecutionHandler handler = new ThreadPoolExecutor.CallerRunsPolicy();//.DiscardPolicy();
+        proxyService = new ThreadPoolExecutor(cores, cores,
+                keepAliveTime, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(queueSize),
+                new NamedThreadFactory("proxyService"), handler);
+    }
+
+    public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx) {
+        final String url = this.backendUrl + fullRequest.uri();
+        proxyService.submit(()->fetchGet(fullRequest, ctx, url));
+    }
+
+    private void fetchGet(final FullHttpRequest inbound, final ChannelHandlerContext ctx, final String url) {
+        client = new OkHttpClient.Builder()
+                .addInterceptor(new HandleRespInterceptor(inbound, ctx))
+                .build();
+
+        Request request = new Request.Builder()
+                .header(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE)
+                .url(url)
+                .build();
+        try {
+            Response response = client.newCall(request).execute();
+            System.out.println(response);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+        cause.printStackTrace();
+        ctx.close();
+    }
+
+    class HandleRespInterceptor implements Interceptor {
+        FullHttpResponse response = null;
+        FullHttpRequest inbound;
+        ChannelHandlerContext ctx;
+
+        public HandleRespInterceptor(FullHttpRequest inbound, ChannelHandlerContext ctx) {
+            this.ctx = ctx;
+            this.inbound = inbound;
+        }
+
+        @Override
+        public Response intercept(Chain chain) throws IOException {
+            Request request = chain.request();
+            Response okHttpResponse = chain.proceed(request);
+            try {
+                byte[] respBytes = okHttpResponse.body().bytes();
+                response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(respBytes));
+                response.headers().set("Content-Type", "application/json");
+                response.headers().setInt("Content-Length", Integer.parseInt(okHttpResponse.header("Content-Length")));
+            }catch (Exception e) {
+                e.printStackTrace();
+                response = new DefaultFullHttpResponse(HTTP_1_1, NO_CONTENT);
+                exceptionCaught(ctx, e);
+            } finally {
+                if (inbound != null) {
+                    if (!HttpUtil.isKeepAlive(inbound)) {
+                        ctx.write(response).addListener(ChannelFutureListener.CLOSE);
+                    } else {
+                        ctx.write(response);
+                    }
+                }
+                ctx.flush();
+            }
+            return okHttpResponse;
+        }
+
+    }
 }