From a6fb1c21b44223efd36f8b252d8c6f8ad465351b Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Tue, 18 Nov 2025 16:52:45 +0800 Subject: [PATCH] =?UTF-8?q?im=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D-redis?= =?UTF-8?q?=E7=BB=9F=E4=B8=80key=EF=BC=8C=E4=BF=9D=E8=AF=81=E4=B8=8D?= =?UTF-8?q?=E5=90=8C=E6=9C=8D=E5=8A=A1=E5=99=A8=E4=BF=9D=E5=AD=98=E7=9B=B8?= =?UTF-8?q?=E5=90=8C=E7=9A=84=E5=AE=A2=E6=9C=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../websocket/service/DistributedSessionService.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/DistributedSessionService.java b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/DistributedSessionService.java index 0533feb0..2813fb87 100644 --- a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/DistributedSessionService.java +++ b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/DistributedSessionService.java @@ -24,7 +24,7 @@ public class DistributedSessionService { private static final String USER_SERVER_KEY = "im:user:server:"; private static final String USER_SESSIONS_KEY = "im:user:sessions:"; - private static final String SERVER_USERS_KEY = "im:server:users:"; + private static final String SERVER_USERS_KEY = "im:server:users:kf"; private static final String GROUP_SESSIONS_KEY = "im:group:sessions:"; /** @@ -33,7 +33,7 @@ public class DistributedSessionService { public void registerUserSession(String userId, String sessionId, Map attributes) { String userKey = USER_SESSIONS_KEY + userId; String serverKey = USER_SERVER_KEY + userId; - String serverUsersKey = SERVER_USERS_KEY + getServerId(); + String serverUsersKey = SERVER_USERS_KEY; // 存储用户会话信息 Map sessionInfo = new HashMap<>(); @@ -61,7 +61,7 @@ public class DistributedSessionService { */ public void unregisterUserSession(String userId, String sessionId) { String userKey = USER_SESSIONS_KEY + userId; - String serverUsersKey = SERVER_USERS_KEY + getServerId(); + String serverUsersKey = SERVER_USERS_KEY; // 从用户会话中移除 redisTemplate.opsForHash().delete(userKey, sessionId); @@ -146,7 +146,7 @@ public class DistributedSessionService { */ public List getOnlineUserIds() { // 方法1: 通过服务器用户集合获取（推荐） - String serverUsersKey = SERVER_USERS_KEY + getServerId(); + String serverUsersKey = SERVER_USERS_KEY; Set userIds = redisTemplate.opsForSet().members(serverUsersKey); if (userIds != null && !userIds.isEmpty()) {