diff --git a/02nio/nio02/pom.xml b/02nio/nio02/pom.xml
index 005de90a..5072eb01 100644
--- a/02nio/nio02/pom.xml
+++ b/02nio/nio02/pom.xml
@@ -57,7 +57,21 @@
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
-    
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>30.1-jre</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.4</version>
+        </dependency>
         <!--
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -81,6 +95,4 @@
             </plugin>
         </plugins>
     </build>
-
-
 </project>
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/NettyServerApplication.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/NettyServerApplication.java
index e67b7961..41870a5e 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/NettyServerApplication.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/NettyServerApplication.java
@@ -1,35 +1,15 @@
 package io.github.kimmking.gateway;
 
 
-import io.github.kimmking.gateway.inbound.HttpInboundServer;
-
-import java.util.Arrays;
+import io.github.kimmking.gateway.server.NettyHttpServer;
 
 public class NettyServerApplication {
-    
-    public final static String GATEWAY_NAME = "NIOGateway";
-    public final static String GATEWAY_VERSION = "3.0.0";
-    
-    public static void main(String[] args) {
-
-        String proxyPort = System.getProperty("proxyPort","8888");
 
-        // 这是之前的单个后端url的例子
-//        String proxyServer = System.getProperty("proxyServer","http://localhost:8088");
-//          //  http://localhost:8888/api/hello  ==> gateway API
-//          //  http://localhost:8088/api/hello  ==> backend service
-        // java -Xmx512m gateway-server-0.0.1-SNAPSHOT.jar  #作为后端服务
-
-
-        // 这是多个后端url走随机路由的例子
-        String proxyServers = System.getProperty("proxyServers","http://localhost:8801,http://localhost:8802");
-        int port = Integer.parseInt(proxyPort);
-        System.out.println(GATEWAY_NAME + " " + GATEWAY_VERSION +" starting...");
-        HttpInboundServer server = new HttpInboundServer(port, Arrays.asList(proxyServers.split(",")));
-        System.out.println(GATEWAY_NAME + " " + GATEWAY_VERSION +" started at http://localhost:" + port + " for server:" + server.toString());
+    public static void main(String[] args) {
+        NettyHttpServer server = new NettyHttpServer(8080);
         try {
-            server.run();
-        }catch (Exception ex){
+            server.start();
+        } catch (Exception ex) {
             ex.printStackTrace();
         }
     }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/client/NettyHttpClient.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/client/NettyHttpClient.java
new file mode 100644
index 00000000..a4e0c300
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/client/NettyHttpClient.java
@@ -0,0 +1,75 @@
+package io.github.kimmking.gateway.client;
+
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 09:35
+ **/
+
+import io.github.kimmking.gateway.outbound.netty4.HttpClientInboundHandler;
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.http.*;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.UnsupportedEncodingException;
+import java.net.URI;
+import java.net.URISyntaxException;
+
+@Data
+@Slf4j
+public class NettyHttpClient {
+    private String url;
+    private String body;
+
+    public NettyHttpClient(String url, String body) {
+        this.url = url;
+        this.body = body;
+    }
+
+    public void start() {
+        Bootstrap bootstrap = new Bootstrap();
+        //创建从线程组，处理主线程组分配下来的io操作
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+        bootstrap.group(workerGroup)
+                .channel(NioSocketChannel.class)
+                .option(ChannelOption.SO_KEEPALIVE, true)
+                .handler(new ChannelInitializer<Channel>() {
+                    @Override
+                    protected void initChannel(Channel channel) throws Exception {
+                        ChannelPipeline pipeline = channel.pipeline();
+                        pipeline.addLast(new HttpClientCodec());
+                        pipeline.addLast(new HttpObjectAggregator(1024 * 1024));
+                        pipeline.addLast(new HttpClientInboundHandler());
+                    }
+                });
+        try {
+            URI url = new URI(this.url);
+            String host = url.getHost();
+            int port = url.getPort();
+            ChannelFuture channelFuture = bootstrap.connect(host, port).sync();
+            DefaultFullHttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET,
+                    url.toASCIIString(), Unpooled.wrappedBuffer(this.body.getBytes("UTF-8")));
+            request.headers().set(HttpHeaderNames.HOST, host);
+            request.headers().set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE);
+            request.headers().set(HttpHeaderNames.CONTENT_LENGTH, request.content().readableBytes());
+            channelFuture.channel().write(request);
+            channelFuture.channel().flush();
+            channelFuture.channel().closeFuture().sync();
+        } catch (InterruptedException | URISyntaxException | UnsupportedEncodingException e) {
+            e.printStackTrace();
+        } finally {
+            workerGroup.shutdownGracefully();
+        }
+    }
+
+    public static void main(String[] args) {
+        NettyHttpClient nettyHttpClient = new NettyHttpClient("http://localhost:8088/api/hello", "你好");
+        nettyHttpClient.start();
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpRequestFilter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpRequestFilter.java
index af5c37fb..669b8f4f 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpRequestFilter.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpRequestFilter.java
@@ -3,10 +3,12 @@
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.http.FullHttpRequest;
 
+import java.util.UUID;
+
 public class HeaderHttpRequestFilter implements HttpRequestFilter {
 
     @Override
     public void filter(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
-        fullRequest.headers().set("mao", "soul");
+        fullRequest.headers().set("token", UUID.randomUUID());
     }
 }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpResponseFilter.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpResponseFilter.java
index 53493fb4..87418b02 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpResponseFilter.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/filter/HeaderHttpResponseFilter.java
@@ -5,6 +5,6 @@
 public class HeaderHttpResponseFilter implements HttpResponseFilter {
     @Override
     public void filter(FullHttpResponse response) {
-        response.headers().set("kk", "java-1-nio");
+        response.headers().set("timestamp", System.currentTimeMillis());
     }
 }
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 69b40fde..e444e715 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,81 +1,35 @@
 package io.github.kimmking.gateway.inbound;
 
-import io.github.kimmking.gateway.filter.HeaderHttpRequestFilter;
-import io.github.kimmking.gateway.filter.HttpRequestFilter;
+import com.google.common.collect.Lists;
 import io.github.kimmking.gateway.outbound.httpclient4.HttpOutboundHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.codec.http.FullHttpRequest;
-import io.netty.util.ReferenceCountUtil;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 13:00
+ **/
 public class HttpInboundHandler extends ChannelInboundHandlerAdapter {
 
-    private static Logger logger = LoggerFactory.getLogger(HttpInboundHandler.class);
-    private final List<String> proxyServer;
-    private HttpOutboundHandler handler;
-    private HttpRequestFilter filter = new HeaderHttpRequestFilter();
-    
-    public HttpInboundHandler(List<String> proxyServer) {
-        this.proxyServer = proxyServer;
-        this.handler = new HttpOutboundHandler(this.proxyServer);
+    private HttpOutboundHandler outboundHandler;
+
+    public HttpInboundHandler() {
+        this.outboundHandler = new HttpOutboundHandler(Lists.newArrayList("http://localhost:8088/api/hello"));
     }
-    
+
     @Override
-    public void channelReadComplete(ChannelHandlerContext ctx) {
-        ctx.flush();
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        FullHttpRequest request = (FullHttpRequest) msg;
+        outboundHandler.handle(request, ctx);
     }
 
     @Override
-    public void channelRead(ChannelHandlerContext ctx, Object msg) {
-        try {
-            //logger.info("channelRead流量接口请求开始，时间为{}", startTime);
-            FullHttpRequest fullRequest = (FullHttpRequest) msg;
-//            String uri = fullRequest.uri();
-//            //logger.info("接收到的请求url为{}", uri);
-//            if (uri.contains("/test")) {
-//                handlerTest(fullRequest, ctx);
-//            }
-    
-            handler.handle(fullRequest, ctx, filter);
-    
-        } catch(Exception e) {
-            e.printStackTrace();
-        } finally {
-            ReferenceCountUtil.release(msg);
-        }
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+        ctx.flush();
     }
-
-//    private void handlerTest(FullHttpRequest fullRequest, ChannelHandlerContext ctx) {
-//        FullHttpResponse response = null;
-//        try {
-//            String value = "hello,kimmking";
-//            response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(value.getBytes("UTF-8")));
-//            response.headers().set("Content-Type", "application/json");
-//            response.headers().setInt("Content-Length", response.content().readableBytes());
-//
-//        } catch (Exception e) {
-//            logger.error("处理测试接口出错", e);
-//            response = new DefaultFullHttpResponse(HTTP_1_1, NO_CONTENT);
-//        } finally {
-//            if (fullRequest != null) {
-//                if (!HttpUtil.isKeepAlive(fullRequest)) {
-//                    ctx.write(response).addListener(ChannelFutureListener.CLOSE);
-//                } else {
-//                    response.headers().set(CONNECTION, KEEP_ALIVE);
-//                    ctx.write(response);
-//                }
-//            }
-//        }
-//    }
-//
-//    @Override
-//    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-//        cause.printStackTrace();
-//        ctx.close();
-//    }
-
 }
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
deleted file mode 100644
index 1d651fb1..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundInitializer.java
+++ /dev/null
@@ -1,33 +0,0 @@
-package io.github.kimmking.gateway.inbound;
-
-import io.github.kimmking.gateway.filter.HttpRequestFilter;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.ChannelPipeline;
-import io.netty.channel.socket.SocketChannel;
-import io.netty.handler.codec.http.FullHttpRequest;
-import io.netty.handler.codec.http.HttpObjectAggregator;
-import io.netty.handler.codec.http.HttpServerCodec;
-
-import java.util.List;
-
-public class HttpInboundInitializer extends ChannelInitializer<SocketChannel> {
-	
-	private List<String> proxyServer;
-	
-	public HttpInboundInitializer(List<String> proxyServer) {
-		this.proxyServer = proxyServer;
-	}
-	
-	@Override
-	public void initChannel(SocketChannel ch) {
-		ChannelPipeline p = ch.pipeline();
-//		if (sslCtx != null) {
-//			p.addLast(sslCtx.newHandler(ch.alloc()));
-//		}
-		p.addLast(new HttpServerCodec());
-		//p.addLast(new HttpServerExpectContinueHandler());
-		p.addLast(new HttpObjectAggregator(1024 * 1024));
-		p.addLast(new HttpInboundHandler(this.proxyServer));
-	}
-}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java
deleted file mode 100644
index 97d54ccd..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpInboundServer.java
+++ /dev/null
@@ -1,60 +0,0 @@
-package io.github.kimmking.gateway.inbound;
-
-import io.netty.bootstrap.ServerBootstrap;
-import io.netty.buffer.PooledByteBufAllocator;
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelOption;
-import io.netty.channel.EventLoopGroup;
-import io.netty.channel.epoll.EpollChannelOption;
-import io.netty.channel.nio.NioEventLoopGroup;
-import io.netty.channel.socket.nio.NioServerSocketChannel;
-import io.netty.handler.logging.LogLevel;
-import io.netty.handler.logging.LoggingHandler;
-import lombok.Data;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.List;
-
-@Data
-public class HttpInboundServer {
-
-    private int port;
-    
-    private List<String> proxyServers;
-
-    public HttpInboundServer(int port, List<String> proxyServers) {
-        this.port=port;
-        this.proxyServers = proxyServers;
-    }
-
-    public void run() throws Exception {
-
-        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
-        EventLoopGroup workerGroup = new NioEventLoopGroup(16);
-
-        try {
-            ServerBootstrap b = new ServerBootstrap();
-            b.option(ChannelOption.SO_BACKLOG, 128)
-                    .childOption(ChannelOption.TCP_NODELAY, true)
-                    .childOption(ChannelOption.SO_KEEPALIVE, true)
-                    .childOption(ChannelOption.SO_REUSEADDR, true)
-                    .childOption(ChannelOption.SO_RCVBUF, 32 * 1024)
-                    .childOption(ChannelOption.SO_SNDBUF, 32 * 1024)
-                    .childOption(EpollChannelOption.SO_REUSEPORT, true)
-                    .childOption(ChannelOption.SO_KEEPALIVE, true)
-                    .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
-
-            b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
-                    .handler(new LoggingHandler(LogLevel.DEBUG))
-                    .childHandler(new HttpInboundInitializer(this.proxyServers));
-
-            Channel ch = b.bind(port).sync().channel();
-            System.out.println("开启netty http服务器，监听地址和端口为 http://127.0.0.1:" + port + '/');
-            ch.closeFuture().sync();
-        } finally {
-            bossGroup.shutdownGracefully();
-            workerGroup.shutdownGracefully();
-        }
-    }
-}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpRequestServerHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpRequestServerHandler.java
new file mode 100644
index 00000000..3c7e5876
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpRequestServerHandler.java
@@ -0,0 +1,45 @@
+package io.github.kimmking.gateway.inbound;
+
+import com.alibaba.fastjson.JSON;
+import com.google.common.collect.Maps;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+import io.netty.handler.codec.http.*;
+import io.netty.util.CharsetUtil;
+
+import java.util.Map;
+
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 09:51
+ **/
+public class HttpRequestServerHandler extends SimpleChannelInboundHandler<FullHttpRequest> {
+    @Override
+    protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest fullHttpRequest) throws Exception {
+        if (fullHttpRequest.uri().contains("/test")) {
+            handlerTest(fullHttpRequest, ctx);
+        }
+    }
+
+    private void handlerTest(FullHttpRequest fullHttpRequest, ChannelHandlerContext ctx) {
+        Map<String, Object> result = Maps.newHashMapWithExpectedSize(2);
+        result.put("code", 0);
+        result.put("msg", "success");
+        FullHttpResponse response = new DefaultFullHttpResponse(
+                HttpVersion.HTTP_1_1,
+                HttpResponseStatus.OK,
+                Unpooled.copiedBuffer(JSON.toJSONString(result), CharsetUtil.UTF_8));
+        response.headers().set("Content-Type", "application/json");
+        ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE);
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpRequestServerInitializer.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpRequestServerInitializer.java
new file mode 100644
index 00000000..2d5f7151
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/inbound/HttpRequestServerInitializer.java
@@ -0,0 +1,23 @@
+package io.github.kimmking.gateway.inbound;
+
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.handler.codec.http.HttpObjectAggregator;
+import io.netty.handler.codec.http.HttpServerCodec;
+
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 09:43
+ **/
+public class HttpRequestServerInitializer extends ChannelInitializer<SocketChannel> {
+    @Override
+    protected void initChannel(SocketChannel socketChannel) {
+        ChannelPipeline pipeline = socketChannel.pipeline();
+        pipeline.addLast(new HttpServerCodec());
+        pipeline.addLast(new HttpObjectAggregator(1024 * 1024));
+        pipeline.addLast(new HttpInboundHandler());
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
index c20c9be5..1ae339f2 100644
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/HttpOutboundHandler.java
@@ -1,163 +1,99 @@
 package io.github.kimmking.gateway.outbound.httpclient4;
 
-
+import io.github.kimmking.gateway.filter.HeaderHttpRequestFilter;
 import io.github.kimmking.gateway.filter.HeaderHttpResponseFilter;
 import io.github.kimmking.gateway.filter.HttpRequestFilter;
 import io.github.kimmking.gateway.filter.HttpResponseFilter;
-import io.github.kimmking.gateway.router.HttpEndpointRouter;
 import io.github.kimmking.gateway.router.RandomHttpEndpointRouter;
 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 io.netty.handler.codec.http.*;
+import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
+import org.apache.http.client.config.RequestConfig;
 import org.apache.http.client.methods.HttpGet;
 import org.apache.http.concurrent.FutureCallback;
+import org.apache.http.impl.client.HttpClients;
 import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
 import org.apache.http.impl.nio.client.HttpAsyncClients;
-import org.apache.http.impl.nio.reactor.IOReactorConfig;
-import org.apache.http.protocol.HTTP;
 import org.apache.http.util.EntityUtils;
 
+import java.io.IOException;
 import java.util.List;
-import java.util.Random;
-import java.util.concurrent.*;
-import java.util.logging.Filter;
-import java.util.stream.Collectors;
-
-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;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 11:05
+ **/
 public class HttpOutboundHandler {
-    
-    private CloseableHttpAsyncClient httpclient;
-    private ExecutorService proxyService;
+    private CloseableHttpAsyncClient httpClient;
+    private ExecutorService executorService;
+    private HttpRequestFilter requestFilter = new HeaderHttpRequestFilter();
+    private HttpResponseFilter responseFilter = new HeaderHttpResponseFilter();
+    private RandomHttpEndpointRouter router = new RandomHttpEndpointRouter();
     private List<String> backendUrls;
 
-    HttpResponseFilter filter = new HeaderHttpResponseFilter();
-    HttpEndpointRouter router = new RandomHttpEndpointRouter();
-
-    public HttpOutboundHandler(List<String> backends) {
-
-        this.backendUrls = backends.stream().map(this::formatUrl).collect(Collectors.toList());
-
-        int cores = Runtime.getRuntime().availableProcessors();
-        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);
-        
-        IOReactorConfig ioConfig = IOReactorConfig.custom()
-                .setConnectTimeout(1000)
-                .setSoTimeout(1000)
-                .setIoThreadCount(cores)
-                .setRcvBufSize(32 * 1024)
-                .build();
-        
-        httpclient = HttpAsyncClients.custom().setMaxConnTotal(40)
-                .setMaxConnPerRoute(8)
-                .setDefaultIOReactorConfig(ioConfig)
-                .setKeepAliveStrategy((response,context) -> 6000)
-                .build();
-        httpclient.start();
+    public HttpOutboundHandler(List<String> backendUrls) {
+        this.backendUrls = backendUrls;
+        int threadSize = Runtime.getRuntime().availableProcessors();
+        executorService = new ThreadPoolExecutor(threadSize, threadSize, 1, TimeUnit.MINUTES, new LinkedBlockingDeque<Runnable>(100), new ThreadPoolExecutor.CallerRunsPolicy());
+        RequestConfig config = RequestConfig.custom().setConnectTimeout(2000).setSocketTimeout(2000).setConnectionRequestTimeout(2000).build();
+        httpClient = HttpAsyncClients.custom().setDefaultRequestConfig(config).build();
+        httpClient.start();
     }
 
-    private String formatUrl(String backend) {
-        return backend.endsWith("/")?backend.substring(0,backend.length()-1):backend;
-    }
-    
-    public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx, HttpRequestFilter filter) {
+    public void handle(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx) {
         String backendUrl = router.route(this.backendUrls);
         final String url = backendUrl + fullRequest.uri();
-        filter.filter(fullRequest, ctx);
-        proxyService.submit(()->fetchGet(fullRequest, ctx, url));
+        requestFilter.filter(fullRequest, ctx);
+        executorService.submit(() -> httpGet(fullRequest, ctx, url));
     }
-    
-    private void fetchGet(final FullHttpRequest inbound, final ChannelHandlerContext ctx, final String url) {
-        final HttpGet httpGet = new HttpGet(url);
-        //httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_CLOSE);
-        httpGet.setHeader(HTTP.CONN_DIRECTIVE, HTTP.CONN_KEEP_ALIVE);
-        httpGet.setHeader("mao", inbound.headers().get("mao"));
 
-        httpclient.execute(httpGet, new FutureCallback<HttpResponse>() {
+    private void httpGet(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx, final String url) {
+        final HttpGet httpGet = new HttpGet(url);
+        httpGet.setHeader("token", fullRequest.headers().get("token"));
+        httpClient.execute(httpGet, new FutureCallback<HttpResponse>() {
             @Override
-            public void completed(final HttpResponse endpointResponse) {
-                try {
-                    handleResponse(inbound, ctx, endpointResponse);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                } finally {
-                    
-                }
+            public void completed(HttpResponse httpResponse) {
+                handleResponse(fullRequest, ctx, httpResponse);
             }
-            
+
             @Override
-            public void failed(final Exception ex) {
-                httpGet.abort();
-                ex.printStackTrace();
+            public void failed(Exception e) {
+
             }
-            
+
             @Override
             public void cancelled() {
-                httpGet.abort();
+
             }
         });
     }
-    
-    private void handleResponse(final FullHttpRequest fullRequest, final ChannelHandlerContext ctx, final HttpResponse endpointResponse) throws Exception {
+
+    private void handleResponse(final FullHttpRequest fullHttpRequest, final ChannelHandlerContext ctx, HttpResponse httpResponse) {
+        HttpEntity entity = httpResponse.getEntity();
         FullHttpResponse response = null;
         try {
-//            String value = "hello,kimmking";
-//            response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(value.getBytes("UTF-8")));
-//            response.headers().set("Content-Type", "application/json");
-//            response.headers().setInt("Content-Length", response.content().readableBytes());
-    
-    
-            byte[] body = EntityUtils.toByteArray(endpointResponse.getEntity());
-//            System.out.println(new String(body));
-//            System.out.println(body.length);
-    
-            response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(body));
-
+            response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
+                    HttpResponseStatus.OK, Unpooled.wrappedBuffer(EntityUtils.toByteArray(entity)));
             response.headers().set("Content-Type", "application/json");
-            response.headers().setInt("Content-Length", Integer.parseInt(endpointResponse.getFirstHeader("Content-Length").getValue()));
-
-            filter.filter(response);
-
-//            for (Header e : endpointResponse.getAllHeaders()) {
-//                //response.headers().set(e.getName(),e.getValue());
-//                System.out.println(e.getName() + " => " + e.getValue());
-//            } 
-        
-        } catch (Exception e) {
+            response.headers().setInt("Content-Length", Integer.parseInt(httpResponse.getFirstHeader("Content-Length").getValue()));
+            responseFilter.filter(response);
+            ctx.write(response);
+            ctx.flush();
+        } catch (IOException e) {
             e.printStackTrace();
-            response = new DefaultFullHttpResponse(HTTP_1_1, NO_CONTENT);
-            exceptionCaught(ctx, e);
         } finally {
-            if (fullRequest != null) {
-                if (!HttpUtil.isKeepAlive(fullRequest)) {
-                    ctx.write(response).addListener(ChannelFutureListener.CLOSE);
-                } else {
-                    //response.headers().set(CONNECTION, KEEP_ALIVE);
-                    ctx.write(response);
-                }
+            if (!HttpUtil.isKeepAlive(fullHttpRequest)) {
+                ctx.write(response).addListener(ChannelFutureListener.CLOSE);
             }
-            ctx.flush();
-            //ctx.close();
         }
-        
-    }
-    
-    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-        cause.printStackTrace();
-        ctx.close();
     }
-    
-    
 }
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/NamedThreadFactory.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/NamedThreadFactory.java
deleted file mode 100644
index 726beb9d..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/httpclient4/NamedThreadFactory.java
+++ /dev/null
@@ -1,32 +0,0 @@
-package io.github.kimmking.gateway.outbound.httpclient4;
-
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.atomic.AtomicInteger;
-
-public class NamedThreadFactory implements ThreadFactory {
-    
-    private final ThreadGroup group;
-    private final AtomicInteger threadNumber = new AtomicInteger(1);
-    
-    private final String namePrefix;
-    private final boolean daemon;
-    
-    public NamedThreadFactory(String namePrefix, boolean daemon) {
-        this.daemon = daemon;
-        SecurityManager s = System.getSecurityManager();
-        group = (s != null) ? s.getThreadGroup() :
-                Thread.currentThread().getThreadGroup();
-        this.namePrefix = namePrefix;
-    }
-    
-    public NamedThreadFactory(String namePrefix) {
-        this(namePrefix, false);
-    }
-    
-    @Override
-    public Thread newThread(Runnable r) {
-        Thread t = new Thread(group, r, namePrefix + "-thread-" + threadNumber.getAndIncrement(), 0);
-        t.setDaemon(daemon);
-        return t;
-    }
-}
\ No newline at end of file
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/HttpClientInboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/HttpClientInboundHandler.java
new file mode 100644
index 00000000..405f4e4b
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/HttpClientInboundHandler.java
@@ -0,0 +1,26 @@
+package io.github.kimmking.gateway.outbound.netty4;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.handler.codec.http.*;
+import io.netty.util.CharsetUtil;
+
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 12:14
+ **/
+public class HttpClientInboundHandler extends ChannelInboundHandlerAdapter {
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        if (msg instanceof HttpResponse) {
+            FullHttpResponse response = (FullHttpResponse) msg;
+            ByteBuf buf = response.content();
+            String result = buf.toString(CharsetUtil.UTF_8);
+            System.out.println("response -> "+result);
+
+        }
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
deleted file mode 100644
index 79aeb148..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClient.java
+++ /dev/null
@@ -1,51 +0,0 @@
-//package io.github.kimmking.gateway.outbound;
-//
-//import io.netty.bootstrap.Bootstrap;
-//import io.netty.channel.ChannelFuture;
-//import io.netty.channel.ChannelInitializer;
-//import io.netty.channel.ChannelOption;
-//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.handler.codec.http.HttpRequestEncoder;
-//import io.netty.handler.codec.http.HttpResponseDecoder;
-//
-//public class NettyHttpClient {
-//    public void connect(String host, int port) throws Exception {
-//        EventLoopGroup workerGroup = new NioEventLoopGroup();
-//
-//        try {
-//            Bootstrap b = new Bootstrap();
-//            b.group(workerGroup);
-//            b.channel(NioSocketChannel.class);
-//            b.option(ChannelOption.SO_KEEPALIVE, true);
-//            b.handler(new ChannelInitializer<SocketChannel>() {
-//                @Override
-//                public void initChannel(SocketChannel ch) throws Exception {
-//                    // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
-//                    ch.pipeline().addLast(new HttpResponseDecoder());
-//                     客户端发送的是httprequest，所以要使用HttpRequestEncoder进行编码
-//                    ch.pipeline().addLast(new HttpRequestEncoder());
-//                    ch.pipeline().addLast(new HttpClientOutboundHandler());
-//                }
-//            });
-//
-//            // Start the client.
-//            ChannelFuture f = b.connect(host, port).sync();
-//
-//           
-//            f.channel().write(request);
-//            f.channel().flush();
-//            f.channel().closeFuture().sync();
-//        } finally {
-//            workerGroup.shutdownGracefully();
-//        }
-//
-//    }
-//
-//    public static void main(String[] args) throws Exception {
-//        NettyHttpClient client = new NettyHttpClient();
-//        client.connect("127.0.0.1", 8844);
-//    }
-//}
\ No newline at end of file
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClientOutboundHandler.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClientOutboundHandler.java
deleted file mode 100644
index 6730cd5a..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/netty4/NettyHttpClientOutboundHandler.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package io.github.kimmking.gateway.outbound.netty4;
-
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
-
-public class NettyHttpClientOutboundHandler  extends ChannelInboundHandlerAdapter {
-    
-    @Override
-    public void channelActive(ChannelHandlerContext ctx)
-            throws Exception {
-        
-        
-    }
-    
-    @Override
-    public void channelRead(ChannelHandlerContext ctx, Object msg)
-            throws Exception {
-        
-        
-        
-    }
-}
\ No newline at end of file
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
deleted file mode 100644
index 5f194588..00000000
--- a/02nio/nio02/src/main/java/io/github/kimmking/gateway/outbound/okhttp/OkhttpOutboundHandler.java
+++ /dev/null
@@ -1,4 +0,0 @@
-package io.github.kimmking.gateway.outbound.okhttp;
-
-public class OkhttpOutboundHandler {
-}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/server/NettyHttpServer.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/server/NettyHttpServer.java
new file mode 100644
index 00000000..5517ac37
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/server/NettyHttpServer.java
@@ -0,0 +1,49 @@
+package io.github.kimmking.gateway.server;
+
+/**
+ * @program: netty-gateway
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-23 09:35
+ **/
+
+import io.github.kimmking.gateway.inbound.HttpRequestServerInitializer;
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+
+@Data
+@Slf4j
+public class NettyHttpServer {
+    private int port;
+
+    public NettyHttpServer(int port) {
+        this.port = port;
+    }
+
+    public void start() {
+        ServerBootstrap bootstrap = new ServerBootstrap();
+        int threadSize = Runtime.getRuntime().availableProcessors();
+        //创建主线程组，接收请求
+        EventLoopGroup bossGroup = new NioEventLoopGroup(threadSize);
+        //创建从线程组，处理主线程组分配下来的io操作
+        EventLoopGroup workerGroup = new NioEventLoopGroup(threadSize * 2);
+        bootstrap.group(bossGroup, workerGroup)
+                .channel(NioServerSocketChannel.class)
+                .childHandler(new HttpRequestServerInitializer());
+        try {
+            ChannelFuture channelFuture = bootstrap.bind(port).sync();
+            channelFuture.channel().closeFuture().sync();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } finally {
+            // 释放资源
+            workerGroup.shutdownGracefully();
+            bossGroup.shutdownGracefully();
+        }
+    }
+}
diff --git a/02nio/nio02/src/main/java/io/github/kimmking/gateway/util/HttpUtil.java b/02nio/nio02/src/main/java/io/github/kimmking/gateway/util/HttpUtil.java
new file mode 100644
index 00000000..bec05f0b
--- /dev/null
+++ b/02nio/nio02/src/main/java/io/github/kimmking/gateway/util/HttpUtil.java
@@ -0,0 +1,110 @@
+package io.github.kimmking.gateway.util;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @program: boss-crm
+ * @description:
+ * @author: Yu Bin
+ * @create: 2021-05-17 11:47
+ **/
+public class HttpUtil {
+    private static int socketTimeout = 2000;
+
+    private static int connectTimeout = 2000;
+
+    private static int connectionRequestTimeout = 2000;
+
+    public static CloseableHttpClient createCloseableHttpClient() {
+        RequestConfig config = RequestConfig.custom().setConnectTimeout(connectTimeout).setSocketTimeout(socketTimeout).setConnectionRequestTimeout(connectionRequestTimeout).build();
+        return HttpClients.custom().setDefaultRequestConfig(config).build();
+    }
+
+    public static String getJsonByApi(String url) throws IOException {
+        if (StringUtils.isBlank(url)) {
+            return StringUtils.EMPTY;
+        }
+        HttpGet httpGet = null;
+        CloseableHttpResponse response = null;
+        try {
+            httpGet = new HttpGet(url);
+            response = HttpUtil.createCloseableHttpClient().execute(httpGet);
+            HttpEntity entity = response.getEntity();
+            if (entity == null) {
+                return StringUtils.EMPTY;
+            }
+            return EntityUtils.toString(entity, "UTF-8");
+        } finally {
+            if (httpGet != null) {
+                httpGet.releaseConnection();
+            }
+            if (response != null) {
+                response.close();
+            }
+        }
+    }
+
+    public static String postJsonByApi(String url, Map<String, String> param) throws UnsupportedEncodingException, IOException {
+        if (StringUtils.isBlank(url)) {
+            return StringUtils.EMPTY;
+        }
+        HttpPost httpPost = null;
+        CloseableHttpResponse response = null;
+        try {
+            httpPost = new HttpPost(url);
+            httpPost.setEntity(getEntity(param));
+            response = HttpUtil.createCloseableHttpClient().execute(httpPost);
+            HttpEntity entity = response.getEntity();
+            if (entity == null) {
+                return StringUtils.EMPTY;
+            }
+            return EntityUtils.toString(entity, "UTF-8");
+        } finally {
+            if (httpPost != null) {
+                httpPost.releaseConnection();
+            }
+            if (response != null) {
+                response.close();
+            }
+        }
+    }
+
+    private static HttpEntity getEntity(Map<String, String> paramMap) throws UnsupportedEncodingException {
+        List<NameValuePair> nvps = new ArrayList<>();
+        for (Map.Entry<String, String> entry : paramMap.entrySet()) {
+            String key = entry.getKey();
+            String value = entry.getValue();
+            nvps.add(new BasicNameValuePair(key, value));
+        }
+        return new UrlEncodedFormEntity(nvps, "UTF-8");
+    }
+
+    public static void main(String[] args) {
+        try {
+            System.out.println(HttpUtil.getJsonByApi("http://localhost:8088/api/hello"));
+            Map<String, String> param = new HashMap<>();
+            param.put("key1", "yubin");
+            System.out.println(HttpUtil.postJsonByApi("http://localhost:8088/api/hello", param));
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}