IdleStateHandler源码分析

深碍√TFBOYSˉ_ 2022-12-04 15:59 8阅读 0赞

\*\*

## IdleStateHandler构造器 ##

\*\*

**readerIdleTime**读空闲超时时间设定，如果channelRead()方法超过readerIdleTime时间未被调用则会触发超时事件调用userEventTrigger()方法；

**writerIdleTime**写空闲超时时间设定，如果write()方法超过writerIdleTime时间未被调用则会触发超时事件调用userEventTrigger()方法；

**allIdleTime**所有类型的空闲超时时间设定，包括读空闲和写空闲；

**unit**时间单位，包括时分秒等；

//设置通道心跳机制
    //设置读取器空闲时间秒、写入器空闲时间秒、读写器空闲时间秒
    pipeline.addLast(new IdleStateHandler("","",""));
    public IdleStateHandler(int readerIdleTimeSeconds, 
    int writerIdleTimeSeconds, int allIdleTimeSeconds) { 
            this((long)readerIdleTimeSeconds, (long)writerIdleTimeSeconds, (long)allIdleTimeSeconds, TimeUnit.SECONDS);
        } 
        //读闲的三个状态
    public enum IdleState { 
        READER_IDLE,
        WRITER_IDLE,
        ALL_IDLE;
    
        private IdleState() { 
        }
    }

## 总结 ##

**IdleStateHandler**心跳检测主要是通过向线程任务队列中添加定时任务，判断**channelRead**()方法或**write**()方法是否调用空闲超时，如果超时则触发超时事件执行自定义**userEventTrigger**()方法；

**Netty**通过**IdleStateHandler**实现最常见的心跳机制不是一种双向心跳的PING-PONG模式，而是客户端发送心跳数据包，服务端接收心跳但不回复，因为如果服务端同时有上千个连接，心跳的回复需要消耗大量网络资源；如果服务端一段时间内没有收到客户端的心跳数据包则认为客户端已经下线，将通道关闭避免资源的浪费；在这种心跳模式下服务端可以感知客户端的存活情况，无论是宕机的正常下线还是网络问题的非正常下线，服务端都能感知到，而客户端不能感知到服务端的非正常下线；

要想实现客户端感知服务端的存活情况，需要进行双向的心跳；**Netty**中的**channelInactive**()方法是通过**Socket**连接关闭时挥手数据包触发的，因此可以通过**channelInactive**()方法感知正常的下线情况，但是因为网络异常等非正常下线则无法感知；