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沒有寫事件發(fā)生 就會觸發(fā)下面的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 {
        // 指定時間內沒有寫事件發(fā)送 就會觸發(fā) IdleState.WRITER_IDLE 類型事件
        // 我們就可以對該連接進行處理 主動發(fā)送心跳
        if(evt.state()== IdleState.WRITER_IDLE){
            log.info("{} 秒內沒有發(fā)送數(shù)據(jù),再不發(fā)送小心和服務端斷開連接", WRITE_IDLE_TIME);
            ctx.writeAndFlush(new NettyMsg(ServiceCodeEnum.TEST_TYPE,"我還活著，不要斷開連接"));
        }
    }
}

@Slf4j
public class ServerHeartbeatHandler extends IdleStateHandler {
    // 設置讀取事件為10s
    // 如果10s沒有讀事件發(fā)生 就會觸發(fā)下面的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 {
        // 指定時間內沒有讀事件發(fā)送 就會觸發(fā) IdleState.READER_IDLE 類型事件
        // 我們就可以對該連接進行處理 這里是直接關閉
        if(evt.state()== IdleState.READER_IDLE){
            log.info("{} 秒內沒有讀取到數(shù)據(jù),關閉連接", READER_IDLE_TIME);
            ctx.channel().close();
        }
    }
}

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        log.info(ctx.channel().remoteAddress() + " 已斷開連接,開始重連");
        int maxRetryNum=6; //最大重連次數(shù)
        int maxRetryTime=60; // 最大重連時間
        int baseRetryTime=4; // 間隔時間基數(shù)
        // 開始重連
        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("這么多次重連都不行寄了吧");
    }