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

perf[encode]: serialization error prints the error log

Browse Source
This commit is contained in:
godotg
2024-01-20 18:46:18 +08:00
parent 950f90a022
commit c411a80855
1 changed files with 26 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/packet/PacketService.java
+26 -21
View File
@@ -164,30 +164,35 @@ public class PacketService implements IPacketService {
logger.error("packet is null and can not be sent.");
return;
}
try {
// 预留写入包的长度，一个int字节大小
buffer.writeInt(PACKET_HEAD_LENGTH);
// 预留写入包的长度，一个int字节大小
buffer.writeInt(PACKET_HEAD_LENGTH);
// 写入包packet
ProtocolManager.write(buffer, packet);
// 写入包packet
ProtocolManager.write(buffer, packet);
// 写入包的附加包attachment
if (attachment == null) {
ByteBufUtils.writeBoolean(buffer, false);
} else {
ByteBufUtils.writeBoolean(buffer, true);
// 写入包的附加包attachment
ProtocolManager.write(buffer, attachment);
if (attachment == null) {
ByteBufUtils.writeBoolean(buffer, false);
} else {
ByteBufUtils.writeBoolean(buffer, true);
// 写入包的附加包attachment
ProtocolManager.write(buffer, attachment);
}
int length = buffer.readableBytes();
int packetLength = length - PACKET_HEAD_LENGTH;
buffer.writerIndex(0);
buffer.writeInt(packetLength);
buffer.writerIndex(length);
} catch (Exception e) {
logger.error("write packet exception", e);
} catch (Throwable t) {
logger.error("write packet error", t);
}
int length = buffer.readableBytes();
int packetLength = length - PACKET_HEAD_LENGTH;
buffer.writerIndex(0);
buffer.writeInt(packetLength);
buffer.writerIndex(length);
}
}