lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-05-17 19:10:51 +08:00
parent 4d523d1ca4
commit 39ba0f86f6
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/org/redkale/net/http/WebSocketNode.java
View File

@@ -152,17 +152,15 @@ public abstract class WebSocketNode {
int rscode = RETCODE_GROUP_EMPTY; int rscode = RETCODE_GROUP_EMPTY;
WebSocketGroup group = this.localEngine == null ? null : this.localEngine.getWebSocketGroup(groupid); WebSocketGroup group = this.localEngine == null ? null : this.localEngine.getWebSocketGroup(groupid);
if (group != null) rscode = group.send(recent, message, last); if (group != null) rscode = group.send(recent, message, last);
if ((recent && rscode == 0) || remoteNode == null || sncpAddressNodes == null) { //没有其他远程的WebSocket连接 if (recent && rscode == 0) { //已经给最近连接发送的消息
if (finest) { if (finest) logger.finest("websocket want send recent message success");
if ((recent && rscode == 0)) { return rscode;
logger.finest("websocket want send recent message success"); }
} else { if (this.sncpAddressNodes == null || this.remoteNode == null) {
logger.finest("websocket remote node is null"); if (finest) logger.finest("websocket remote node is null");
} //没有CacheSource就不会有分布式节点
}
return rscode; return rscode;
} }
if (this.sncpAddressNodes == null || this.remoteNode == null) return rscode; //没有CacheSource就不会有分布式节点
//-----------------------发送远程的----------------------------- //-----------------------发送远程的-----------------------------
Collection<InetSocketAddress> addrs = sncpAddressNodes.getCollectionAsync(groupid).join(); Collection<InetSocketAddress> addrs = sncpAddressNodes.getCollectionAsync(groupid).join();
if (finest) logger.finest("websocket found groupid:" + groupid + " on " + addrs); if (finest) logger.finest("websocket found groupid:" + groupid + " on " + addrs);