diff --git a/net/src/main/java/com/zfoo/net/router/route/PacketBus.java b/net/src/main/java/com/zfoo/net/router/route/PacketBus.java index 4ef4e907..6f6222fd 100644 --- a/net/src/main/java/com/zfoo/net/router/route/PacketBus.java +++ b/net/src/main/java/com/zfoo/net/router/route/PacketBus.java @@ -53,7 +53,8 @@ public abstract class PacketBus { public static void route(Session session, IPacket packet, IAttachment attachment) { var packetReceiver = (IPacketReceiver) ProtocolManager.getProtocol(packet.protocolId()).receiver(); if (packetReceiver == null) { - throw new RuntimeException(StringUtils.format("no any packetReceiverDefinition found for this [packet:{}]", packet.getClass().getName())); + var name = packet.getClass().getSimpleName(); + throw new RuntimeException(StringUtils.format("no any packetReceiver:[at{}] found for this packet:[{}] or no GatewayAttachment sent back if this server is gateway", name, name)); } packetReceiver.invoke(session, packet, attachment); } diff --git a/net/src/main/java/com/zfoo/net/session/Session.java b/net/src/main/java/com/zfoo/net/session/Session.java index 7a613262..3b8e54dd 100644 --- a/net/src/main/java/com/zfoo/net/session/Session.java +++ b/net/src/main/java/com/zfoo/net/session/Session.java @@ -32,16 +32,17 @@ public class Session implements Closeable { */ private long sid; - /** - * EN:The default user ID is an ID greater than 0, or equal 0 if there is no login - * CN:默认用户的id都是大于0的id,如果没有登录则等于0 - */ - private long uid = 0; - private Channel channel; /** - * Session附带的属性参数,消费者的属性 + * EN:The default user ID is an ID greater than 0, or equal 0 if there is no login, user extra parameters + * CN:默认用户的id都是大于0的id,如果没有登录则等于0,用户额外参数 + */ + private long uid = 0; + + /** + * EN:Session extra parameters + * CN:Session附带的属性参数,消费者的属性 */ private RegisterVO consumerAttribute = null;