diff --git a/src/org/redkale/net/http/WebSocketNode.java b/src/org/redkale/net/http/WebSocketNode.java index eacf16fd1..f4ee6a60b 100644 --- a/src/org/redkale/net/http/WebSocketNode.java +++ b/src/org/redkale/net/http/WebSocketNode.java @@ -71,7 +71,7 @@ public abstract class WebSocketNode { public final void postDestroy(AnyValue conf) { if (this.localEngine == null) return; //关掉所有本地本地WebSocket - this.localEngine.getLocalWebSockets().forEach(g -> disconnect(g.getUserid())); + this.localEngine.getLocalWebSockets().forEach(g -> disconnect(g.getUserid()).join()); if (sncpNodeAddresses != null && localSncpAddress != null) { sncpNodeAddresses.removeSetItem(SOURCE_SNCP_ADDRS_KEY, localSncpAddress); }