From 692c1a185d768a18c2007348806d775b2fbdeaa7 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期五, 23 二月 2024 09:45:19 +0800
Subject: [PATCH] 增加MQ 示例

---
 springboot-vue3/src/main/java/com/example/springboot/component/Plcsign.java |   16 +++++++++++-----
 1 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/Plcsign.java b/springboot-vue3/src/main/java/com/example/springboot/component/Plcsign.java
index 89881b8..8329678 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/Plcsign.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/Plcsign.java
@@ -71,7 +71,7 @@
       // System.out.println(PlcAddress);
 
 //      List<Boolean> plclist = S7control.getinstance().ReadBits(PlcAddress, Plccount);
-       List<Boolean> plclist = S7control.getinstance().ReadBits("DB102.0.0", 64);
+       List<Boolean> plclist = S7control.getinstance().ReadBits("DB102.0.0", 112);
 
 //       Boolean[] values = { true, true, true, true, true, false, true, false,
 //       true, false, true, false, true, false,
@@ -95,11 +95,17 @@
         }
         JSONObject jsonObject = new JSONObject();
         jsonObject.append("sig", Intlist);
-        WebSocketServer sendwServer3 = WebSocketServer.sessionMap.get("Sign");
-        if (sendwServer3 != null) {
-          sendwServer3.sendMessage(jsonObject.toString());
-        }
+//        WebSocketServer sendwServer3 = WebSocketServer.sessionMap.get("Sign");
+//        if (sendwServer3 != null) {
+//          sendwServer3.sendMessage(jsonObject.toString());
+//        }
 
+        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Sign");
+        if (sendwServer != null) {
+          for (WebSocketServer webserver : sendwServer) {
+            webserver.sendMessage(jsonObject.toString());
+          }
+        }
       }
     }
   }

--
Gitblit v1.8.0