alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-07 22:07:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] channel with no clientId

Browse Source
This commit is contained in:
wujiawei 2024-01-17 16:25:58 +08:00
parent 62ecd2f987
commit 8f904cf1b0
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
wu-lazy-cloud-heartbeat-server/src/main/java/wu/framework/lazy/cloud/heartbeat/server/netty/handler/NettyServerHandler.java
View File

@ -105,10 +105,13 @@ public class NettyServerHandler extends SimpleChannelInboundHandler<NettyProxyMs
String clientId = ChannelAttributeKeyUtils.getClientId(channel); String clientId = ChannelAttributeKeyUtils.getClientId(channel);
log.info("断开客户端的连接:{}", clientId); log.info("断开客户端的连接:{}", clientId);
if (!ObjectUtils.isEmpty(clientId)) {
NettyProxyMsg nettyMsg = new NettyProxyMsg(); NettyProxyMsg nettyMsg = new NettyProxyMsg();
nettyMsg.setType(MessageType.REPORT_CLIENT_DISCONNECTION); nettyMsg.setType(MessageType.REPORT_CLIENT_DISCONNECTION);
nettyMsg.setClientId(clientId); nettyMsg.setClientId(clientId);
channelTypeAdapter.handler(channel, nettyMsg); channelTypeAdapter.handler(channel, nettyMsg);
super.channelInactive(ctx); super.channelInactive(ctx);
} }
}
} }