摘要：客戶端客戶端啟動(dòng)的常規(guī)代碼如下用于接收客戶端請求的線程池職責(zé)如下。注冊對(duì)應(yīng)的網(wǎng)絡(luò)監(jiān)聽狀態(tài)為到多路復(fù)用器。由多路復(fù)用器在現(xiàn)場中輪詢個(gè)，處理連接結(jié)果。具體服務(wù)端與客戶端如何通信，以及內(nèi)存管理等方面的知識(shí)下一次再寫。

歡迎關(guān)注公眾號(hào)：【愛編程】
如果有需要后臺(tái)回復(fù)2019贈(zèng)送1T的學(xué)習(xí)資料哦??！

本文是基于Netty4.1.36進(jìn)行分析

Netty服務(wù)端的啟動(dòng)代碼基本都是如下：

private void start() throws Exception {

        final EchoServerHandler serverHandler = new EchoServerHandler();
        /**
         * NioEventLoop并不是一個(gè)純粹的I/O線程，它除了負(fù)責(zé)I/O的讀寫之外
         * 創(chuàng)建了兩個(gè)NioEventLoopGroup，
         * 它們實(shí)際是兩個(gè)獨(dú)立的Reactor線程池。
         * 一個(gè)用于接收客戶端的TCP連接，
         * 另一個(gè)用于處理I/O相關(guān)的讀寫操作，或者執(zhí)行系統(tǒng)Task、定時(shí)任務(wù)Task等。
         */
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup childGroup = new NioEventLoopGroup();

        try {
            //ServerBootstrap負(fù)責(zé)初始化netty服務(wù)器，并且開始監(jiān)聽端口的socket請求
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, childGroup)
                    .channel(NioServerSocketChannel.class)
                    .localAddress(new InetSocketAddress(port))
                    .childHandler(new ChannelInitializer() {
                        @Override
                        protected void initChannel(SocketChannel socketChannel) throws Exception {
//                            為監(jiān)聽客戶端read/write事件的Channel添加用戶自定義的ChannelHandler
                            socketChannel.pipeline().addLast(serverHandler);
                        }
                    });

            ChannelFuture f = b.bind().sync();

            f.channel().closeFuture().sync();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            bossGroup.shutdownGracefully().sync();
            childGroup.shutdownGracefully().sync();
        }
    }

從上圖的代碼可以總結(jié)為以下幾個(gè)步驟：

1、創(chuàng)建ServerBootStrap實(shí)例
2、設(shè)置并綁定Reactor線程池：EventLoopGroup，EventLoop就是處理所有注冊到本線程的Selector上面的Channel
3、設(shè)置并綁定服務(wù)端的channel
4、5、創(chuàng)建處理網(wǎng)絡(luò)事件的ChannelPipeline和handler，網(wǎng)絡(luò)時(shí)間以流的形式在其中流轉(zhuǎn)，handler完成多數(shù)的功能定制：比如編解碼 SSl安全認(rèn)證
6、綁定并啟動(dòng)監(jiān)聽端口
7、當(dāng)輪訓(xùn)到準(zhǔn)備就緒的channel后，由Reactor線程：NioEventLoop執(zhí)行pipline中的方法，最終調(diào)度并執(zhí)行channelHandler

它就是主要引導(dǎo)啟動(dòng)服務(wù)端，工作包括以下：

1.創(chuàng)建服務(wù)端Channel

2.初始化服務(wù)端Channel

3.將Channel注冊到selector

4.端口綁定

流程：
首先從用戶代碼的bind()其實(shí)就是AbstractBootstrap.bind(),然后通過反射工廠將用戶通過b.channel(NioServerSocketChannel.class)傳入的NioServerSocketChannel通過調(diào)用底層的jdk的SelectorProvider創(chuàng)建channel，同時(shí)也接著創(chuàng)建好對(duì)應(yīng)的ChannelPipeline。
詳情可以參考下圖，自己去查看一下源碼：

主要工作如下：

1）設(shè)置的option緩存到NioServerSocketChannelConfig里
2）設(shè)置的attr設(shè)置到channel里
3）保存配置的childOptions，配置的childAttrs 到ServerBootstrapAcceptor里
4）往NioSocketChannel的pipeline中添加一個(gè)ServerBootstrapAcceptor

主要的核心源碼如下：

 @Override
    void init(Channel channel) throws Exception {
        final Map, Object> options = options0();
        synchronized (options) {
            setChannelOptions(channel, options, logger);
        }

        final Map, Object> attrs = attrs0();
        synchronized (attrs) {
            for (Entry, Object> e: attrs.entrySet()) {
                @SuppressWarnings("unchecked")
                AttributeKey