摘要：對于，目前大家只知道是個(gè)線程組，其內(nèi)部到底如何實(shí)現(xiàn)的，它的作用到底是什么，大家也都不太清楚，由于篇幅原因，這里不作詳細(xì)介紹，后面會有文章作專門詳解。

在上一篇《ServerBootstrap 與 Bootstrap 初探》中，我們已經(jīng)初步的了解了ServerBootstrap是netty進(jìn)行服務(wù)端開發(fā)的引導(dǎo)類。 且在上一篇的服務(wù)端示例中，我們也看到了，在使用netty進(jìn)行網(wǎng)絡(luò)編程時(shí)，我們是通過bind方法的調(diào)用來完成服務(wù)器端口的偵聽：

EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap(); 
    b.group(bossGroup, workerGroup)　　
     .channel(NioServerSocketChannel.class) 
     .handler(new LoggingHandler())   
     .childHandler(new ChannelInitializer() { 
         @Override
         public void initChannel(SocketChannel ch) throws Exception {
             ch.pipeline().addLast(new DiscardServerHandler());
         }
     })
     .option(ChannelOption.SO_BACKLOG, 128)        
     .childOption(ChannelOption.SO_KEEPALIVE, true);
    
     // 偵聽8000端口
     ChannelFuture f = b.bind(8000).sync(); 
    
     f.channel().closeFuture().sync();
} finally {
    workerGroup.shutdownGracefully();
    bossGroup.shutdownGracefully();
}

從上面的服務(wù)端示例中可以看到，我們只是定義了主線程組及worker線程組，以及指定了channel類型為NioServerSocketChannel等等一些簡單的配置， 然后綁定偵聽端口，用于網(wǎng)絡(luò)服務(wù)的主體代碼基本就完了（業(yè)務(wù)代碼在Handler中實(shí)現(xiàn)，后面的文章會詳細(xì)介紹。
這真的大大簡化并方便了java程序員使用netty來進(jìn)行網(wǎng)絡(luò)開發(fā)，但是想要深入學(xué)習(xí)netty的人可能會有下面的一些疑問：

netty是繼續(xù)Java NIO的，那么ServerSocketChannel是什么時(shí)候初始化的？

我怎么沒有看到Java NIO中的selector， netty是如何實(shí)現(xiàn)多路復(fù)用的？

我們設(shè)置的handler 或者 childHandler，是如何應(yīng)用的？

boss線程組 以及 worker線程組 其實(shí)如何分配線程的？

為什么是boss線程組，難道接收用戶請求是多個(gè)線程一起工作？

。。。

本篇將帶著上面這些疑問，我們將進(jìn)入bind方法內(nèi)部，深入淺出，對netty的工作機(jī)制一探究竟。

當(dāng)我們調(diào)用ServerBootstrap的bind方法時(shí)，其實(shí)是調(diào)用的是父類AbstractBootstrap的bind方法：

public ChannelFuture bind(int inetPort) {
    return bind(new InetSocketAddress(inetPort));
}

進(jìn)而調(diào)用另一個(gè)重載bind方法：

public ChannelFuture bind(SocketAddress localAddress) {
    validate();
    if (localAddress == null) {
        throw new NullPointerException("localAddress");
    }
    return doBind(localAddress);
}

此bind(SocketAddress localAddress)內(nèi)部有兩個(gè)調(diào)用：
1、 調(diào)用validate()
顧名思義，validate應(yīng)該是做校驗(yàn)，由于ServerBootstrap覆蓋了AbstractBootstrap方法，因此此validate其實(shí)是調(diào)用ServerBootstrap中的validate方法：

@Override
public ServerBootstrap validate() {
    super.validate();
    if (childHandler == null) {
        throw new IllegalStateException("childHandler not set");
    }
    if (childGroup == null) {
        logger.warn("childGroup is not set. Using parentGroup instead.");
        childGroup = config.group();
    }
    return this;
}

在子類ServerBootstrap的validate方法中，首先它有調(diào)用了基類的validate()方法：

public B validate() {
    if (group == null) {
        throw new IllegalStateException("group not set");
    }
    if (channelFactory == null) {
        throw new IllegalStateException("channel or channelFactory not set");
    }
    return self();
}

