IdleStateHandler及心跳机制的使用

xuchang1 · Jul 24, 2019 · c998b11 · c998b11
1 parent 177e92d
commit c998b11
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/src/main/java/netty_demo/nettytimeout/ClientHandler.java b/src/main/java/netty_demo/nettytimeout/ClientHandler.java
@@ -15,7 +15,8 @@ protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Excep
 
     @Override
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
-        ctx.channel().writeAndFlush(Unpooled.copiedBuffer("nihao", CharsetUtil.UTF_8));
+        ByteBuf byteBuf = Unpooled.copiedBuffer("nihao", CharsetUtil.UTF_8);
+        ctx.channel().writeAndFlush(byteBuf);
     }
 
     @Override

diff --git a/src/main/java/netty_demo/nettytimeout/EchoServer.java b/src/main/java/netty_demo/nettytimeout/EchoServer.java
@@ -36,7 +36,7 @@ private void start() throws Exception {
                         @Override
                         protected void initChannel(SocketChannel ch) throws Exception {
                             //IdleStateHandler监控服务端读写超时时间
-                            ch.pipeline().addLast(new IdleStateHandler(10, 8, 7, TimeUnit.SECONDS));
+                            ch.pipeline().addLast(new IdleStateHandler(0, 0, 5, TimeUnit.SECONDS));
                             ch.pipeline().addLast(new EchoServerHandler());
                         }
                     });

diff --git a/src/main/java/netty_demo/nettytimeout/EchoServerHandler.java b/src/main/java/netty_demo/nettytimeout/EchoServerHandler.java
@@ -1,14 +1,23 @@
 package netty_demo.nettytimeout;
 
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.handler.timeout.IdleStateEvent;
+import io.netty.util.CharsetUtil;
 
 public class EchoServerHandler extends ChannelInboundHandlerAdapter {
 
     @Override
     public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
+
         if (evt instanceof IdleStateEvent) {
+            ctx.writeAndFlush(Unpooled.copiedBuffer("是否断开连接了", CharsetUtil.UTF_8))
+                    .addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
+        }
+
+        /*if (evt instanceof IdleStateEvent) {
             IdleStateEvent event = (IdleStateEvent) evt;
 
             String eventType = null;
@@ -28,6 +37,6 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exc
             }
 
             System.out.println(ctx.channel().remoteAddress() + " 超时时间 : " + eventType);
-        }
+        }*/
     }
 }