最近一直在看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.初始化
初始化只作了兩件事
p.addLast()
向serverChannel的流水線處理器中加入了一個 ServerBootstrapAcceptor
,從名字上就能夠看出來,這是一個接入器,專門接受新請求,把新的請求扔給某個事件循環器
3.註冊
將該條channel
綁定到一個selector
上去,一個selector被一個reactor線程使用,後續該channel
的事件輪詢,以及事件處理,異步task執行都是由此reactor線程來負責
如今咱們的channel
已經和reactor
線程綁定在一塊兒了,如今就剩下最後一步了,完成端口的綁定。
netty經過異步線程的方式完成端口綁定,這段代碼比較難找,最終會來到 io.netty.channel.DefaultChannelPipeline.HeadContext#bind
最終調到了jdk裏面的bind方法,這行代碼事後,正常狀況下,就真正進行了端口的綁定。