From 39ba0f86f6a2c300a1e0a4e0f87b77490f18e4d9 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Wed, 17 May 2017 19:10:51 +0800 Subject: [PATCH] --- src/org/redkale/net/http/WebSocketNode.java | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 94d5eb32e..93ed19dff 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -152,17 +152,15 @@ public abstract class WebSocketNode { int rscode = RETCODE_GROUP_EMPTY; WebSocketGroup group = this.localEngine == null ? null : this.localEngine.getWebSocketGroup(groupid); if (group != null) rscode = group.send(recent, message, last); - if ((recent && rscode == 0) || remoteNode == null || sncpAddressNodes == null) { //没有其他远程的WebSocket连接 - if (finest) { - if ((recent && rscode == 0)) { - logger.finest("websocket want send recent message success"); - } else { - logger.finest("websocket remote node is null"); - } - } + if (recent && rscode == 0) { //已经给最近连接发送的消息 + if (finest) logger.finest("websocket want send recent message success"); + return rscode; + } + if (this.sncpAddressNodes == null || this.remoteNode == null) { + if (finest) logger.finest("websocket remote node is null"); + //没有CacheSource就不会有分布式节点 return rscode; } - if (this.sncpAddressNodes == null || this.remoteNode == null) return rscode; //没有CacheSource就不会有分布式节点 //-----------------------发送远程的----------------------------- Collection addrs = sncpAddressNodes.getCollectionAsync(groupid).join(); if (finest) logger.finest("websocket found groupid:" + groupid + " on " + addrs);