Nett中的心跳机制与断线重连详解

public IdleStateHandler(long readerIdleTime, long writerIdleTime, long allIdleTime, TimeUnit unit) {
    this(false, readerIdleTime, writerIdleTime, allIdleTime, unit);
}

// 管道中直接添加
// 时间配置为0则代表不检测对应事件
channel.pipeline().addLast(new IdleStateHandler(5,0,0, TimeUnit.SECONDS))

@Slf4j
public class ClientHeartbeatHandler extends IdleStateHandler {
    // 设置写事件为5s
    // 如果5s没有写事件发生 就会触发下面的IdleStateEvent
    private static final int WRITE_IDLE_TIME = 5;
    public ClientHeartbeatHandler() {
        super(0, WRITE_IDLE_TIME, 0, TimeUnit.SECONDS);
    }
    @Override
    protected void channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt) throws Exception {
        // 指定时间内没有写事件发送 就会触发 IdleState.WRITER_IDLE 类型事件
        // 我们就可以对该连接进行处理 主动发送心跳
        if(evt.state()== IdleState.WRITER_IDLE){
            log.info("{} 秒内没有发送数据,再不发送小心和服务端断开连接", WRITE_IDLE_TIME);
            ctx.writeAndFlush(new NettyMsg(ServiceCodeEnum.TEST_TYPE,"我还活着，不要断开连接"));
        }
    }
}

@Slf4j
public class ServerHeartbeatHandler extends IdleStateHandler {
    // 设置读取事件为10s
    // 如果10s没有读事件发生 就会触发下面的IdleStateEvent
    private static final int READER_IDLE_TIME = 10;
    public ServerHeartbeatHandler() {
        super(READER_IDLE_TIME, 0, 0, TimeUnit.SECONDS);
    }
    @Override
    protected void channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt) throws Exception {
        // 指定时间内没有读事件发送 就会触发 IdleState.READER_IDLE 类型事件
        // 我们就可以对该连接进行处理 这里是直接关闭
        if(evt.state()== IdleState.READER_IDLE){
            log.info("{} 秒内没有读取到数据,关闭连接", READER_IDLE_TIME);
            ctx.channel().close();
        }
    }
}

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        log.info(ctx.channel().remoteAddress() + " 已断开连接,开始重连");
        int maxRetryNum=6; //最大重连次数
        int maxRetryTime=60; // 最大重连时间
        int baseRetryTime=4; // 间隔时间基数
        // 开始重连
        for (int i = 1; i <= maxRetryNum; i++) {
            log.info("第{}次重连，间隔{}s后开始",i,baseRetryTime > maxRetryTime ? maxRetryTime:baseRetryTime);
            ctx.channel().eventLoop().schedule(()->{
                // 重连操作
                // .......
                // 判断是否超过隔间上限
            },baseRetryTime > maxRetryTime ? maxRetryTime:baseRetryTime,TimeUnit.SECONDS);
            // 左移扩大一倍
            baseRetryTime = baseRetryTime << 1;
        }
        log.info("这么多次重连都不行寄了吧");
    }