diff --git a/src/org/redkale/net/http/WebSocket.java b/src/org/redkale/net/http/WebSocket.java index 89c904394..b30a7db8e 100644 --- a/src/org/redkale/net/http/WebSocket.java +++ b/src/org/redkale/net/http/WebSocket.java @@ -257,12 +257,16 @@ public abstract class WebSocket { private int sendMessage(Serializable groupid, boolean recent, String text, boolean last) { if (_engine.node == null) return RETCODE_NODESERVICE_NULL; - return _engine.node.sendMessage(groupid, recent, text, last); + int rs = _engine.node.sendMessage(groupid, recent, text, last); + if(_engine.finest) _engine.logger.finest("groupid:" + groupid + " websocket "+(recent ? "recent " : "") + "send result is " + rs + " on " + this + " by message(" + text + ")"); + return rs; } private int sendMessage(Serializable groupid, boolean recent, byte[] data, boolean last) { if (_engine.node == null) return RETCODE_NODESERVICE_NULL; - return _engine.node.sendMessage(groupid, recent, data, last); + int rs = _engine.node.sendMessage(groupid, recent, data, last); + if(_engine.finest) _engine.logger.finest("groupid:" + groupid + " websocket "+(recent ? "recent " : "") + "send result is " + rs + " on " + this + " by message(byte[" + data.length + "])"); + return rs; } /** @@ -426,4 +430,9 @@ public abstract class WebSocket { public void onClose(int code, String reason) { } + + @Override + public String toString() { + return "ws" + Objects.hashCode(this) + "@" + _remoteAddr; + } } diff --git a/src/org/redkale/net/http/WebSocketEngine.java b/src/org/redkale/net/http/WebSocketEngine.java index 4d9509a51..06c77453e 100644 --- a/src/org/redkale/net/http/WebSocketEngine.java +++ b/src/org/redkale/net/http/WebSocketEngine.java @@ -69,7 +69,7 @@ public final class WebSocketEngine { containers.putIfAbsent(socket._groupid, group); } group.add(socket); - if (node != null) node.connect(socket._groupid, engineid); + if (node != null) node.connect(socket._groupid, engineid, socket.toString()); } void remove(WebSocket socket) { diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index f5302cf18..a7ea00f31 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -102,7 +102,7 @@ public abstract class WebSocketNode { return map; } - public final void connect(Serializable groupid, String engineid) { + public final void connect(Serializable groupid, String engineid, String wsinfo) { if (finest) logger.finest(localSncpAddress + " receive websocket connect event (" + groupid + " on " + engineid + ")."); Set engineids = localNodes.get(groupid); if (engineids == null) {