tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-20 06:24:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[net]: 优化协议注册日志

Browse Source
This commit is contained in:
jaysunxiao
2021-08-15 23:07:43 +08:00
parent 6984444fc3
commit 4f57351d0a
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/dispatcher/manager/PacketBus.java
+4 -1
View File
@@ -27,6 +27,7 @@ import com.zfoo.net.session.model.Session;
import com.zfoo.protocol.IPacket;
import com.zfoo.protocol.ProtocolManager;
import com.zfoo.protocol.collection.ArrayUtils;
import com.zfoo.protocol.exception.RunException;
import com.zfoo.protocol.registration.IProtocolRegistration;
import com.zfoo.protocol.util.AssertionUtils;
import com.zfoo.protocol.util.ReflectionUtils;
@@ -130,11 +131,13 @@ public abstract class PacketBus {
// 将receiver注册到IProtocolRegistration
var protocolRegistration = packetReceiverList[protocolId];
AssertionUtils.notNull(protocolRegistration, "协议类[class:{}][protocolId:{}]没有注册", packetClazz.getSimpleName(), protocolId);
var receiverField = ReflectionUtils.getFieldByNameInPOJOClass(protocolRegistration.getClass(), "receiver");
ReflectionUtils.makeAccessible(receiverField);
ReflectionUtils.setField(receiverField, protocolRegistration, enhanceReceiverDefinition);
} catch (Throwable t) {
throw new RuntimeException(t);
throw new RunException(t, "解析协议类[class:{}]未知异常", packetClazz.getSimpleName());
}
}
}