在线推送消息时 打印内容

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

 package com.wecloud.im.ws.sender;
 package com.wecloud.im.ws.sender;
 
 
-import com.alibaba.fastjson.JSON;
-import com.wecloud.im.executor.SendMsgThreadPool;
-import com.wecloud.im.router.RouterSendService;
-import com.wecloud.im.ws.cache.UserStateCacheManager;
-import com.wecloud.im.ws.manager.ChannelManager;
-import com.wecloud.im.ws.model.ClientInfo;
-import com.wecloud.im.ws.model.WsResponse;
-import com.wecloud.im.ws.model.redis.ClientChannelInfo;
-import com.wecloud.im.ws.model.request.ReceiveVO;
-import com.wecloud.utils.GetIpUtils;
-import com.wecloud.utils.JsonUtils;
 import io.geekidea.springbootplus.framework.common.api.ApiCode;
 import io.geekidea.springbootplus.framework.common.api.ApiCode;
 import io.geekidea.springbootplus.framework.common.api.ApiResult;
 import io.geekidea.springbootplus.framework.common.api.ApiResult;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import io.netty.channel.socket.nio.NioSocketChannel;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.apache.dubbo.rpc.RpcContext;
 import org.apache.dubbo.rpc.RpcContext;
 import org.apache.dubbo.rpc.cluster.router.address.Address;
 import org.apache.dubbo.rpc.cluster.router.address.Address;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
 
 
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
+import com.alibaba.fastjson.JSON;
+import com.wecloud.im.executor.SendMsgThreadPool;
+import com.wecloud.im.router.RouterSendService;
+import com.wecloud.im.ws.cache.UserStateCacheManager;
+import com.wecloud.im.ws.manager.ChannelManager;
+import com.wecloud.im.ws.model.ClientInfo;
+import com.wecloud.im.ws.model.WsResponse;
+import com.wecloud.im.ws.model.redis.ClientChannelInfo;
+import com.wecloud.im.ws.model.request.ReceiveVO;
+import com.wecloud.utils.GetIpUtils;
+import com.wecloud.utils.JsonUtils;
 
 
 /**
 /**
  * @Description 下发数据
  * @Description 下发数据
@@ -144,6 +146,7 @@ public class ChannelSender {
                 // 调用本地下发
                 // 调用本地下发
                 log.info("在线用户入参 {}, 具体ip结果 {}", toClientId, JSON.toJSONString(channelInfoEntry));
                 log.info("在线用户入参 {}, 具体ip结果 {}", toClientId, JSON.toJSONString(channelInfoEntry));
                 for(ClientChannelInfo clientChannelInfo : channelInfoEntry.getValue()) {
                 for(ClientChannelInfo clientChannelInfo : channelInfoEntry.getValue()) {
+                    log.info("客户端 {}, 推送消息内容 {}", toClientId, JSON.toJSONString(msgJson));
                     this.sendMsgLocal(toClientId, clientChannelInfo.getPlatform(), msgJson);
                     this.sendMsgLocal(toClientId, clientChannelInfo.getPlatform(), msgJson);
                 }
                 }
                 continue;
                 continue;