判断keep-alive

Author: wangqifox

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

@@ -44,7 +44,7 @@ public ForwardCommand(ChannelHandlerContext ctx, RequestHolder requestHolder) {
                         // command配置
                         .andCommandPropertiesDefaults(
                             HystrixCommandProperties.Setter()
-                                .withExecutionTimeoutInMilliseconds(100)
+                                .withExecutionTimeoutInMilliseconds(1000)
                                 .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE)
                                 .withFallbackIsolationSemaphoreMaxConcurrentRequests(10000)
                         )

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

@@ -4,6 +4,8 @@
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.codec.http.FullHttpRequest;
 import io.netty.handler.codec.http.HttpResponseStatus;
+import io.netty.handler.codec.http.HttpUtil;
+import love.wangqi.context.RequestConstant;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import love.wangqi.context.HttpRequestContext;
@@ -32,6 +34,9 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
             httpRequest = (FullHttpRequest) msg;
             httpRequestContext.setChannelHandlerContext(httpRequest, ctx);
 
+            Boolean keepAlive = HttpUtil.isKeepAlive(httpRequest);
+            httpRequestContext.set(httpRequest, RequestConstant.KEEPALIVE, keepAlive);
+
             runner = GatewayRunner.getInstance();
             runner.forwardAction(httpRequest);
         } catch (Throwable e) {