webSocket

jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java

@@ -89,6 +89,7 @@ public class WebSocket {
     public void pushMessage(String message) {
         try {
             for (WebSocket ws : webSockets) {
+                synchronized (ws.session){
                     try {
                         ws.session.getBasicRemote().sendText(message);
                     } catch (IOException e) {
@@ -96,6 +97,7 @@ public class WebSocket {
                         continue;
                     }
                 }
+            }
         } catch (Exception e) {
             e.printStackTrace();
         }