From 261b0e0f07a7a9ebe2e8f4c014d1b89443d18970 Mon Sep 17 00:00:00 2001
From: zhn <947514737@qq.com>
Date: Tue, 7 Jun 2022 18:00:42 +0800
Subject: [PATCH] webSocket

---
 .../jero/modules/message/websocket/WebSocket.java  | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java
index 3edaa541d..0f5507f19 100644
--- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java
+++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/message/websocket/WebSocket.java
@@ -89,11 +89,13 @@ public class WebSocket {
     public void pushMessage(String message) {
         try {
             for (WebSocket ws : webSockets) {
-                try {
-                    ws.session.getBasicRemote().sendText(message);
-                } catch (IOException e) {
-                    e.printStackTrace();
-                    continue;
+                synchronized (ws.session){
+                    try {
+                        ws.session.getBasicRemote().sendText(message);
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                        continue;
+                    }
                 }
             }
         } catch (Exception e) {
@@ -152,4 +154,4 @@ public class WebSocket {
         }
     }
 
-}
\ No newline at end of file
+}