問題描述:我們已知的一個或多個channel會注冊到一個EventLoop上,這個EventLoop既要監聽Channel上的事件,又要處理事件到來后業務邏輯(包括出站邏輯),也就是說Netty在同一個Channel上的handler調用是串行的,如下圖,如果業務邏輯比較復雜,就會導致一些簡單的事件得不到響應(也有可能是其他channel上的事件)。所以Netty不建議在handler處理復雜的業務邏輯,比如像數據庫操作等等。那像這樣的耗時邏輯在Netty中該怎么處理呢?我的思路我的想法應該有兩種處理方案使用自定義的線程池,將需要處理的耗時邏輯封裝成task丟到executor pool中,但是我們知道,線程多了并不是好事,會影響吞吐。將這些任務丟到丟到那些空閑的EventLoop上,這樣就能充分利用Netty的線程資源,但是這樣的代碼該怎么實現,有沒有成熟的框架?
1 回答

慕姐4208626
TA貢獻1852條經驗 獲得超7個贊
進一步的學習應該是找到了答案吧!
EventLoop
之所以稱之為EventLoop
,就是因為EventLoop
需要循環的監聽IO
事件,任何耗時的邏輯都有可能導致IO
事件不能被靈敏的響應,所以第二種方案是不可取的,雖然說Netty
應用程序的一般準則是,盡可能的重用EventLoop
,以減少線程創建帶來的開銷,但是前提是不能影響網絡IO
靈敏度。
所以處理復雜耗時的業務邏輯就需要一個專門的業務線程池,只要合理的設置業務線程池和事件循環線程池的線程數量,并不會對吞吐造成太大的影響。通常有兩種方式實現業務線程池:
在
ChannelHandler
中,使用自定義的Java
線程池。借助
Netty
提供的業務線程池,ChannelPipeline
有一些接收一個EventExecutorGroup
的add()
方法。如果有一個事件被傳遞給一個自定義的EventExecutorGroup
,它將被包含在這個EventExecutorGroup
中的某個EventExecutor
所處理。Netty
提供了一個叫DefaultEventExecutorGroup
的默認實現。
添加回答
舉報
0/150
提交
取消