diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index 3f4bc9273..82966bd31 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -67,7 +67,7 @@ public abstract class WebSocketNode { Set engineids = localNodes.get(groupid); if (engineids == null) { engineids = new CopyOnWriteArraySet<>(); - localNodes.put(groupid, engineids); + localNodes.putIfAbsent(groupid, engineids); } if (localSncpAddress != null && engineids.isEmpty()) connect(groupid, localSncpAddress); engineids.add(engineid);