日志打印

core/src/main/java/com/wecloud/im/action/NormalChatAction.java

@@ -231,7 +231,9 @@ public class NormalChatAction {
     private ImMessageOnlineSend assembleImMessageOnlineSend(ChatContentVo data, ImClient imClientSender, Long appId) {
         // 入库  保存消息至消息表
         ImClientSimpleDto client = new ImClientSimpleDto().setId(imClientSender.getId()).setFkAppid(appId);
+        Long time = System.currentTimeMillis();
         ImMessage imMessage = imMessageService.saveImMessage(client, data);
+        log.info("外层插入落库耗时 {}", System.currentTimeMillis() - time);
 
         // 封装响应的实体
         ImMessageOnlineSend imMessageOnlineSend = new ImMessageOnlineSend();

core/src/main/java/com/wecloud/im/service/impl/ImMessageServiceImpl.java

@@ -227,7 +227,9 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         String contentJsonString = JsonUtils.encodeJson(data);
         imMessage.setContent(contentJsonString);
 
+        Long snowTime = System.currentTimeMillis();
         imMessage.setId(SnowflakeUtil.getId());
+        log.info("雪花id生产耗时 {}", System.currentTimeMillis() - snowTime);
         imMessage.setCreateTime(new Date());
         imMessage.setFkAppid(client.getFkAppid());
         imMessage.setSender(client.getId());
@@ -238,9 +240,13 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         imMessage.setMsgType(data.getType());
         imMessage.setAt(data.getAt());
         imMessage.setFkConversationId(data.getToConversation());
+        Long dbTime = System.currentTimeMillis();
         this.save(imMessage);
+        log.info("内部落库耗时 {}", System.currentTimeMillis() - dbTime);
 
+        Long eventTime = System.currentTimeMillis();
         eventPublisher.publishEvent(new ClientSendMessageEvent(client.getFkAppid(), imMessage));
+        log.info("事件耗时 {}", System.currentTimeMillis() - eventTime);
 
         return imMessage;
     }