diff --git a/net/src/main/java/com/zfoo/net/handler/codec/udp/UdpCodecHandler.java b/net/src/main/java/com/zfoo/net/handler/codec/udp/UdpCodecHandler.java index a1fb006a..21c8a7df 100644 --- a/net/src/main/java/com/zfoo/net/handler/codec/udp/UdpCodecHandler.java +++ b/net/src/main/java/com/zfoo/net/handler/codec/udp/UdpCodecHandler.java @@ -21,7 +21,6 @@ import com.zfoo.net.util.SessionUtils; import com.zfoo.protocol.util.JsonUtils; import com.zfoo.protocol.util.StringUtils; import io.netty.buffer.ByteBuf; -import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.socket.DatagramPacket; import io.netty.handler.codec.MessageToMessageCodec; @@ -85,9 +84,7 @@ public class UdpCodecHandler extends MessageToMessageCodec list) { try { - ByteBuf byteBuf = Unpooled.directBuffer(); - byteBuf.clear(); - + var byteBuf = channelHandlerContext.alloc().ioBuffer(); var udpPacketAttachment = (UdpPacketAttachment) out.getPacketAttachment(); NetContext.getPacketService().write(byteBuf, out.getPacket(), out.getPacketAttachment()); 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 3c1f3e39..1a2c948d 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 @@ -21,7 +21,6 @@ import com.zfoo.net.util.SessionUtils; import com.zfoo.protocol.util.JsonUtils; import com.zfoo.protocol.util.StringUtils; import io.netty.buffer.ByteBuf; -import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandlerContext; import io.netty.handler.codec.MessageToMessageCodec; import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame; @@ -86,8 +85,7 @@ public class WebSocketCodecHandler extends MessageToMessageCodec list) { try { - ByteBuf byteBuf = Unpooled.directBuffer(); - byteBuf.clear(); + var byteBuf = channelHandlerContext.alloc().ioBuffer(); NetContext.getPacketService().write(byteBuf, out.getPacket(), out.getPacketAttachment()); list.add(new BinaryWebSocketFrame(byteBuf)); diff --git a/net/src/main/java/com/zfoo/net/packet/service/PacketService.java b/net/src/main/java/com/zfoo/net/packet/service/PacketService.java index b0cc4e06..dd63032a 100644 --- a/net/src/main/java/com/zfoo/net/packet/service/PacketService.java +++ b/net/src/main/java/com/zfoo/net/packet/service/PacketService.java @@ -126,8 +126,6 @@ public class PacketService implements IPacketService { return; } - buffer.clear(); - // 预留写入包的长度,一个int字节大小 buffer.writeInt(PACKET_HEAD_LENGTH);