This commit is contained in:
2023-11-10 13:42:18 +08:00
parent 71501a1e3a
commit af45b8d64b

View File

@@ -179,8 +179,8 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
log.error("Client-IP:【{}】, channelId:【{}】, pileSn:【{}】, ALL_IDLE 总超时", socketString, channelId, pileSn);
}
if (flag) {
ctx.channel().close();
close(channelId, pileSn);
// ctx.channel().close();
// close(channelId, pileSn);
}
}
}
@@ -203,7 +203,7 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
log.error("【{}】发生了错误, pileSn:【{}】此连接被关闭, 此时连通数量: {}", channelId, pileSn, CHANNEL_MAP.size());
ctx.channel().close();
}
close(channelId, pileSn);
// close(channelId, pileSn);
}
private void close(ChannelId channelId, String pileSn) {