16_Netty_Netty心跳机制实例

实例要求：

1. 编写一个Netty心跳检测机制案例，当服务器超过3秒没有读取事件发生的时候，就提示读空闲；
2. 当服务器超过5秒没有写操作的时候，就提醒写空闲；
3. 实现当服务器超过7秒没有读或者写操作的时候，就提示读写空闲；

服务端

public class MyHeartBeatServer {

    public static void main(String[] args) {
        //两个线程组
        NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);
        NioEventLoopGroup wokerGroup = new NioEventLoopGroup(8);
        try {
            // serverBootstrap
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap
                    .group(bossGroup,wokerGroup)
                    .channel(NioServerSocketChannel.class)
                    // 在bossGroup添加一个日志处理器
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline pipeline = ch.pipeline();
                            // 加入一个netty提供的IdleStateHandler
                            /**
                             * 说明：
                             * 1. IdleStateHandler是netty提供的处理空闲状态的处理器
                             * 2. 前三个参数分别是：
                             *      readerIdleTime【读空闲时间】,
                             *      writerIdleTime【写空闲时间】,
                             *      allIdleTime【读写空闲时间】,
                             *    最后一个参数是时间单位
                             * 3. 如果符合上述条件，就会发送一个心跳检测包检测是否还是连接的状态
                             * 4. 文档说明:
                             *    Triggers an {@link IdleStateEvent} when a {@link Channel} has not performed
                             *    read, write, or both operation for a while.
                             *    读空闲、写空闲、或者读写空闲的时候会触发一个IdleStateEvent事件
                             * 5. 当IdleStateEvent触发，就会传递给管道的下一个Handler去处理
                             *    通过调用（触发）下一个handler的userEventTiggered，在该方法中处理IdleStateEvent（可能是读空闲、写空闲、读写空闲事件）
                             */
                            pipeline.addLast(new IdleStateHandler(3,5,7, TimeUnit.SECONDS));
                            // 加入一个对空闲检测进一步处理的自定义Handler
                            pipeline.addLast(new MyHeartBeatServerHandler());
                        }
                    });
            // 启动服务器
            ChannelFuture channelFuture = serverBootstrap.bind(7000).sync();
            channelFuture.channel().closeFuture().sync();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            bossGroup.shutdownGracefully();
            wokerGroup.shutdownGracefully();
        }
    }

}

自定义处理器

public class MyHeartBeatServerHandler extends ChannelInboundHandlerAdapter {

    /**
     * @param ctx 上下文对象
     * @param evt 事件
     * @throws Exception
     */
    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent) {
            // 将evt向下转型IdleStateEvent
            IdleStateEvent event = (IdleStateEvent) evt;
            String eventType = null;
            switch (event.state()) {
                case READER_IDLE:
                    eventType = "读空闲";
                    break;
                case WRITER_IDLE:
                    eventType = "写空闲";
                    break;
                case ALL_IDLE:
                    eventType = "读写空闲";
                    break;
                default:
            }
            System.out.println(ctx.channel().remoteAddress() + "--------超时事件发生--------" + eventType);
            System.out.println("在这里服务器判断空闲类型，做出相应处理");
//             如果发生空闲，直接关闭channel
//            ctx.channel().close();
        }
    }
}