修改weobsocket 连接多用户同时推送

wuyouming666

2023-12-11 b496fab726e76436f1200725926f863da6edc694

 springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java

@@ -88,16 +88,18 @@


        JSONObject jsonObject = new JSONObject();

        jsonObject.append("params", params);

        WebSocketServer sendwServer = WebSocketServer.sessionMap.get("action");







      ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("action");

        if (sendwServer != null) {

          sendwServer.sendMessage(jsonObject.toString());

        }

      }

        for (WebSocketServer webserver : sendwServer) {

          webserver.sendMessage(jsonObject.toString());



      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("action");

      if (webSocketServer != null) {



        List<String> messages = webSocketServer.getMessages();





        List<String> messages = webserver.getMessages();



        String addressList = "DB2.0.0";



@@ -130,7 +132,9 @@
          System.out.println("messageValues：" + messageBooleans);

          System.out.println("addressList：" + addressList);

          // 清空消息列表

          webSocketServer.clearMessages();

          webserver.clearMessages();

        }

        }

        }

      }

    }