gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

修复Session关闭时空指针问题

pull/22/head
rays 2021-06-18 15:03:52 +08:00
parent 6f10b330fa
commit 84299d0963
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kernel-d-socket/socket-sdk-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/websocket/session/SessionCenter.java
View File

@ -50,7 +50,7 @@ public class SessionCenter {
/** /**
* 根据用户ID和消息类型获取会话信息列表 * 根据用户ID和消息类型获取会话信息列表
* *
* @param userId 用户ID * @param userId 用户ID
* @return {@link SocketSession <GettySocketOperator>} * @return {@link SocketSession <GettySocketOperator>}
* @author majianguo * @author majianguo
* @date 2021/6/1 下午1:48 * @date 2021/6/1 下午1:48
@ -103,7 +103,9 @@ public class SessionCenter {
**/ **/
public static void closed(String sessionId) { public static void closed(String sessionId) {
for (List<SocketSession<GettySocketOperator>> values : socketSessionMap.values()) { for (List<SocketSession<GettySocketOperator>> values : socketSessionMap.values()) {
values.removeIf(item -> item.getSessionId().equals(sessionId)); if (ObjectUtil.isNotEmpty(values)) {
values.removeIf(item -> item.getSessionId().equals(sessionId));
}
} }
} }
} }