backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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

Browse Source
This commit is contained in:
liyj 2025-11-20 11:55:31 +08:00
parent 3971c5f504
commit 8eeee63f58
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
View File

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