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

im问题修复-获取不到用户

Browse Source
This commit is contained in:
liyj 2025-11-18 14:55:10 +08:00
parent 1754272f7f
commit e97416feeb
2 changed files with 6 additions and 4 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/DistributedSessionService.java
View File

@ -146,11 +146,12 @@ public class DistributedSessionService {
*/ */
public List<Integer> getOnlineUserIds() { public List<Integer> getOnlineUserIds() {
// 方法1: 通过服务器用户集合获取（推荐） // 方法1: 通过服务器用户集合获取（推荐）
String serverUsersKey = SERVER_USERS_KEY + new RabbitMQManager().getServerId(); String serverUsersKey = SERVER_USERS_KEY + getServerId();
Set<Object> userIds = redisTemplate.opsForSet().members(serverUsersKey); Set<Object> userIds = redisTemplate.opsForSet().members(serverUsersKey);
if (userIds != null && !userIds.isEmpty()) { if (userIds != null && !userIds.isEmpty()) {
return userIds.stream() List<Integer> userIdList = new ArrayList<>(userIds.size());
userIdList= userIds.stream()
.map(userIdStr -> { .map(userIdStr -> {
try { try {
return Integer.parseInt(userIdStr.toString()); return Integer.parseInt(userIdStr.toString());
@ -160,6 +161,7 @@ public class DistributedSessionService {
}) })
.filter(Objects::nonNull) .filter(Objects::nonNull)
.collect(Collectors.toList()); .collect(Collectors.toList());
return userIdList;
} }
return new ArrayList<>(); return new ArrayList<>();

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

@ -68,7 +68,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
distributedSessionService.registerUserSession(loginUserId, sessionId, attributes); distributedSessionService.registerUserSession(loginUserId, sessionId, attributes);
// 处理离线消息等原有逻辑... // 处理离线消息等原有逻辑...
this.updateOnlineStatus(); // this.updateOnlineStatus();
} }
@ -214,7 +214,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
distributedSessionService.removeUserFromGroup(groupId, sessionId); distributedSessionService.removeUserFromGroup(groupId, sessionId);
} }
this.updateOnlineStatus(); // this.updateOnlineStatus();
} }
@Override @Override