From 9a294dc08a0beb787e8179d26f726eb81a7c81e9 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Thu, 5 Mar 2026 21:07:25 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=97=B6=E5=9C=A8=E7=BA=BF=E7=94=A8?= =?UTF-8?q?=E6=88=B7=E6=8E=92=E9=99=A4=E6=88=BF=E4=B8=BB=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../circle/live/app/listener/UserHeartbeatListener.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java index 23f538fb..99b6e87e 100644 --- a/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java +++ b/rc-service/rc-service-live/live-application/src/main/java/com/red/circle/live/app/listener/UserHeartbeatListener.java @@ -137,11 +137,11 @@ public class UserHeartbeatListener implements MessageListener { MemberRolesQryCmd roleQry = new MemberRolesQryCmd().setRoomId(roomId).setUserIds(userIdList); Map body = roomMemberClient.mapMemberRoles(roleQry).getBody(); - Set collect = body.values().stream() - .filter(roleEnum -> !RoomUserRolesEnum.TOURIST.equals(roleEnum)) - .collect(Collectors.toSet()); + long onlineCount = body.entrySet().stream() + .filter(e -> !RoomUserRolesEnum.TOURIST.equals(e.getValue())) + .count(); - handleOnlineUserCountTask(event.getUserId(), collect.size()); + handleOnlineUserCountTask(event.getUserId(), (int) onlineCount); } else { // 在他人房间活跃 if (!tryAcquireMinuteTick(event.getUserId())) {