diff --git a/net/src/main/java/com/zfoo/net/handler/codec/tcp/TcpPacketCodecHandler.java b/net/src/main/java/com/zfoo/net/handler/codec/tcp/TcpPacketCodecHandler.java index e3e3d96c..0ef45430 100644 --- a/net/src/main/java/com/zfoo/net/handler/codec/tcp/TcpPacketCodecHandler.java +++ b/net/src/main/java/com/zfoo/net/handler/codec/tcp/TcpPacketCodecHandler.java @@ -52,9 +52,8 @@ public class TcpPacketCodecHandler extends ByteToMessageCodec // 如果长度非法,则抛出异常断开连接 if (length < 0) { - throw new IllegalArgumentException(StringUtils - .format("[session:{}]的包头长度[length:{}]非法" - , SessionUtils.sessionInfo(ctx), length)); + throw new IllegalArgumentException(StringUtils.format("[session:{}]的包头长度[length:{}]非法" + , SessionUtils.sessionInfo(ctx), length)); } // ByteBuf里的数据太小 @@ -63,8 +62,9 @@ public class TcpPacketCodecHandler extends ByteToMessageCodec return; } - var tmpByteBuf = in.readRetainedSlice(length); + ByteBuf tmpByteBuf = null; try { + tmpByteBuf = in.readRetainedSlice(length); DecodedPacketInfo packetInfo = NetContext.getPacketService().read(tmpByteBuf); out.add(packetInfo); } catch (Exception e) { diff --git a/net/src/main/java/com/zfoo/net/handler/codec/websocket/WebSocketCodecHandler.java b/net/src/main/java/com/zfoo/net/handler/codec/websocket/WebSocketCodecHandler.java index b7284e44..5d08982c 100644 --- a/net/src/main/java/com/zfoo/net/handler/codec/websocket/WebSocketCodecHandler.java +++ b/net/src/main/java/com/zfoo/net/handler/codec/websocket/WebSocketCodecHandler.java @@ -60,9 +60,8 @@ public class WebSocketCodecHandler extends MessageToMessageCodec