問題描述:我們已知的一個或多個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
提交
取消
