删除原先转发的逻辑

Author: wangqifox

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.debug("proxy_pass {}", url.toString());
 
         // 请求路径
         QueryStringEncoder queryStringEncoder = new QueryStringEncoder(url.getPath());

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

@@ -21,10 +21,6 @@ public void operationComplete(ChannelFuture future) throws Exception {
             Channel channel = future.channel();
             Boolean keepAlive = ContextUtil.getKeepAlive(channel);
 
-//        if (ContextUtil.getRequest(channel) != null) {
-//            ContextUtil.getRequest(channel).release();
-//        }
-
             if (keepAlive == null || !keepAlive) {
                 channel.close();
             }

src/main/java/love/wangqi/exception/GatewayNoRouteException.java

@@ -13,4 +13,8 @@ public GatewayNoRouteException() {
         super(HttpResponseStatus.NOT_FOUND, "no route found");
     }
 
+    @Override
+    public synchronized Throwable fillInStackTrace() {
+        return this;
+    }
 }

src/main/java/love/wangqi/exception/handler/DefaultExceptionHandler.java

@@ -44,7 +44,6 @@ public ExceptionResponse getExceptionResponse(Exception exception) {
     public void send(Channel channel, ExceptionResponse exceptionResponse) {
         String content = exceptionResponse.getContent();
         FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, exceptionResponse.getStatus());
-        response.headers().set(HttpHeaderNames.CONTENT_LENGTH, response.content().readableBytes());
         if (content != null) {
             response.headers().set("X-Ca-Error-Message", content);
         }

src/main/java/love/wangqi/filter/SendForwardFilter.java

@@ -6,7 +6,7 @@
 import love.wangqi.codec.RequestHolder;
 import love.wangqi.config.GatewayConfig;
 import love.wangqi.context.ContextUtil;
-import love.wangqi.filter.command.ForwardRunner;
+import love.wangqi.handler.back.BackClientPool;
 
 /**
  * @author: wangqi
@@ -33,8 +33,8 @@ public synchronized void filter(Channel channel) throws Exception {
 
         FullHttpRequest httpRequest = ContextUtil.getRequest(channel);
         RequestHolder requestHolder = httpRequestBuilder.build(httpRequest);
+        httpRequest.release();
 
-        ForwardRunner forwardRunner = new ForwardRunner(channel, requestHolder);
-        forwardRunner.execute();
+        BackClientPool.INSTANCE.request(requestHolder, channel);
     }
 }

src/main/java/love/wangqi/filter/command/ForwardRunner.java

@@ -1,4 +1,4 @@
-package love.wangqi.filter.command;
+package love.wangqi.handler.back;
 
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.Channel;
@@ -25,16 +25,16 @@
  * @description:
  * @date: Created in 2018-11-27 16:14
  */
-public class HttpClientPool {
-    private final static Logger logger = LoggerFactory.getLogger(HttpClientPool.class);
+public class BackClientPool {
+    private final static Logger logger = LoggerFactory.getLogger(BackClientPool.class);
 
     private final EventLoopGroup group = new NioEventLoopGroup(8 * 4);
     private final Bootstrap bootstrap = new Bootstrap();
     private ChannelPoolMap<RequestHolder, SimpleChannelPool> poolMap;
 
-    public static final HttpClientPool INSTANCE = new HttpClientPool();
+    public static final BackClientPool INSTANCE = new BackClientPool();
 
-    private HttpClientPool() {
+    private BackClientPool() {
         bootstrap
                 .group(group)
                 .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 500)
@@ -45,7 +45,7 @@ private HttpClientPool() {
         poolMap = new AbstractChannelPoolMap<RequestHolder, SimpleChannelPool>() {
             @Override
             protected SimpleChannelPool newPool(RequestHolder requestHolder) {
-                return new FixedChannelPool(bootstrap.remoteAddress(requestHolder.getSocketAddress()), new HttpPoolHandler(requestHolder), 50);
+                return new FixedChannelPool(bootstrap.remoteAddress(requestHolder.getSocketAddress()), new BackPoolHandler(requestHolder), 50);
             }
         };
     }
@@ -67,8 +67,6 @@ public synchronized void request(RequestHolder requestHolder, Channel serverChan
                     clientChannel.write(bodyRequestEncoder);
                 }
                 clientChannel.flush();
-
-//                pool.release(clientChannel);
             }
         });
     }

src/main/java/love/wangqi/handler/BackendFilter.java

@@ -1,4 +1,4 @@
-package love.wangqi.filter.command;
+package love.wangqi.handler.back;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
@@ -17,10 +17,10 @@
  * @description:
  * @date: Created in 2018-11-28 08:37
  */
-public class HttpHandler extends SimpleChannelInboundHandler<FullHttpResponse> {
-    private Logger logger = LoggerFactory.getLogger(HttpHandler.class);
+public class BackHandler extends SimpleChannelInboundHandler<FullHttpResponse> {
+    private Logger logger = LoggerFactory.getLogger(BackHandler.class);
 
-    public HttpHandler() {
+    public BackHandler() {
         super(false);
     }