替换SimpleChannelInboundHandler

Author: wangqifox

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

@@ -46,7 +46,7 @@ private HttpClientPool() {
             @Override
             protected SimpleChannelPool newPool(RequestHolder requestHolder) {
                 logger.debug("address: {}", requestHolder.getSocketAddress());
-                return new FixedChannelPool(bootstrap.remoteAddress(requestHolder.getSocketAddress()), new HttpPoolHandler(requestHolder), 1);
+                return new FixedChannelPool(bootstrap.remoteAddress(requestHolder.getSocketAddress()), new HttpPoolHandler(requestHolder), 50);
             }
         };
     }

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

@@ -2,7 +2,6 @@
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.handler.codec.http.FullHttpResponse;
 import io.netty.handler.timeout.ReadTimeoutException;
@@ -16,20 +15,17 @@
 /**
  * @author: wangqi
  * @description:
- * @date: Created in 2018-11-26 20:59
+ * @date: Created in 2018-11-28 08:37
  */
-public class HttpHandler extends ChannelInboundHandlerAdapter {
+public class HttpHandler extends SimpleChannelInboundHandler<FullHttpResponse> {
     private Logger logger = LoggerFactory.getLogger(HttpHandler.class);
 
-    @Override
-    public void channelActive(ChannelHandlerContext ctx) throws Exception {
-        System.out.println("channelActive");
-        super.channelActive(ctx);
+    public HttpHandler() {
+        super(false);
     }
 
     @Override
-    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        FullHttpResponse response = (FullHttpResponse) msg;
+    protected void channelRead0(ChannelHandlerContext ctx, FullHttpResponse response) throws Exception {
         logger.debug("handler hashCode: {}", this.hashCode());
         logger.debug("clientChannelId: {}", ctx.channel().id());
         Channel serverChannel = ctx.channel().attr(Attributes.SERVER_CHANNEL).get();
@@ -40,6 +36,12 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
         GatewayRunner.getInstance().postRoutAction(serverChannel);
     }
 
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        System.out.println("channelActive");
+        super.channelActive(ctx);
+    }
+
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
         Channel serverChannel = ctx.channel().attr(Attributes.SERVER_CHANNEL).get();

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

@@ -11,15 +11,12 @@
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
 import io.netty.handler.stream.ChunkedWriteHandler;
-import io.netty.handler.timeout.ReadTimeoutHandler;
 import love.wangqi.codec.RequestHolder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import javax.net.ssl.SSLException;
 
-import java.util.concurrent.TimeUnit;
-
 import static love.wangqi.context.Constants.HTTPS;
 
 /**