快捷導(dǎo)航

Netty啟動流程服務(wù)端channel初始化源碼分析

更新時間：2022年03月25日 10:08:08 作者：向南是個萬人迷

這篇文章主要為大家介紹了Netty啟動流程服務(wù)端channel初始化源碼分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

服務(wù)端channel初始化

回顧上一小節(jié)initAndRegister()方法

final ChannelFuture initAndRegister() {
    Channel channel = null;
    try {
        //創(chuàng)建channel
        channel = channelFactory.newChannel();
        //初始化channel
        init(channel);
    } catch (Throwable t) {
        //忽略非關(guān)鍵代碼
    }
    ChannelFuture regFuture = config().group().register(channel);
    //忽略非關(guān)鍵代碼
    return regFuture;
}

簡單回顧上一小節(jié)內(nèi)容, 我們跟完了創(chuàng)建channel的步驟, 知道了Netty的NioServerSocketChannel和jdk的ServerSocketChannel之間的關(guān)系, NioServerSocketChannel和jdk的channel是組合關(guān)系, 在其父類AbstractChannel中有jdk的channel的一個成員變量, 通過創(chuàng)建netty的channel為jdk的channel賦值

init(Channel)方法

我們繼續(xù)往下看init(Channel)方法

因為是ServerBootstrap對象調(diào)用的init()方法, 所以我們跟到ServerBootstrap類的init()方法中:

void init(Channel channel) throws Exception {
    //獲取用戶定義的選項(1)
    final Map<ChannelOption<?>, Object> options = options0();
    synchronized (options) {
        channel.config().setOptions(options);
    }

    //獲取用戶定義的屬性(2)
    final Map<AttributeKey<?>, Object> attrs = attrs0();
    synchronized (attrs) {
        for (Entry<AttributeKey<?>, Object> e: attrs.entrySet()) {
            @SuppressWarnings("unchecked")
            AttributeKey<Object> key = (AttributeKey<Object>) e.getKey();
            channel.attr(key).set(e.getValue());
        }
    }
    //獲取channel的pipline(3)
    ChannelPipeline p = channel.pipeline();
    //work線程組(4)
    final EventLoopGroup currentChildGroup = childGroup;
    //用戶設(shè)置的Handler(5)
    final ChannelHandler currentChildHandler = childHandler;
    final Entry<ChannelOption<?>, Object>[] currentChildOptions;
    final Entry<AttributeKey<?>, Object>[] currentChildAttrs;
    //選項轉(zhuǎn)化為Entry對象(6)
    synchronized (childOptions) { 
        currentChildOptions = childOptions.entrySet().toArray(newOptionArray(childOptions.size()));
    }
    //屬性轉(zhuǎn)化為Entry對象(7)
    synchronized (childAttrs) { 
        currentChildAttrs = childAttrs.entrySet().toArray(newAttrArray(childAttrs.size()));
    }
    //添加服務(wù)端handler(8)
    p.addLast(new ChannelInitializer<Channel>() {
        //初始化channel
        @Override
        public void initChannel(Channel ch) throws Exception {
            final ChannelPipeline pipeline = ch.pipeline();
            ChannelHandler handler = config.handler();
            if (handler != null) { 
                pipeline.addLast(handler);
            } 
            ch.eventLoop().execute(new Runnable() {
                @Override
                public void run() { 
                    pipeline.addLast(new ServerBootstrapAcceptor(
                            currentChildGroup, currentChildHandler, currentChildOptions, currentChildAttrs));
                }
            });
        }
    });
}

初看起來代碼好長, 其實并不復(fù)雜, 這里對每一步進行一個簡述:

步驟(1), (2)是獲取的用戶代碼中定義的選項和屬性

步驟(3)是獲取channel的pipeline, 這個channel就是上一小節(jié)我們學(xué)習(xí)創(chuàng)建的NioServerSocketChannel, 我們知道每個channel都有個pipeline的屬性, 是AbstractChannel的成員變量, 而這里的pipeline()就是獲取其與channel綁定的pipeline, 這個pipline, 會在后面的章節(jié)中講到

步驟(4)是獲取worker線程組, 我們知道這個worker線程組就是在用戶代碼中創(chuàng)建的NioEventLoopGroup, 后來在ServerBootstrap的group()方法中賦值為ServerBootstrap的成員變量, 而這里是獲取其成員變量, 并賦值到局部變量currentChildGroup中, NioEventLoop相關(guān)知識會在后面的章節(jié)講到

步驟(6), (7)是將選項和屬性轉(zhuǎn)化成Entry對象

步驟(8)是添加服務(wù)端Handler, 是通過和channel綁定的pipeline調(diào)用addLast()方法進行添加, 傳入一個ChannelInitializer類的子類對象, 至于addLast方法是做什么的, ChannelInitializer是做什么的, 后緒章節(jié)都會給大家詳細(xì)剖析, 這里不必深究

這一小節(jié)我們了解了有關(guān)channel初始化的過程, 我們目前只需了解其大概步驟, 有關(guān)addLast的邏輯會在后面的章節(jié)進行詳細(xì)剖析

以上就是Netty啟動流程服務(wù)端channel初始化源碼分析的詳細(xì)內(nèi)容，更多關(guān)于Netty啟動流程服務(wù)端channel初始化的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: