From a4ea65e8431dea69b2c44a5e4f7cb6ebc4c0189a Mon Sep 17 00:00:00 2001 From: limqhz Date: Sun, 12 Jul 2020 09:59:56 +0800 Subject: [PATCH] =?UTF-8?q?netty-=E5=AE=A2=E6=88=B7=E7=AB=AF=E4=B8=8D?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E8=AF=BB=E8=B6=85=E6=97=B6=E6=A3=80=E6=B5=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/sv/netty/netty/ServerHandler.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/netty-pad/src/main/java/com/sv/netty/netty/ServerHandler.java b/netty-pad/src/main/java/com/sv/netty/netty/ServerHandler.java index 36d0e18..27dbc1b 100644 --- a/netty-pad/src/main/java/com/sv/netty/netty/ServerHandler.java +++ b/netty-pad/src/main/java/com/sv/netty/netty/ServerHandler.java @@ -113,16 +113,16 @@ public class ServerHandler extends SimpleChannelInboundHandler { @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) { // 服务器统计现在有的客户端数量， 客户端这个方法用来发心跳 - if (evt instanceof IdleStateEvent){ - IdleState state = ((IdleStateEvent) evt).state(); - if (state == IdleState.READER_IDLE){ - logger.info("IdleStateEvent READER_IDLE 超时"); - Integer venueId = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getVenueId(); - String deviceName = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getDeviceName(); - messageService.Offline(deviceName,venueId); - ctx.channel().close(); - } - } +// if (evt instanceof IdleStateEvent){ +// IdleState state = ((IdleStateEvent) evt).state(); +// if (state == IdleState.READER_IDLE){ +// logger.info("IdleStateEvent READER_IDLE 超时"); +// Integer venueId = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getVenueId(); +// String deviceName = ctx.channel().attr(Constant.CHANNEL_PARAM).get().getDeviceName(); +// messageService.Offline(deviceName,venueId); +// ctx.channel().close(); +// } +// } Set conns = messageService.countConnection(); logger.info("count connected device ! the count is " + conns.size() + " and they are + [" + conns.toString() + "]" ); }