Netty源码 服务端的启动
最近一直在看netty,看完之后就想做點筆記??墒菍嵲谑翘α?#xff0c;擠了還要幾個晚上終于擠出來了
?
上圖是服務端的實例代碼。大致的流程先梳理一遍。
首先會執行?用于創建兩個線程組,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.初始化?
?
初始化只做了兩件事
p.addLast()向serverChannel的流水線處理器中加入了一個?ServerBootstrapAcceptor,從名字上就可以看出來,這是一個接入器,專門接受新請求,把新的請求扔給某個事件循環器
3.注冊
將該條channel綁定到一個selector上去,一個selector被一個reactor線程使用,后續該channel的事件輪詢,以及事件處理,異步task執行都是由此reactor線程來負責
?
現在我們的channel已經和reactor線程綁定在一起了,現在就剩下最后一步了,完成端口的綁定。
netty通過異步線程的方式完成端口綁定,這段代碼比較難找,最終會來到?io.netty.channel.DefaultChannelPipeline.HeadContext#bind
?
?最終調到了jdk里面的bind方法,這行代碼過后,正常情況下,就真正進行了端口的綁定。
?
轉載于:https://www.cnblogs.com/xmzJava/p/9425440.html
總結
以上是生活随笔為你收集整理的Netty源码 服务端的启动的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: [CF587F]Duff is Mad[
- 下一篇: git在实际开发中的应用