venue/smart_venue
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

netty-客户端不进行读超时检测

Browse Source
This commit is contained in:
limqhz
2020-07-12 09:59:56 +08:00
parent 6f08b24538
commit a4ea65e843
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
netty-pad/src/main/java/com/sv/netty/netty/ServerHandler.java
View File

@@ -113,16 +113,16 @@ public class ServerHandler extends SimpleChannelInboundHandler<String> {
@Override @Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) { public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
// 服务器统计现在有的客户端数量， 客户端这个方法用来发心跳 // 服务器统计现在有的客户端数量， 客户端这个方法用来发心跳
if (evt instanceof IdleStateEvent){ // if (evt instanceof IdleStateEvent){
IdleState state = ((IdleStateEvent) evt).state(); // IdleState state = ((IdleStateEvent) evt).state();
if (state == IdleState.READER_IDLE){ // if (state == IdleState.READER_IDLE){
logger.info("IdleStateEvent READER_IDLE 超时"); // logger.info("IdleStateEvent READER_IDLE 超时");
Integer venueId = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getVenueId(); // Integer venueId = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getVenueId();
String deviceName = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getDeviceName(); // String deviceName = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getDeviceName();
messageService.Offline(deviceName,venueId); // messageService.Offline(deviceName,venueId);
ctx.channel().close(); // ctx.channel().close();
} // }
} // }
Set<String> conns = messageService.countConnection(); Set<String> conns = messageService.countConnection();
logger.info("count connected device ! the count is " + conns.size() + " and they are + [" + conns.toString() + "]" ); logger.info("count connected device ! the count is " + conns.size() + " and they are + [" + conns.toString() + "]" );
} }