From e636ad342aab44687a2d7b372e865b59a25954a2 Mon Sep 17 00:00:00 2001 From: jaysunxiao Date: Wed, 14 Jul 2021 18:28:26 +0800 Subject: [PATCH] =?UTF-8?q?perf[net]:=20=E7=BD=91=E7=BB=9C=E5=8D=8F?= =?UTF-8?q?=E8=AE=AE=E5=BA=8F=E5=88=97=E5=8C=96=E7=9A=84bytebuf=E4=BD=BF?= =?UTF-8?q?=E7=94=A8=E6=B1=A0=E5=8C=96=E5=AF=B9=E8=B1=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/zfoo/net/handler/codec/udp/UdpCodecHandler.java | 5 +---- .../net/handler/codec/websocket/WebSocketCodecHandler.java | 4 +--- .../main/java/com/zfoo/net/packet/service/PacketService.java | 2 -- 3 files changed, 2 insertions(+), 9 deletions(-) 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);