Netty檢測(cè)空閑連接以及超時(shí)

處理空閑連接是一項(xiàng)常見(jiàn)的任務(wù),Netty 提供了幾個(gè) ChannelHandler 實(shí)現(xiàn)此目的。表8.4概述。

Table 8.4 ChannelHandlers for idle connections and timeouts

詳細(xì)看下 IdleStateHandler，下面是一個(gè)例子，當(dāng)超過(guò)60秒沒(méi)有數(shù)據(jù)收到時(shí)，就會(huì)得到通知，此時(shí)就發(fā)送心跳到遠(yuǎn)端，如果沒(méi)有回應(yīng)，連接就關(guān)閉。

Listing 8.7 Sending heartbeats

public class IdleStateHandlerInitializer extends ChannelInitializer<Channel> {

    @Override
    protected void initChannel(Channel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast(new IdleStateHandler(0, 0, 60, TimeUnit.SECONDS));  //1
        pipeline.addLast(new HeartbeatHandler());
    }

    public static final class HeartbeatHandler extends ChannelInboundHandlerAdapter {
        private static final ByteBuf HEARTBEAT_SEQUENCE = Unpooled.unreleasableBuffer(
                Unpooled.copiedBuffer("HEARTBEAT", CharsetUtil.ISO_8859_1));  //2

        @Override
        public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
            if (evt instanceof IdleStateEvent) {
                 ctx.writeAndFlush(HEARTBEAT_SEQUENCE.duplicate())
                         .addListener(ChannelFutureListener.CLOSE_ON_FAILURE);  //3
            } else {
                super.userEventTriggered(ctx, evt);  //4
            }
        }
    }
}

1. IdleStateHandler 將通過(guò) IdleStateEvent 調(diào)用 userEventTriggered ，如果連接沒(méi)有接收或發(fā)送數(shù)據(jù)超過(guò)60秒鐘
2. 心跳發(fā)送到遠(yuǎn)端
3. 發(fā)送的心跳并添加一個(gè)偵聽(tīng)器，如果發(fā)送操作失敗將關(guān)閉連接
4. 事件不是一個(gè) IdleStateEvent 的話，就將它傳遞給下一個(gè)處理程序

總而言之,這個(gè)例子說(shuō)明了如何使用 IdleStateHandler 測(cè)試遠(yuǎn)端是否還活著，如果遠(yuǎn)端已經(jīng)不活著了就可以將該鏈接關(guān)閉以釋放資源。