From d9a1164c71b939eaaaddb4727c0c5ad0751aacc9 Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Sun, 6 Jul 2025 17:58:16 +0800 Subject: [PATCH] fix[cache]: do not close session whe tunnel is exception --- .../net/core/proxy/handler/TunnelClientRouteHandler.java | 4 ++++ .../net/core/proxy/handler/TunnelServerRouteHandler.java | 5 +++++ 2 files changed, 9 insertions(+) diff --git a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java index e73229ff..9deb35a1 100644 --- a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java +++ b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelClientRouteHandler.java @@ -57,4 +57,8 @@ public class TunnelClientRouteHandler extends BaseRouteHandler { NetContext.getRouter().receive(session, tunnelPacketInfo.packet, tunnelPacketInfo.attachment); } + @Override + public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { + logger.error("{} session exception:[{}]", SessionUtils.sessionSimpleInfo(ctx), cause.getMessage()); + } } diff --git a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java index fb314b8a..313d981b 100644 --- a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java +++ b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerRouteHandler.java @@ -44,4 +44,9 @@ public class TunnelServerRouteHandler extends BaseRouteHandler { TunnelServer.tunnels.remove(ctx.channel()); logger.warn("tunnel server channel is inactive {}", SessionUtils.sessionSimpleInfo(ctx)); } + + @Override + public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { + logger.error("{} session exception:[{}]", SessionUtils.sessionSimpleInfo(ctx), cause.getMessage()); + } }