diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 512ec85d0..79d9dd3d7 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -81,16 +81,18 @@ public abstract class WebSocketNode { * 获取在线用户的节点地址列表 * * @param groupid groupid + * * @return 地址列表 */ public Collection getOnlineNodes(final Serializable groupid) { - return source.getCollection(groupid); + return source == null ? null : source.getCollection(groupid); } /** * 获取在线用户的详细连接信息 * * @param groupid groupid + * * @return 地址集合 */ public Map> getOnlineRemoteAddress(final Serializable groupid) { @@ -150,7 +152,7 @@ public abstract class WebSocketNode { } } } - if ((recent && rscode == 0) || remoteNode == null) { + if ((recent && rscode == 0) || remoteNode == null || source == null) { if (finest) { if ((recent && rscode == 0)) { logger.finest("websocket want send recent message success");