tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-23 22:27:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[net]: 网络协议序列化的bytebuf使用池化对象

Browse Source
This commit is contained in:
jaysunxiao
2021-07-14 18:28:26 +08:00
parent 975225d505
commit e636ad342a
3 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/handler/codec/udp/UdpCodecHandler.java
+1 -4
View File
@@ -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<DatagramPacket, Encod
@Override
protected void encode(ChannelHandlerContext channelHandlerContext, EncodedPacketInfo out, List<Object> 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());
net/src/main/java/com/zfoo/net/handler/codec/websocket/WebSocketCodecHandler.java
+1 -3
View File
@@ -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<WebSocketFrame,
@Override
protected void encode(ChannelHandlerContext channelHandlerContext, EncodedPacketInfo out, List<Object> 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));
net/src/main/java/com/zfoo/net/packet/service/PacketService.java
-2
View File
@@ -126,8 +126,6 @@ public class PacketService implements IPacketService {
return;
}
buffer.clear();
// 预留写入包的长度，一个int字节大小
buffer.writeInt(PACKET_HEAD_LENGTH);