diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 0024fd973..c77c21b46 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -37,7 +37,7 @@ public abstract class WebSocketNode { protected WebSocketNode remoteNode; //存放所有用户分布在节点上的队列信息,Set 为 sncpnode 的集合 - @Resource(name = "$_websocket_nodes") + @Resource(name = "$") protected CacheSource source; //存放本地节点上所有在线用户的队列信息,Set 为 engineid 的集合 @@ -162,6 +162,7 @@ public abstract class WebSocketNode { } //-----------------------发送远程的----------------------------- Collection addrs = source.getCollection(groupid); + if (finest) logger.finest("websocket found groupid:" + groupid + " on " + addrs); if (addrs != null && !addrs.isEmpty()) { //对方连接在远程节点(包含本地节点),所以正常情况下addrs不会为空。 if (recent) { InetSocketAddress one = null;