消息丢失排查日志添加

core/src/main/java/com/wecloud/im/ws/sender/ChannelSender.java

@@ -128,15 +128,21 @@ public class ChannelSender {
         String msgJson = JsonUtils.encodeJson(responseModel);
         String msgJson = JsonUtils.encodeJson(responseModel);
 
 
         List<ClientChannelInfo> channelInfos = userStateCacheManager.findOnlineInfosByClientId(toClientId);
         List<ClientChannelInfo> channelInfos = userStateCacheManager.findOnlineInfosByClientId(toClientId);
+        log.info("获取在线用户入参 {}, 结果 {}", toClientId, JSON.toJSONString(channelInfos));
 
 
         // 一个用户存在多端的情况，所以先进行分类，key是ip地址，value是channel的列表
         // 一个用户存在多端的情况，所以先进行分类，key是ip地址，value是channel的列表
         Map<String, List<ClientChannelInfo>> ipChannels = channelInfos.stream().collect(Collectors.groupingBy(ClientChannelInfo::getLanIp));
         Map<String, List<ClientChannelInfo>> ipChannels = channelInfos.stream().collect(Collectors.groupingBy(ClientChannelInfo::getLanIp));
 
 
+        log.info("分组在线用户入参 {}, 结果 {}", toClientId, JSON.toJSONString(ipChannels));
+
         for (Map.Entry<String, List<ClientChannelInfo>> channelInfoEntry : ipChannels.entrySet()) {
         for (Map.Entry<String, List<ClientChannelInfo>> channelInfoEntry : ipChannels.entrySet()) {
 
 
+            log.info("在线用户入参 {}, 具体ip结果 {}", toClientId, JSON.toJSONString(channelInfoEntry));
+
             // 是否为当前机器的ip
             // 是否为当前机器的ip
             if (GetIpUtils.getlanIp().equals(channelInfoEntry.getKey())) {
             if (GetIpUtils.getlanIp().equals(channelInfoEntry.getKey())) {
                 // 调用本地下发
                 // 调用本地下发
+                log.info("在线用户入参 {}, 具体ip结果 {}", toClientId, JSON.toJSONString(channelInfoEntry));
                 for(ClientChannelInfo clientChannelInfo : channelInfoEntry.getValue()) {
                 for(ClientChannelInfo clientChannelInfo : channelInfoEntry.getValue()) {
                     this.sendMsgLocal(toClientId, clientChannelInfo.getPlatform(), msgJson);
                     this.sendMsgLocal(toClientId, clientChannelInfo.getPlatform(), msgJson);
                 }
                 }
@@ -217,8 +223,10 @@ public class ChannelSender {
      * @return
      * @return
      */
      */
     private boolean sendMsgLocal(String key, String msgJsonStr) {
     private boolean sendMsgLocal(String key, String msgJsonStr) {
+        log.info("消息推送 key {} 内容 {}", key, msgJsonStr);
         ClientInfo clientInfo = ChannelManager.SESSION_INFO_MAP.get(key);
         ClientInfo clientInfo = ChannelManager.SESSION_INFO_MAP.get(key);
         if (clientInfo == null) {
         if (clientInfo == null) {
+            log.info("消息推送 key {} 本地map取设备信息为空", key);
             return false;
             return false;
         }
         }
 
 
@@ -229,7 +237,7 @@ public class ChannelSender {
         }
         }
         // 判断连接是否断开
         // 判断连接是否断开
         if (nioSocketChannel.isShutdown()) {
         if (nioSocketChannel.isShutdown()) {
-            log.warn("writeData 已连接断开: {}\n channelId: {}", msgJsonStr, nioSocketChannel.id().asLongText());
+            log.info("writeData 已连接断开: {}\n channelId: {}", msgJsonStr, nioSocketChannel.id().asLongText());
             return false;
             return false;
         }
         }