第一節(jié):服務(wù)端初始化

首先看下在我們用戶代碼中netty的使用最簡單的一個demo:

//創(chuàng)建boss和worker線程(1)
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
//創(chuàng)建ServerBootstrap(2)
ServerBootstrap b = new ServerBootstrap();
//初始化boss和work線程化兩個線程(3)
b.group(bossGroup, workerGroup)
        //聲明NioServerSocketChannel(4)
        .channel(NioServerSocketChannel.class)
        //初始化客戶端Handler(5)
        .childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(SocketChannel ch) {
                ch.pipeline().addLast(new StringDecoder());
                ch.pipeline().addLast(new StringEncoder());
                ch.pipeline().addLast(new ServerHandler());
            }
        });
//綁定端口(6)
ChannelFuture f = b.bind(8888).sync();
f.channel().closeFuture().sync();

相信這段代碼使用過netty的同學(xué)應(yīng)該都不陌生.這里每一步都用了注釋和步驟序號進(jìn)行標(biāo)注, 為了方便學(xué)習(xí)過程中更容易的定位.每一步的講解, 盡量自己也去跟到源碼中, 這樣會有個更深刻的理解

第一步, 創(chuàng)建兩個線程組:

其中會調(diào)用NioEventLoopGroup()的構(gòu)造方法, 其中的創(chuàng)建邏輯, 并不是這章的重點, 在這里大家只需要知道這里創(chuàng)建了兩個線程組

第二步, 創(chuàng)建ServerBootstrap, 我們發(fā)現(xiàn), 這里創(chuàng)建只調(diào)用了其無參的構(gòu)造方法, 原因很簡單, 就是參數(shù)太多, 盡量要用構(gòu)造方法去初始化, 而是使用后面的build的方式

第三步, 初始化boss和work線程化兩個線程

group方法

我們跟到group方法中去看:

public ServerBootstrap group(EventLoopGroup parentGroup, EventLoopGroup childGroup) {
    //設(shè)置線程池組
    super.group(parentGroup);
    this.childGroup = childGroup;
    return this;
}

為了代碼可讀性, 去掉非關(guān)鍵代碼(以后不再贅述), 我們看到這里初始化了自家的屬性childGroup, 而這個屬性就是我們傳入的worker線程組, 而boss線程組則交給了其父類的group方法去做處理

我們點進(jìn)去super.group(parentGroup), 進(jìn)入到ServerBootstroop的父類AbstractBootstrap的group()方法:

public B group(EventLoopGroup group) {
    this.group = group;
    return (B) this;
}

看到在其父類初始化了boss線程

我們看到這個方法返回了this, 也就是ServerBootstroop自身, 這樣通過自身對象不斷的build進(jìn)行屬性初始化, 之后的方法也是如此

至此, worker和boss兩個線程組初始化完畢

初始化成員變量

回到最開始的第四步, 再點進(jìn)到channel(ServerSocketChannel.class)方法當(dāng)中, 

我們看到AbsractServerBootstrap的channel(Class<? extends C> channelClass)方法:

public B channel(Class<? extends C> channelClass) {
    return channelFactory(new ReflectiveChannelFactory<C>(channelClass));
}

我們看到這個這返回的是channelFactory(new ReflectiveChannelFactory<C>(channelClass))方法, 并且傳入一個ReflectiveChannelFactory對象的實例,

我們可以跟進(jìn)去看下ReflectiveChannelFactory的構(gòu)造方法:

public ReflectiveChannelFactory(Class<? extends T> clazz) {
    this.clazz = clazz;
}

這里初始化了一個成員變量clazz, 而這個clazz就是用戶代碼調(diào)用channel(NioServerSocketChannel.class)傳入的NioServerSocketChannel的class對象

回到channelFactory(new ReflectiveChannelFactory<C>(channelClass))方法, 點進(jìn)去, 我們看到:

public B channelFactory(io.netty.channel.ChannelFactory<? extends C> channelFactory) {
    return channelFactory((ChannelFactory<C>) channelFactory);
}

繼續(xù)跟:

public B channelFactory(io.netty.channel.ChannelFactory<? extends C> channelFactory) {
    return channelFactory((ChannelFactory<C>) channelFactory);
}

跟到最后:

public B channelFactory(ChannelFactory<? extends C> channelFactory) {
    this.channelFactory = channelFactory;
    return (B) this;
}

這里初始化了channelFactory, 而這個channelFactory就是剛才創(chuàng)建的ReflectiveChannelFactory對象, 這里我們記住這個對象中初始化了我們的NioServerSocket的class對象

至此, 我們的ServerSocketChannel的class對象初始化完成

初始化客戶端Handler

我們跟到最開始的第五步, 初始化客戶端Handler:

.childHandler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(SocketChannel ch) {
                ch.pipeline().addLast(new StringDecoder());
                ch.pipeline().addLast(new StringEncoder());
                ch.pipeline().addLast(new ServerHandler());
            }
        });

childHandler()方法比看起來比較復(fù)雜, 其實不難理解, 就是傳入ChannelInitializer類子類的一個對象(有關(guān)匿名內(nèi)部類不知道的同學(xué)可以找下相關(guān)資料學(xué)習(xí)下), 也就是一個Handler, 這個Handler是做什么的, 目前不需要關(guān)心, 以后會講到, 這里我們只需知道這個方法傳入一個handler對象

我們點進(jìn)childHandler這個方法:

public ServerBootstrap childHandler(ChannelHandler childHandler) {
    this.childHandler = childHandler;
    return this;
}

發(fā)現(xiàn)同樣非常簡單的初始化了handler屬性

這一小節(jié)至此結(jié)束, 只是初始化了ServerBootstrap的各個屬性, 是不是非常簡單

我們可以看到, 通過對象build的方式, 可以初始化非常多的屬性, 并且代碼要比構(gòu)造方法的方式可讀性要好的多, 同學(xué)們可以將這種思想用在自己的代碼當(dāng)中...

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

最新評論