保持客户端连接池连接

Author: wangqifox

src/main/java/love/wangqi/GatewayServerDemo.java

@@ -32,7 +32,7 @@ protected List<Route> locateRouteList(Set<Long> ids) {
                 List<Route> routeList = new ArrayList<>();
                 try {
                     routeList.add(new Route(1L, HttpMethod.GET, "/", new URL("https://blog.wangqi.love/")));
-                    routeList.add(new Route(2L, HttpMethod.GET, "/baidu", new URL("http://www.baidu.com/")));
+                    routeList.add(new Route(2L, HttpMethod.GET, "/baidu", new URL("https://www.baidu.com/")));
                     routeList.add(new Route(3L, HttpMethod.GET, "/taobao", new URL("https://www.taobao.com/")));
                     routeList.add(new Route(4L, HttpMethod.GET, "/github", new URL("https://github.com/")));
                     routeList.add(new Route(5L, HttpMethod.GET, "/oschina", new URL("https://www.oschina.net/")));

src/main/java/love/wangqi/codec/DefaultHttpRequestBuilder.java

@@ -57,7 +57,7 @@ public RequestHolder build(FullHttpRequest originRequest) throws Exception {
             throw new GatewayNoRouteException();
         }
         URL url  = route.getMapUrl();
-//        logger.info(url.toString());
+        logger.info(url.toString());
 
         // 请求路径
         QueryStringEncoder queryStringEncoder = new QueryStringEncoder(url.getPath());
@@ -76,6 +76,7 @@ public RequestHolder build(FullHttpRequest originRequest) throws Exception {
         });
         newRequest.headers().remove(HttpHeaderNames.COOKIE);
         newRequest.headers().set(HttpHeaderNames.HOST, url.getHost());
+        HttpUtil.setKeepAlive(newRequest, true);
 
         // 请求体
         String contentType = httpRequestDecomposer.getContentType();

src/main/java/love/wangqi/core/DefaultChannelWriteFinishListener.java

@@ -19,6 +19,7 @@ public class DefaultChannelWriteFinishListener implements ChannelFutureListener
     public void operationComplete(ChannelFuture future) throws Exception {
         Channel channel = future.channel();
         Boolean keepAlive = ContextUtil.getKeepAlive(channel);
+        logger.debug("keepAlive {}", keepAlive);
         logger.debug("======= serverChannelId: {}", channel.id());
 
         ContextUtil.getRequest(channel).release();