From 5117c8c9826f9b4718694c25823ebfed958cf99e Mon Sep 17 00:00:00 2001
From: zhizhi wu <2377881365@qq.com>
Date: Wed, 16 Dec 2020 15:48:03 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ccsens/ccmq/lowlevel/message/MessageHandler.java  | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/MessageHandler.java b/ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/MessageHandler.java
index 75db8f6..d3e68bc 100644
--- a/ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/MessageHandler.java
+++ b/ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/MessageHandler.java
@@ -205,6 +205,7 @@ public class MessageHandler {
     }
 
     public static void handleMessage(InMessage inMessage) throws Exception{
+        logger.info("消息系统处理消息：{}", inMessage);
         //1. 处理发送给Server的消息
         if(inMessage.getToDomain() == MessageConstant.DomainType.Server){
             String type = null;
@@ -217,14 +218,16 @@ public class MessageHandler {
             handlerServerMessage(type,inMessage);
             return;
         }
-
+        logger.info("非Server消息");
         //2. 处理发送给Client的消息
         //校验错误
         if (CollectionUtil.isEmpty(inMessage.getTos())) {
+            logger.info("没有接受对象");
             ClientManager.sendServerAck(inMessage, MessageConstant.Error.MessageNoReceiversError);
             return;
         }
         if(!ClientManager.isSenderAuthed(inMessage)){
+            logger.info("发送授权失败");
             ClientManager.sendServerAck(inMessage,MessageConstant.Error.UnAuthed);
             ClientManager.closeCurrentSender(inMessage);
             return;
@@ -232,15 +235,15 @@ public class MessageHandler {
 
         //存储消息（原始消息+按照tos拆分之后的每条消息）
         saveMessage(inMessage);
-
+        logger.info("存储消息");
         //3.发送ack
         ClientManager.sendServerAck(inMessage, MessageConstant.Error.Ok);
-
+        logger.info("发送ACK");
         //4.将用户添加到Redis待处理用户集合中
         RedisUtil.sSet(RedisKeyManager.getPendingClientSetKey(),
                 CcMessageUtil.getNameManglingToList(inMessage).toArray()
         );
-
+        logger.info("存储redis");
     }
 
     private static void saveMessage(InMessage inMessage) throws Exception{