From 8eeee63f58915ad1a81efc78667d6fb872bf41a6 Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Thu, 20 Nov 2025 11:55:31 +0800
Subject: [PATCH] =?UTF-8?q?im=E8=B0=83=E6=95=B4sesion,=E8=A7=A3=E5=86=B3?=
 =?UTF-8?q?=E4=B8=80=E6=AC=A1=E6=80=A7=E6=B8=85=E9=99=A4redis=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/onchat/MallsuiteImSocketHandler.java          | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
index 06ca3b13..e2621931 100644
--- a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
+++ b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
@@ -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);
         }