网络心跳机制那么简单，但你会写吗

实例要求

1、编写一个Netty心跳检测机制案例，当服务器超过3秒没有读时，就提示读空闲；

2、当服务器超过5秒没有写操作时，就提示写空闲；

3、实现当服务器超过7秒没有读或者写操作时，就提示读写空闲；

服务端代码

public class MyServer {
    public static void main(String[] args) throws Exception{
        NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);
        //默认是8给NioEventLoop
        NioEventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap serverBootstrap = new ServerBootstrap();
            serverBootstrap.group(bossGroup,workerGroup);
            serverBootstrap.channel(NioServerSocketChannel.class);
                    //在bossGroup增加一个日志处理器
            serverBootstrap.handler(new LoggingHandler(LogLevel.INFO));
            serverBootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ChannelPipeline pipeline = ch.pipeline();
                            //加入一个netty提供的IdelStateHandler
                            /**
                             * 1、IdleStateHandler 是netty提供的处理空闲状态的处理器
                             * 2、readerIdleTime：表示多长时间没有读，就会发送一个心跳检测包检测是否连接；
                             * 3、writerIdleTime：表示多长时间没有写，就会发送一个心跳检测包检测是否连接；
                             * 4、allIdleTime：表示多长时间没有读写，就会发送一个心跳检测包检测是否连接；
                             * 5、当IdleStateEvent 触发后，就会传递给管道的下一个handler去处理，通过调用（触发）下一个
                             * handler的userEventTriggered,在该方法中去处理IdleStateEvent(读空闲，写空闲，读写空闲)
                             */
                            pipeline.addLast(new IdleStateHandler(3,5,7, TimeUnit.SECONDS));
                            //加入一个对空闲检测进一步处理的handler(自定义)
                            pipeline.addLast(new MyServerHandler());
                        }
                    });
            //启动服务器
            ChannelFuture channelFuture = serverBootstrap.bind(7000).sync();
            channelFuture.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }

    }
}

处理心跳的业务逻辑handler

/**
 * 处理心跳机制的业务逻辑
 */
public class MyServerHandler extends ChannelInboundHandlerAdapter {
    /**
     *
     * @param ctx 上下文
     * @param evt 事件
     */
    @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;
            }
            System.out.println(ctx.channel().remoteAddress()+"--超时时间--"+eventType);
            System.out.println("服务器做相应的处理......");
        }
    }
}

利用telnet 127.0.0.1 7000连接服务端，然后不写信息看服务端的检测是怎么样的

可以看到，服务端的心跳检测机制已经起作用，有心跳证明连接还在，如果心跳都没有了，那证明连接已经断开了，在实际应用场景中可以结合实际来进行使用