RelayHandler clone relayChannel whent exceptionCaught. #2152

2024-04-21 10:21:39 +00:00 · 2022-04-18 20:50:12 +08:00
parent 39760baf17
commit 92483fca8f
1 changed files with 7 additions and 1 deletions
@@ -41,6 +41,12 @@ public final class RelayHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        logger.error("RelayHandler error", cause);
-        ctx.close();
+        try {
+            if (relayChannel.isActive()) {
+                relayChannel.close();
+            }
+        } finally {
+            ctx.close();
+        }
    }
 }