moquette改造筆記(四)：解決InterceptHandler中的onConnectionLo

joyqi 發(fā)布于2019-08-19 11:13 / 1717人閱讀

摘要：發(fā)現(xiàn)問題在使用中設(shè)備異常斷開中的。在中事件都是在鏈中依次傳遞的。事件最后傳遞到。解決方法添加會導(dǎo)致調(diào)用兩次解釋會在該從鏈中移除掉時被調(diào)用，一般的話沒有手動從鏈中刪除時，會在連接斷開后回調(diào)該方法。

發(fā)現(xiàn)問題

在使用中設(shè)備異常斷開,InterceptHandler中的onConnectionLost()。經(jīng)過調(diào)試發(fā)現(xiàn)是MoquetteIdleTimeoutHandler中的代碼導(dǎo)致的，代碼如下：

@Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
        if (evt instanceof IdleStateEvent) {
            IdleState e = ((IdleStateEvent) evt).state();
            if (e == IdleState.READER_IDLE) {
                LOG.info("Firing channel inactive event. MqttClientId = {}.", NettyUtils.clientID(ctx.channel()));
                // fire a channelInactive to trigger publish of Will
                ctx.fireChannelInactive();
                ctx.close().addListener(CLOSE_ON_FAILURE);
            }
        } 
        ......
    }

這部分代碼的大致含義是：當(dāng)在一段時間內(nèi)沒有收到任何數(shù)據(jù)后，就會調(diào)用觸發(fā)ChannelInactive事件然后關(guān)掉連接。
在netty中事件都是在handler鏈中依次傳遞的。ChannelInactive事件最后傳遞到NettyMQTTHandler。處理邏輯如下：

  public void channelInactive(ChannelHandlerContext ctx) {
        String clientID = NettyUtils.clientID(ctx.channel());
        if (clientID != null && !clientID.isEmpty()) {
            LOG.info("N otifying connection lost event. MqttClientId = {}", clientID);
            m_processor.processConnectionLost(clientID, ctx.channel());
        }
        ctx.close().addListener(CLOSE_ON_FAILURE);
    }

如果條件成立，會調(diào)用一次m_processor.processConnectionLost(clientID, ctx.channel());這會導(dǎo)致InterceptHandler中的onConnectionLost()調(diào)用一次。因為連接緊接著又被關(guān)閉了，連接關(guān)閉同樣會導(dǎo)致ChannelInactive事件，因此以上方法又會被觸發(fā)一次，因此這樣就會造成異常斷開會調(diào)用兩次onConnectionLost()。

解決方法

添加handlerRemove

 @Override
    public void channelInactive(ChannelHandlerContext ctx) {
        /** modify by ljq 2018.6.11 會導(dǎo)致processConnectionLost調(diào)用兩次*/
//        String clientID = NettyUtils.clientID(ctx.channel());
//        if (clientID != null && !clientID.isEmpty()) {
//            LOG.info("N otifying connection lost event. MqttClientId = {}", clientID);
//            m_processor.processConnectionLost(clientID, ctx.channel());
//        }
        ctx.close().addListener(CLOSE_ON_FAILURE);
    }
    
    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        String clientID = NettyUtils.clientID(ctx.channel());
        if (clientID != null && !clientID.isEmpty()) {
            LOG.info("Notifying connection lost event. MqttClientId = {}", clientID);
            m_processor.processConnectionLost(clientID, ctx.channel());
        }
    }

解釋：
handler remove會在該handler從鏈中移除掉時被調(diào)用，一般的話沒有手動從鏈中刪除時，會在連接斷開后回調(diào)該方法。