private void register0(ChannelPromise promise) {
    try {
        //省略代碼
        //做實際的注冊
        doRegister();
        neverRegistered = false;
        registered = true;
        //觸發(fā)事件
        pipeline.invokeHandlerAddedIfNeeded();
        safeSetSuccess(promise);
        //觸發(fā)注冊成功事件
        pipeline.fireChannelRegistered();
        if (isActive()) {
            if (firstRegistration) {
                //傳播active事件(4)
                pipeline.fireChannelActive();
            } else if (config().isAutoRead()) {
                beginRead();
            }
        }
    } catch (Throwable t) {
        //省略代碼
    }
}

doRegister()做完實際的注冊之后, 會走到if (isActive())這個判斷, 因為這個時候鏈路已經(jīng)完成, 所以這里是true, 默認(rèn)判斷條件if (firstRegistration)也為true, 所以這里會走到pipeline.fireChannelActive()這一步

有關(guān)pipeline我們會在下一章進(jìn)行詳細(xì)分析, 這里我們只需要知道, 最后會流轉(zhuǎn)到AbstractUnsafe的beginRead()方法

跟到beginRead()方法:

public final void beginRead() {
    assertEventLoop();
    if (!isActive()) {
        return;
    }
    try {
        doBeginRead();
    } catch (final Exception e) {
        //代碼省略
    }
}

這塊代碼同樣我們也不陌生, 因為我們分析NioServerSocketChannel也分析過了這一步

我們繼續(xù)跟到doBeginRead():

protected void doBeginRead() throws Exception {
    //拿到selectionKey
    final SelectionKey selectionKey = this.selectionKey;
    if (!selectionKey.isValid()) {
        return;
    }
    readPending = true;
    //獲得感興趣的事件
    final int interestOps = selectionKey.interestOps();
    //判斷是不是對任何事件都不監(jiān)聽
    if ((interestOps & readInterestOp) == 0) {
        //此條件成立
        //將之前的accept事件注冊, readInterest代表可以讀取一個新連接的意思
        selectionKey.interestOps(interestOps | readInterestOp);
    }
}

這段代碼相信大家會比較熟悉, 因為我們服務(wù)端channel注冊完之后也走到了這里

因為我們在創(chuàng)建NioSocketChannel的時候初始化的是read事件, selectionKey是channel在注冊時候返回的key, 所以selectionKey.interestOps(interestOps | readInterestOp)這一步, 會將當(dāng)前channel的讀事件注冊到selector中去

注冊完成之后, NioEventLoop就可以輪詢當(dāng)前channel的讀事件了

以上就是NioSocketChannel注冊監(jiān)聽事件的流程

章節(jié)小結(jié)

本章學(xué)習(xí)了有關(guān)客戶端接入, NioSocketChannel的創(chuàng)建, 注冊等相關(guān)操作, 并且涉及到了上一小節(jié)剖析的eventLoop的相關(guān)邏輯, 同學(xué)們可以將相關(guān)的流程通過debug的方式走一遍以加深印象

以上就是Netty分布式源碼分析監(jiān)聽讀事件的詳細(xì)內(nèi)容，更多關(guān)于Netty分布式監(jiān)聽讀事件的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: