消息更新

src/main/java/cn/meteor/beyondclouds/modules/im/server/SocketIOServiceImpl.java

@@ -135,7 +135,8 @@ public class SocketIOServiceImpl implements SocketIOService {
     private void putClient(String userId, SocketIOClient socketIOClient) {
     private void putClient(String userId, SocketIOClient socketIOClient) {
         Set<SocketIOClient> clients = CLIENT_MAP.get(userId);
         Set<SocketIOClient> clients = CLIENT_MAP.get(userId);
         if (null == clients) {
         if (null == clients) {
-            CLIENT_MAP.put(userId, new HashSet<>());
+            clients = new HashSet<>();
+            CLIENT_MAP.put(userId, clients);
         }
         }
         clients.add(socketIOClient);
         clients.add(socketIOClient);
     }
     }