Netty源碼 服務端的啟動
最近一直在看netty,看完之後就想做點筆記。可是實在是太忙了,擠了還要幾個晚上終於擠出來了
上圖是服務端的實例代碼。大致的流程先梳理一遍。
首先會執行 用於創建兩個線程組,boosGroup用於接受外部連接,對 SelectionKey.OP_ACCEPT 感興趣
,workGroup用於處理io操作,內部,每當有新連接進來的時候boosGroup 都會把連接封裝成一個channel 交給workGroup 去處理。
我們再看 NioEventLoopGroup 的構造方法,一直點進去,實際上調用的 MultithreadEventExecutorGroup
可以看到 這兩行代碼實際就是創建兩個包含 NioEventLoop
ServerBootstrap 是一個輔助類,主要用於設置各種配置參數,
.group(bossGroup, workerGroup)
就是上面我們創建的兩個線程組,bossGroup
的作用就是不斷地accept到新的連接,將新的連接丟給workerGroup
來處理
.channel(NioServerSocketChannel.class)
表示服務端啟動的是nio相關的channel,channel在netty裏面是一大核心概念,可以理解為一條channel就是一個連接或者一個服務端bind動做
.childHandler(new ChannelInitializer<SocketChannel>)
上面的幾行代碼都是做相應配置。
真正的關鍵在於bind方法
我們一路點擊進去。這個幹了三件事 初始化,註冊,綁定端口。
我們先看 initAndRegister
總共三步,創建channel,初始化,註冊。
1.創建 反射調用,這裏的clazz是在中設置的,所以這裏創建出的是NioServerSocketChannel
2.初始化
初始化只做了兩件事
- 將配置屬性設置到channelConfig或者channel 中
- 加入新連接處理器
p.addLast()
向serverChannel的流水線處理器中加入了一個 ServerBootstrapAcceptor
3.註冊
將該條channel
綁定到一個selector
上去,一個selector被一個reactor線程使用,後續該channel
的事件輪詢,以及事件處理,異步task執行都是由此reactor線程來負責
現在我們的channel
已經和reactor
線程綁定在一起了,現在就剩下最後一步了,完成端口的綁定。
netty通過異步線程的方式完成端口綁定,這段代碼比較難找,最終會來到 io.netty.channel.DefaultChannelPipeline.HeadContext#bind
最終調到了jdk裏面的bind方法,這行代碼過後,正常情況下,就真正進行了端口的綁定。
Netty源碼 服務端的啟動