1. 程式人生 > >Netty源碼 服務端的啟動

Netty源碼 服務端的啟動

兩個 read clas channel 核心 tex 構造 bootstra 流程

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

技術分享圖片

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

首先會執行技術分享圖片 用於創建兩個線程組,boosGroup用於接受外部連接,對 SelectionKey.OP_ACCEPT 感興趣

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

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

技術分享圖片

可以看到 這兩行代碼實際就是創建兩個包含 NioEventLoop

對象的數組。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.初始化

技術分享圖片

初始化只做了兩件事

  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方法,這行代碼過後,正常情況下,就真正進行了端口的綁定。

Netty源碼 服務端的啟動