From 8707b24e2fa7db72c72a91726216ea33831aa076 Mon Sep 17 00:00:00 2001
From: xsx <825657193@qq.com>
Date: Sat, 29 Jun 2024 01:44:09 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E5=BF=83=E8=B7=B3=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/bx/imserver/netty/IMChannelHandler.java    | 2 +-
 .../com/bx/imserver/netty/processor/HeartbeatProcessor.java  | 5 ++++-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/im-server/src/main/java/com/bx/imserver/netty/IMChannelHandler.java b/im-server/src/main/java/com/bx/imserver/netty/IMChannelHandler.java
index d985867..dd9e30e 100644
--- a/im-server/src/main/java/com/bx/imserver/netty/IMChannelHandler.java
+++ b/im-server/src/main/java/com/bx/imserver/netty/IMChannelHandler.java
@@ -74,7 +74,7 @@ public class IMChannelHandler extends SimpleChannelInboundHandler<IMSendInfo> {
             RedisTemplate<String, Object> redisTemplate = SpringContextHolder.getBean("redisTemplate");
             String key = String.join(":", IMRedisKey.IM_USER_SERVER_ID, userId.toString(), terminal.toString());
             redisTemplate.delete(key);
-            log.info("断开连接,userId:{},终端类型:{}", userId, terminal);
+            log.info("断开连接,userId:{},终端类型:{},{}", userId, terminal, ctx.channel().id().asLongText());
         }
     }
 
diff --git a/im-server/src/main/java/com/bx/imserver/netty/processor/HeartbeatProcessor.java b/im-server/src/main/java/com/bx/imserver/netty/processor/HeartbeatProcessor.java
index bf9bf3c..2a0e997 100644
--- a/im-server/src/main/java/com/bx/imserver/netty/processor/HeartbeatProcessor.java
+++ b/im-server/src/main/java/com/bx/imserver/netty/processor/HeartbeatProcessor.java
@@ -30,7 +30,7 @@ public class HeartbeatProcessor extends AbstractMessageProcessor<IMHeartbeatInfo
         IMSendInfo sendInfo = new IMSendInfo();
         sendInfo.setCmd(IMCmdType.HEART_BEAT.code());
         ctx.channel().writeAndFlush(sendInfo);
-
+        ;
         // 设置属性
         AttributeKey<Long> heartBeatAttr = AttributeKey.valueOf(ChannelAttrKey.HEARTBEAT_TIMES);
         Long heartbeatTimes = ctx.channel().attr(heartBeatAttr).get();
@@ -44,6 +44,9 @@ public class HeartbeatProcessor extends AbstractMessageProcessor<IMHeartbeatInfo
             String key = String.join(":", IMRedisKey.IM_USER_SERVER_ID, userId.toString(), terminal.toString());
             redisTemplate.expire(key, IMConstant.ONLINE_TIMEOUT_SECOND, TimeUnit.SECONDS);
         }
+        AttributeKey<Long> userIdAttr = AttributeKey.valueOf(ChannelAttrKey.USER_ID);
+        Long userId = ctx.channel().attr(userIdAttr).get();
+        log.info("心跳,userId:{},{}",userId,ctx.channel().id().asLongText());
     }
 
     @Override