websocket并发发送消息

2024-10-22 13:13:09 +08:00 · 2024-10-22 13:13:09 +08:00 · a3aa3b2187
commit a3aa3b2187
parent ae484ed814
1 changed files with 3 additions and 0 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
@ -44,6 +44,9 @@ public class NodeMessageHandler  extends TextWebSocketHandler {

        // 如果version是0，则需要调用一次configUpdate配置更新
        if (version == 0){
+            if (dataService == null){
+                dataService = SpringUtil.getBean(DataService.class);
+            }
            dataService.sendTerminalConfig(Long.valueOf(nodeId));
        }