所以通過validate方法我們得出如下結(jié)論：

1） 服務(wù)端程序必須要設(shè)置boss線程組 以及 worker線程組，分別用于Acceptor 以及 I/O操作； 
2）必須通過Boostrap的channel()來指定通道類型，用來生成相應(yīng)的通道（ServerSocketChannel或SocketChannel）；
3） 因?yàn)槭欠?wù)端程序，所以必須設(shè)置ChildHandler，來指定業(yè)務(wù)處理器，否則沒有業(yè)務(wù)處理的服務(wù)器hi沒有意義的；

2、 調(diào)用doBind(localAddress)
首先我們先看一下AbstractBootstrap中doBind方法代碼片段：

private ChannelFuture doBind(final SocketAddress localAddress) {
    final ChannelFuture regFuture = initAndRegister();      // (1)
    final Channel channel = regFuture.channel();            // (2)
    if (regFuture.cause() != null) {
        return regFuture;
    }

    if (regFuture.isDone()) {
        ChannelPromise promise = channel.newPromise();
        doBind0(regFuture, channel, localAddress, promise);     // (3)
        return promise;
    } else {
        final PendingRegistrationPromise promise = new PendingRegistrationPromise(channel);
        regFuture.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                Throwable cause = future.cause();
                if (cause != null) {
                    promise.setFailure(cause);
                } else {
                    promise.registered();

                    doBind0(regFuture, channel, localAddress, promise);  // (3)
                }
            }
        });
        return promise;
    }
}

剝?nèi)o用代碼，其實(shí)doBind方法內(nèi)部，只做了兩件事：
一、調(diào)用了initAndRegister方法
二、調(diào)用用了doBind0方法
到底這兩個(gè)方法做了啥工作，我們繼續(xù)往下分析。

一、首先看看 initAndRegister方法內(nèi)部代碼：

final ChannelFuture initAndRegister() {
    Channel channel = null;
    try {
        // (1) 調(diào)用工廠方法，生成channel實(shí)例
        channel = channelFactory.newChannel();
        
        // (2) 初始化通道信息
        init(channel);
    } catch (Throwable t) {
        if (channel != null) {
            channel.unsafe().closeForcibly();
        }
        
        return new DefaultChannelPromise(channel, GlobalEventExecutor.INSTANCE).setFailure(t);
    }

    // (3) 注冊通道
    ChannelFuture regFuture = config().group().register(channel);
    if (regFuture.cause() != null) {
        if (channel.isRegistered()) {
            channel.close();
        } else {
            channel.unsafe().closeForcibly();
        }
    }

    return regFuture;
}

通過上面代碼，我們可以看出initAndRegister方法做了三件事：

①、調(diào)用channelFactory生成通道channel實(shí)例：

在上一篇中，我們已經(jīng)知道，通過serverbootstrap的channel方法來指定通道類型，其實(shí)是調(diào)用基類AbstractBoostrap的channel方法，其內(nèi)部其實(shí)是實(shí)例化了一個(gè)產(chǎn)生指定channel類型的channelFactory。

所以，initAndRegister中的channelFactory.newChannel()方法就是生成了一個(gè)NioServerSocketChannel的實(shí)例。 關(guān)于NioServerSocketChannel內(nèi)部細(xì)節(jié)，我會有專門的文章進(jìn)行分析，此處不做詳述。

②、調(diào)用init(channel)初始化通道信息

init方法在基類AbstractBootstrap中是一個(gè)抽象方法：

abstract void init(Channel channel) throws Exception;

所以此處init的具體實(shí)現(xiàn)在子類ServerBootstrap類中：

@Override
void init(Channel channel) throws Exception {
    // 設(shè)置引導(dǎo)類配置的option
    final Map, Object> options = options0();
    synchronized (options) {
        setChannelOptions(channel, options, logger);
    }
    // 設(shè)置引導(dǎo)類配置的attr
    final Map, Object> attrs = attrs0();
    synchronized (attrs) {
        for (Entry, Object> e: attrs.entrySet()) {
            @SuppressWarnings("unchecked")
            AttributeKey