消息更新

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

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