[xuxueli#50] XXL RST ERROR xuxueli#50

gezhiwei8899 · Mar 31, 2023 · 74b2588 · 74b2588
1 parent eeaa1bd
commit 74b2588
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/...ain/java/com/xxl/rpc/core/remoting/net/impl/netty_http/client/NettyHttpClientHandler.java b/...ain/java/com/xxl/rpc/core/remoting/net/impl/netty_http/client/NettyHttpClientHandler.java
@@ -9,11 +9,14 @@
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.handler.codec.http.FullHttpResponse;
+import io.netty.handler.codec.http.HttpHeaders;
 import io.netty.handler.codec.http.HttpResponseStatus;
 import io.netty.handler.timeout.IdleStateEvent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.Objects;
+
 /**
  * netty_http
  *
@@ -40,6 +43,14 @@ protected void channelRead0(ChannelHandlerContext ctx, FullHttpResponse msg) thr
             throw new XxlRpcException("xxl-rpc response status invalid.");
         }
 
+        HttpHeaders headers = msg.headers();
+        String connection = headers.get("connection");
+        if (Objects.equals("close", connection)) {
+            logger.warn(">>>>>>>>>>> xxl-rpc netty_http client received close");
+            ctx.close();
+            return;
+        }
+
         // response parse
         byte[] responseBytes = ByteBufUtil.getBytes(msg.content());