From f4548bbe34ad2a3b4132ef1a064559d5a8964a6b Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Fri, 11 Oct 2019 11:13:41 +0800 Subject: [PATCH] --- src/org/redkale/net/http/WebSocketNode.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 725cbfb79..87051f82f 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -595,7 +595,7 @@ public abstract class WebSocketNode { protected CompletableFuture sendOneAddrMessage(final InetSocketAddress sncpAddr, final Object message, final boolean last, final Serializable... userids) { if (message instanceof CompletableFuture) return ((CompletableFuture) message).thenApply(msg -> sendOneAddrMessage(sncpAddr, msg, last, userids)); - if (logger.isLoggable(Level.FINEST)) { + if (logger.isLoggable(Level.FINEST) && this.localEngine == null) { //只打印远程模式的 logger.finest("websocket want send message {userids:" + JsonConvert.root().convertTo(userids) + ", sncpaddr:" + sncpAddr + ", content:" + (message instanceof WebSocketPacket ? ((WebSocketPacket) message).toSimpleString() : (message instanceof CharSequence ? message : JsonConvert.root().convertTo(message))) + "} from locale node to " + ((this.localEngine != null) ? "locale" : "remote") + " engine"); } if (Objects.equals(sncpAddr, this.localSncpAddress)) { @@ -918,7 +918,7 @@ public abstract class WebSocketNode { } protected CompletableFuture sendOneAddrAction(final InetSocketAddress sncpAddr, final WebSocketAction action, final Serializable... userids) { - if (logger.isLoggable(Level.FINEST)) { + if (logger.isLoggable(Level.FINEST) && this.localEngine == null) { //只打印远程模式的 logger.finest("websocket want send action {userids:" + JsonConvert.root().convertTo(userids) + ", sncpaddr:" + sncpAddr + ", action:" + action + " from locale node to " + ((this.localEngine != null) ? "locale" : "remote") + " engine"); } if (Objects.equals(sncpAddr, this.localSncpAddress)) {