channelInactive

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

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