Netty源碼 服務端的啓動

最近一直在看netty,看完以後就想作點筆記。但是實在是太忙了,擠了還要幾個晚上終於擠出來了java

 

上圖是服務端的實例代碼。大體的流程先梳理一遍。react

首先會執行 用於建立兩個線程組,boosGroup用於接受外部鏈接,對 SelectionKey.OP_ACCEPT 感興趣數組

,workGroup用於處理io操做,內部,每當有新鏈接進來的時候boosGroup 都會把鏈接封裝成一個channel 交給workGroup 去處理。異步

 

咱們再看 NioEventLoopGroup 的構造方法,一直點進去,實際上調用的 MultithreadEventExecutorGroup oop

 

 能夠看到 這兩行代碼實際就是建立兩個包含 NioEventLoop 對象的數組。NioEventLoop對象咱們後面介紹。spa

ServerBootstrap 是一個輔助類,主要用於設置各類配置參數,.net

.group(bossGroup, workerGroup) 線程

就是上面咱們建立的兩個線程組,bossGroup的做用就是不斷地accept到新的鏈接,將新的鏈接丟給workerGroup來處理3d

.channel(NioServerSocketChannel.class) netty

表示服務端啓動的是nio相關的channel,channel在netty裏面是一大核心概念,能夠理解爲一條channel就是一個鏈接或者一個服務端bind動作

.childHandler(new ChannelInitializer<SocketChannel>)表示一條新的鏈接進來以後,該怎麼處理

上面的幾行代碼都是作相應配置。

真正的關鍵在於bind方法

咱們一路點擊進去。這個幹了三件事 初始化,註冊,綁定端口。

咱們先看 initAndRegister

總共三步,建立channel,初始化,註冊。

1.建立 反射調用,這裏的clazz是在中設置的,因此這裏建立出的是NioServerSocketChannel

2.初始化 

 

初始化只作了兩件事

  1. 將配置屬性設置到channelConfig或者channel 中
  2. 加入新鏈接處理器

p.addLast()向serverChannel的流水線處理器中加入了一個 ServerBootstrapAcceptor,從名字上就能夠看出來,這是一個接入器,專門接受新請求,把新的請求扔給某個事件循環器

3.註冊

將該條channel綁定到一個selector上去,一個selector被一個reactor線程使用,後續該channel的事件輪詢,以及事件處理,異步task執行都是由此reactor線程來負責

 

如今咱們的channel已經和reactor線程綁定在一塊兒了,如今就剩下最後一步了,完成端口的綁定。

netty經過異步線程的方式完成端口綁定,這段代碼比較難找,最終會來到 io.netty.channel.DefaultChannelPipeline.HeadContext#bind

 

 最終調到了jdk裏面的bind方法,這行代碼事後,正常狀況下,就真正進行了端口的綁定。

相關文章
相關標籤/搜索