快捷導(dǎo)航

Netty啟動(dòng)步驟綁定端口示例方法源碼分析

更新時(shí)間：2022年03月25日 11:54:46 作者：向南是個(gè)萬(wàn)人迷

這篇文章主要介紹了Netty啟動(dòng)步驟綁定端口源碼分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

綁定端口

上一小節(jié)我們學(xué)習(xí)了channel注冊(cè)在selector的步驟, 僅僅做了注冊(cè)但并沒(méi)有監(jiān)聽(tīng)事件, 事件是如何監(jiān)聽(tīng)的呢?

我們繼續(xù)跟第一小節(jié)的最初的doBind()方法

private ChannelFuture doBind(final SocketAddress localAddress) {
    //初始化并注冊(cè)(1)
    final ChannelFuture regFuture = initAndRegister();
    //獲得channel(2)
    final Channel channel = regFuture.channel();
    if (regFuture.cause() != null) {
        return regFuture;
    }
    if (regFuture.isDone()) {
        ChannelPromise promise = channel.newPromise();
        //綁定(3) 
        doBind0(regFuture, channel, localAddress, promise);
        return promise;
    } else {
        //去除非關(guān)鍵代碼
        return promise;
    }
}

上一小節(jié)跟完了initAndRegister()方法, 我們繼續(xù)往下走:

第二步, 獲得channel

final Channel channel = regFuture.channel();

通過(guò)ChannelFuture的channel()方法獲得了我們剛剛注冊(cè)的NioServerSocketChannel, 拿到這個(gè)channel我們跟到第三步, 綁定

跟進(jìn)方法doBind0(regFuture, channel, localAddress, promise):

private static void doBind0(final ChannelFuture regFuture, final Channel channel, final SocketAddress localAddress, final ChannelPromise promise) { 
    channel.eventLoop().execute(new Runnable() {
        @Override
        public void run() {
            if (regFuture.isSuccess()) {
                //綁定端口
                channel.bind(localAddress, promise).addListener(ChannelFutureListener.CLOSE_ON_FAILURE);
            } else {
                promise.setFailure(regFuture.cause());
            }
        }
    });
}

最終會(huì)走到channel.bind(localAddress, promise)這個(gè)方法當(dāng)中

繼續(xù)跟, 會(huì)走到AbstractChannel的bind()方法中:

public ChannelFuture bind(SocketAddress localAddress, ChannelPromise promise) {
    //通過(guò)pipeline綁定端口
    return pipeline.bind(localAddress, promise);
}

這里的pipeline就是channel初始化創(chuàng)建的pipline, pipline是事件傳輸通道, 這里我們暫不跟傳輸過(guò)程, 我們只需知道最后這個(gè)方法走到了AbstractChannel的bind()方法

跟到AbstractChannel的bind()方法:

public final void bind(final SocketAddress localAddress, final ChannelPromise promise) {
    //代碼省略
    //端口綁定之前不是active, 返回false
    boolean wasActive = isActive();
    try {
        //做jdk底層的綁定
        doBind(localAddress);
    } catch (Throwable t) {
        //省略
        return;
    }
    //端口綁定之前不是active, 端口綁定之后變成active了
    if (!wasActive && isActive()) {
        invokeLater(new Runnable() {
            @Override
            public void run() {
                pipeline.fireChannelActive();
            }
        });
    }
    safeSetSuccess(promise);
}

重點(diǎn)關(guān)注下doBind(localAddress)方法

跟到NioSeverSocketChannel的doBind()方法:

protected void doBind(SocketAddress localAddress) throws Exception {
    //jdk版本的判斷
    if (PlatformDependent.javaVersion() >= 7) {
        javaChannel().bind(localAddress, config.getBacklog());
    } else {
        javaChannel().socket().bind(localAddress, config.getBacklog());
    }
}

開(kāi)始是一個(gè)jdk版本的判斷, 我們以jdk7以上為例, 看到這條語(yǔ)句:

javaChannel().bind(localAddress, config.getBacklog());

終于找到了和jdk底層相關(guān)的綁定邏輯了, javaChannel()返回的是當(dāng)前channel綁定的jdk底層的channel, 而bind()方法, 就是jdk底層的channel綁定端口的邏輯

回到bind(final SocketAddress localAddress, final ChannelPromise promise)方法:

首先看if判斷: if (!wasActive && isActive())

這里意思是如果之前不是active, 綁定之后是active的話, 執(zhí)行if塊, 顯然這里符合條件, 繼續(xù)往里走

最終會(huì)走到這一步, pipeline.fireChannelActive()

這也是傳輸active事件, 目前我們只需知道, 事件完成之后, 會(huì)調(diào)用AbstractChannel內(nèi)部類AbstractUnsafe的beginRead()方法

跟到AbstractUnsafe的beginRead()方法中:

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

我們關(guān)注doBeginRead()方法:

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

這里到了jdk底層的調(diào)用邏輯, 通過(guò)注釋不難看出其中的邏輯, 我們拿到和channel綁定的jdk底層的selectionKey, 獲取其監(jiān)聽(tīng)事件, 一上節(jié)我們知道, channel注冊(cè)的時(shí)候沒(méi)有注冊(cè)任何事件, 所以我們這里if ((interestOps & readInterestOp) == 0) 返回true, 之后, 將accept事件注冊(cè)到channel中, 也就是 selectionKey.interestOps(interestOps | readInterestOp) 這步執(zhí)行的

注冊(cè)完accept事件之后, 就可以輪詢selector, 監(jiān)聽(tīng)是否有新連接接入了