Merge pull request #51 from gezhiwei8899/master

[#50] XXL RST ERROR #50
xuxueli · Nov 23, 2024 · 87b47dc · 87b47dc
2 parents 755360c + 74b2588
commit 87b47dc
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());