im调整sesion,解决一次性清除redis问题

This commit is contained in:
liyj 2025-11-20 11:55:31 +08:00
parent 808649c2ec
commit 2cf86c2dec

View File

@ -219,8 +219,12 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
}
// 从分布式存储注销
distributedSessionService.unregisterUserSession(loginUserId, sessionId);
if (groupId != null) {
List<WebSocketSession> sessions= userSessions.get(loginUserId);
if(null==sessions || sessions.isEmpty()){
distributedSessionService.unregisterUserSession(loginUserId, sessionId);
}
List<WebSocketSession> groupSessionList= groupSessions.get(groupId);
if (null==groupSessionList||groupSessionList.isEmpty()) {
distributedSessionService.removeUserFromGroup(groupId, sessionId);
}