問題描述：我們已知的一個或多個channel會注冊到一個EventLoop上，這個EventLoop既要監(jiān)聽Channel上的事件，又要處理事件到來后業(yè)務(wù)邏輯（包括出站邏輯），也就是說Netty在同一個Channel上的handler調(diào)用是串行的，如下圖，如果業(yè)務(wù)邏輯比較復(fù)雜，就會導(dǎo)致一些簡單的事件得不到響應(yīng)（也有可能是其他channel上的事件）。所以Netty不建議在handler處理復(fù)雜的業(yè)務(wù)邏輯，比如像數(shù)據(jù)庫操作等等。那像這樣的耗時邏輯在Netty中該怎么處理呢？我的思路我的想法應(yīng)該有兩種處理方案使用自定義的線程池，將需要處理的耗時邏輯封裝成task丟到executor pool中,但是我們知道，線程多了并不是好事，會影響吞吐。將這些任務(wù)丟到丟到那些空閑的EventLoop上，這樣就能充分利用Netty的線程資源，但是這樣的代碼該怎么實現(xiàn)，有沒有成熟的框架？
1 回答
慕姐4208626
TA貢獻1852條經(jīng)驗 獲得超7個贊
進一步的學(xué)習(xí)應(yīng)該是找到了答案吧！
EventLoop之所以稱之為EventLoop，就是因為EventLoop需要循環(huán)的監(jiān)聽IO事件，任何耗時的邏輯都有可能導(dǎo)致IO事件不能被靈敏的響應(yīng)，所以第二種方案是不可取的，雖然說Netty應(yīng)用程序的一般準則是，盡可能的重用EventLoop，以減少線程創(chuàng)建帶來的開銷,但是前提是不能影響網(wǎng)絡(luò)IO靈敏度。
所以處理復(fù)雜耗時的業(yè)務(wù)邏輯就需要一個專門的業(yè)務(wù)線程池，只要合理的設(shè)置業(yè)務(wù)線程池和事件循環(huán)線程池的線程數(shù)量，并不會對吞吐造成太大的影響。通常有兩種方式實現(xiàn)業(yè)務(wù)線程池：
在
ChannelHandler中，使用自定義的Java線程池。借助
Netty提供的業(yè)務(wù)線程池，ChannelPipeline有一些接收一個EventExecutorGroup的add()方法。如果有一個事件被傳遞給一個自定義的EventExecutorGroup，它將被包含在這個EventExecutorGroup中的某個EventExecutor所處理。Netty提供了一個叫DefaultEventExecutorGroup的默認實現(xiàn)。
添加回答
舉報
0/150
提交
取消