autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-07-07 15:38:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

公共方法 关闭连接

Browse Source
This commit is contained in:
autumn.g@foxmail.com
2023-12-06 14:31:21 +08:00
parent 33f33778bd
commit f249184cfe
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerHandler.java
View File

@@ -208,14 +208,20 @@ public class NettyServerHandler extends ChannelInboundHandlerAdapter {
// close(channelId, pileSn); // close(channelId, pileSn);
} }
private void close(ChannelId channelId, String pileSn, ChannelHandlerContext ctx) {
log.error("close方法-发生异常，关闭链接，channelId:{}, pileSn:{}", channelId.asShortText(), pileSn);
// 公共方法 关闭连接
private void closeConnection(String pileSn, ChannelHandlerContext ctx) {
Channel channel = ctx.channel();
ChannelId channelId = channel.id();
log.error("close方法-发生异常，关闭链接，channelId:{}, pileSn:{}", channelId.asShortText(), pileSn);
if (channel != null && !channel.isActive() && !channel.isOpen() && !channel.isWritable()) {
channel.close();
// 删除连接
CHANNEL_MAP.remove(channelId);
}
// 删除桩编号和channel的关系 // 删除桩编号和channel的关系
if (StringUtils.isNotBlank(pileSn)) { if (StringUtils.isNotBlank(pileSn)) {
// PileChannelEntity.removeByPileSn(pileSn); PileChannelEntity.removeByPileSn(pileSn);
} }
// 删除连接
CHANNEL_MAP.remove(channelId);
} }
} }