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<Long, RoomUserRolesEnum> body = roomMemberClient.mapMemberRoles(roleQry).getBody();
-      Set<RoomUserRolesEnum> 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())) {