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

Merge pull request #103 from LucaLq/feature/router

Browse Source 
feat[net]:modify the access modifier
This commit is contained in:
godotg
2024-05-17 10:13:55 +08:00
committed by GitHub
parent ab93891b95 14e7aedbf1
commit 770679af26
1 changed files with 18 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/router/Router.java
+18 -5
View File
@@ -62,14 +62,14 @@ public class Router implements IRouter {
public static final long DEFAULT_TIMEOUT = 3000;
private final ShortObjectHashMap<IPacketReceiver> receiverMap = new ShortObjectHashMap<>();
protected final ShortObjectHashMap<IPacketReceiver> receiverMap = new ShortObjectHashMap<>();
/**
* 作为服务器接收方，会把receive收到的attachment存储在这个地方，只针对task线程。
* atReceiver会设置attachment，但是在方法调用完成会取消，不需要过多关注。
* asyncAsk会再次设置attachment，需要重点关注。
*/
private final FastThreadLocalAdapter<Object> serverReceiverAttachmentThreadLocal = new FastThreadLocalAdapter<>();
protected final FastThreadLocalAdapter<Object> serverReceiverAttachmentThreadLocal = new FastThreadLocalAdapter<>();
/**
* 在服务端收到数据后，会调用这个方法. 这个方法在BaseRouteHandler.java的channelRead中被调用
@@ -370,16 +370,29 @@ public class Router implements IRouter {
receiver.invoke(session, packet, attachment);
} catch (Exception e) {
EventBus.post(ServerExceptionEvent.valueOf(session, packet, attachment, e));
logger.error("at{} e[uid:{}][sid:{}] invoke exception", StringUtils.capitalize(packet.getClass().getSimpleName()), session.getUid(), session.getSid(), e);
exceptionHandler(e, packetReceiverTask);
} catch (Throwable t) {
logger.error("at{} e[uid:{}][sid:{}] invoke error", StringUtils.capitalize(packet.getClass().getSimpleName()), session.getUid(), session.getSid(), t);
throwableHandler(t, packetReceiverTask);
} finally {
// 如果有服务器在处理同步或者异步消息的时候由于错误没有返回给客户端消息，则可能会残留serverAttachment，所以先移除
serverReceiverAttachmentThreadLocal.set(null);
}
}
protected void exceptionHandler(Exception e, PacketReceiverTask packetReceiverTask){
var session = packetReceiverTask.getSession();
var packet = packetReceiverTask.getPacket();
var attachment = packetReceiverTask.getAttachment();
EventBus.post(ServerExceptionEvent.valueOf(session, packet, attachment, e));
logger.error("at{} e[uid:{}][sid:{}] invoke exception", StringUtils.capitalize(packet.getClass().getSimpleName()), session.getUid(), session.getSid(), e);
}
protected void throwableHandler(Throwable t, PacketReceiverTask packetReceiverTask){
var session = packetReceiverTask.getSession();
var packet = packetReceiverTask.getPacket();
logger.error("at{} e[uid:{}][sid:{}] invoke error", StringUtils.capitalize(packet.getClass().getSimpleName()), session.getUid(), session.getSid(), t);
}
@Override
public void registerPacketReceiverDefinition(Object bean) {