diff --git a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerCodecHandler.java b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerCodecHandler.java
index 9f996e6b..52b35d75 100644
--- a/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerCodecHandler.java
+++ b/net/src/main/java/com/zfoo/net/core/proxy/handler/TunnelServerCodecHandler.java
@@ -92,7 +92,11 @@ public class TunnelServerCodecHandler extends ByteToMessageCodec<TunnelProtocolS
         }
 
         var retainedByteBuf = in.readRetainedSlice(length);
-        session.getChannel().writeAndFlush(TunnelProtocolServer2Client.valueOf(sid, uid, retainedByteBuf));
+        try {
+            session.getChannel().writeAndFlush(TunnelProtocolServer2Client.valueOf(sid, uid, retainedByteBuf));
+        } catch (Throwable t) {
+            ReferenceCountUtil.release(retainedByteBuf);
+        }
     }
 
     @Override