优化2-每3秒像正在直播的直播间发送

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImLiveBroadcastRoomServiceImpl.java

@@ -530,6 +530,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
             return;
         }
         log.info("sendLiveOnlineNum>>>> liveRooms{}", JSONObject.toJSONString(liveRooms));
+        Map<String, Integer> onlineUserMap = new HashMap<>();
         liveRooms.forEach(room -> {
             //查询在线观看者信息
             RMap<Integer, BaseRoomUserVo> onlineUserCache = this.getOnlineUserCache(room.getRoomUid());
@@ -545,7 +546,8 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
             if (size < 1) {
                 return;
             }
-            message.setContent(size);
+            onlineUserMap.put("count", size);
+            message.setContent(onlineUserMap);
             //主讲人发送消息
             try {
                 imFeignService.publishRoomMsg(message);