websocket并发发送消息

2024-10-22 12:58:04 +08:00 · 2024-10-22 12:58:04 +08:00 · 3779033bc9
commit 3779033bc9
parent b7b11e4a26
1 changed files with 4 additions and 1 deletions
--- a/das/src/main/java/com/das/modules/node/handler/NodeMessageHandler.java
+++ b/das/src/main/java/com/das/modules/node/handler/NodeMessageHandler.java
@ -75,7 +75,10 @@ public class NodeMessageHandler  extends TextWebSocketHandler {
                    .time(time)
                    .data(configUpdateData)
                    .build();
+            ThreadUtil.execute(()->{
                sendActionMessage(Long.valueOf(nodeId), configUpdate);
+            });
+
        }
    }