From 84299d0963ffa1dff491757180445c21663b26b2 Mon Sep 17 00:00:00 2001 From: rays <1615175118@qq.com> Date: Fri, 18 Jun 2021 15:03:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DSession=E5=85=B3=E9=97=AD?= =?UTF-8?q?=E6=97=B6=E7=A9=BA=E6=8C=87=E9=92=88=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kernel/socket/websocket/session/SessionCenter.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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)); + } } } }