优化资产导入自动创建业主账号

service-api/src/main/java/com/java110/api/websocket/MessageWebsocket.java

@@ -155,7 +155,10 @@ public class MessageWebsocket {
      * 实现服务器主动推送
      */
     public void sendMessage(String message) throws IOException {
-        this.session.getBasicRemote().sendText(message);
+        //this.session.getBasicRemote().sendText(message);
+        synchronized (this.session) {
+            this.session.getBasicRemote().sendText(message);
+        }
     }
 
 

service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java

@@ -139,7 +139,10 @@ public class ParkingAreaWebsocket {
      * 实现服务器主动推送
      */
     public void sendMessage(String message) throws IOException {
-        this.session.getBasicRemote().sendText(message);
+       // this.session.getBasicRemote().sendText(message);
+        synchronized (this.session) {
+            this.session.getBasicRemote().sendText(message);
+        }
     }
 
 

service-api/src/main/java/com/java110/api/websocket/ParkingBoxWebsocket.java

@@ -139,7 +139,10 @@ public class ParkingBoxWebsocket {
      * 实现服务器主动推送
      */
     public void sendMessage(String message) throws IOException {
-        this.session.getBasicRemote().sendText(message);
+        //this.session.getBasicRemote().sendText(message);
+        synchronized (this.session) {
+            this.session.getBasicRemote().sendText(message);
+        }
     }
 
 

springboot/src/main/java/com/java110/boot/websocket/MessageWebsocket.java

@@ -155,7 +155,10 @@ public class MessageWebsocket {
      * 实现服务器主动推送
      */
     public void sendMessage(String message) throws IOException {
-        this.session.getBasicRemote().sendText(message);
+        //this.session.getBasicRemote().sendText(message);
+        synchronized (this.session) {
+            this.session.getBasicRemote().sendText(message);
+        }
     }
 
 

springboot/src/main/java/com/java110/boot/websocket/ParkingAreaWebsocket.java

@@ -139,7 +139,10 @@ public class ParkingAreaWebsocket {
      * 实现服务器主动推送
      */
     public void sendMessage(String message) throws IOException {
-        this.session.getBasicRemote().sendText(message);
+        synchronized (this.session) {
+            this.session.getBasicRemote().sendText(message);
+        }
+        //this.session.getBasicRemote().sendText(message);
     }
 
 
@@ -149,9 +152,10 @@ public class ParkingAreaWebsocket {
     public static void sendInfo(String message, String paId) throws IOException {
         logger.info("发送消息到:" + paId + "，报文:" + message);
         for (ParkingAreaWebsocket server : webSocketMap.values()) {
-            if (paId.equals(server.paId)) {
-                webSocketMap.get(server.clientId).sendMessage(message);
+            if (!paId.equals(server.paId)) {
+                continue;
             }
+            webSocketMap.get(server.clientId).sendMessage(message);
         }
     }
 

springboot/src/main/java/com/java110/boot/websocket/ParkingBoxWebsocket.java

@@ -139,7 +139,10 @@ public class ParkingBoxWebsocket {
      * 实现服务器主动推送
      */
     public void sendMessage(String message) throws IOException {
-        this.session.getBasicRemote().sendText(message);
+        //this.session.getBasicRemote().sendText(message);
+        synchronized (this.session) {
+            this.session.getBasicRemote().sendText(message);
+        }
     }