netty心跳检测

为什么需要心跳

在TCP长连接的过程中，若发生网络抖动等原因，导致连接中断。恰好服务器和客户端之间在这个 时间点没有数据交互。则不能在短时间内发现对方掉线。

心跳检测的原理：

在客服端和服务器之间没有数据交互处于idle状态时，客服端或者服务器向对方发送一种特殊的数据包 ，对方收到数据包之后也回一个特定的数据包。形成一个ping-pong交互。当某方掉线时，可以及时确认TCP的连接有效性

实现心跳的两种方式

1、使用TCP协议层面keeplive机制【注意区分Http的header中的keep-alive是标识 是否保持长连接。HTTP/1.1 默认长连接，不需要带这个 header】

• TCP 层的 keepalive 默认关闭，且经过路由等中转设备 keepalive 包可能会被丢弃
• TCP 层的 keepalive 时间太长,默认 > 2 小时，虽然可改，但属于系统参数，改动影响所有应用

查看系统tcp_keepalive命令：

sysctl -a|grep tcp_keepalive

#TCP 在连接没有数据通过的7200秒后发送 keepalive 消息
net.ipv4.tcp_keepalive_time = 7200 
#当探测没有确认时，按75秒的重试频率重发，
net.ipv4.tcp_keepalive_intvl = 75
#一直发 9 个探测包都没有确认，就认定连接失效
net.ipv4.tcp_keepalive_probes = 9

所以总耗时一般为：2 小时 11 分钟 (7200 秒 + 75 秒* 9 次)

2、在应用层实现心跳机制

原理：客户端或者服务器会开启一个定时任务，定时对已经建立连接的对端应用发送请求， 对方收到请求并响应。如果心跳持续多次没有收到响应，就会认为对方连接不可用，主动断开连接。

例如应用层的框架dubbo、cloud、zookeeper、redis部署均有心跳检测机制

Netty实现心跳检测

Netty中自带了一个IdleStateHandler 可以用来实现心跳检测。

public class Server {


    public void start(){
        ServerBootstrap bootstrap = new ServerBootstrap();
        EventLoopGroup boss = new NioEventLoopGroup();
        EventLoopGroup worker = new NioEventLoopGroup();
        try{
            bootstrap.group(boss,worker)
                    .handler(new LoggingHandler(LogLevel.INFO))
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new HeartBeatInitializer());

            ChannelFuture future = bootstrap.bind(8080).sync();
            future.channel().closeFuture().sync();
        }catch(Exception e){
            e.printStackTrace();
        }finally {
            worker.shutdownGracefully();
            boss.shutdownGracefully();
        }
    }
    
}