添加日志打印

core/src/main/java/com/wecloud/im/netty/core/ChannelInboundHandler.java

@@ -75,6 +75,7 @@ public class ChannelInboundHandler extends ChannelInboundHandlerAdapter {
         super.channelInactive(ctx);
         super.channelInactive(ctx);
         Long clientId = ctx.channel().attr(ChannelManager.CLIENT_ID).get();
         Long clientId = ctx.channel().attr(ChannelManager.CLIENT_ID).get();
         log.info("触发channelInactive方法 clientId {}", clientId);
         log.info("触发channelInactive方法 clientId {}", clientId);
+//        ctx.channel().close();
     }
     }
     @Override
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)

core/src/main/java/com/wecloud/im/ws/manager/ChannelManager.java

@@ -99,6 +99,7 @@ public class ChannelManager {
         log.info("本地存缓存key {}", genKeyForSessionInfoMap(clientId, platform));
         log.info("本地存缓存key {}", genKeyForSessionInfoMap(clientId, platform));
         ClientInfo oldChanel = ChannelManager.SESSION_INFO_MAP.get(genKeyForSessionInfoMap(clientId, platform));
         ClientInfo oldChanel = ChannelManager.SESSION_INFO_MAP.get(genKeyForSessionInfoMap(clientId, platform));
         if(oldChanel != null) {
         if(oldChanel != null) {
+            log.info("删除旧连接 oldChanel {}", oldChanel.getNioSocketChannel().id());
             oldChanel.getNioSocketChannel().close();
             oldChanel.getNioSocketChannel().close();
         }
         }
         ChannelManager.SESSION_INFO_MAP.put(genKeyForSessionInfoMap(clientId, platform), clientInfo);
         ChannelManager.SESSION_INFO_MAP.put(genKeyForSessionInfoMap(clientId, platform), clientInfo);