解决WebSocket session并发问题

modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/websocket/MessageWebSocket.java

@@ -82,12 +82,14 @@ public class MessageWebSocket {
     public static void sendMessage(Long userId, String message){
         try {
             MessageWebSocket websocket = webSocketSet.get(userId);
-            if(websocket != null) {
-                if (message.equals("heartBit")) {
-                    websocket.session.getBasicRemote().sendText(message + "=" + sendCount);
-                    sendCount++;
-                } else {
-                    websocket.session.getBasicRemote().sendText(message);
+            synchronized (websocket){
+                if(websocket != null) {
+                    if (message.equals("heartBit")) {
+                        websocket.session.getBasicRemote().sendText(message + "=" + sendCount);
+                        sendCount++;
+                    } else {
+                        websocket.session.getBasicRemote().sendText(message);
+                    }
                 }
             }
         } catch (IOException e) {