diff --git a/kernel-d-socket/socket-sdk-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/websocket/session/SessionCenter.java b/kernel-d-socket/socket-sdk-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/websocket/session/SessionCenter.java index 63503cd80..e5e2d266b 100644 --- a/kernel-d-socket/socket-sdk-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/websocket/session/SessionCenter.java +++ b/kernel-d-socket/socket-sdk-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/websocket/session/SessionCenter.java @@ -50,7 +50,7 @@ public class SessionCenter { /** * 根据用户ID和消息类型获取会话信息列表 * - * @param userId 用户ID + * @param userId 用户ID * @return {@link SocketSession } * @author majianguo * @date 2021/6/1 下午1:48 @@ -103,7 +103,9 @@ public class SessionCenter { **/ public static void closed(String sessionId) { for (List> values : socketSessionMap.values()) { - values.removeIf(item -> item.getSessionId().equals(sessionId)); + if (ObjectUtil.isNotEmpty(values)) { + values.removeIf(item -> item.getSessionId().equals(sessionId)); + } } } }