Netty每次讀取客戶端數(shù)量有多少

發(fā)布時間：2021-12-28 15:41:04 來源：億速云閱讀：164 作者：小新欄目：大數(shù)據(jù)

這篇文章將為大家詳細(xì)講解有關(guān)Netty每次讀取客戶端數(shù)量有多少，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

當(dāng)許多客戶端同時連接服務(wù)端時, Netty默認(rèn)每次讀取多少連接呢? 接下來我們就結(jié)合源碼和實戰(zhàn)分析下.

之前我們講到NioEventLoop在進(jìn)行三部曲之后(創(chuàng)建-啟動-執(zhí)行), 就會一直無限循環(huán)在執(zhí)行過程. 而執(zhí)行過程又分為三個步驟(輪詢IO事件-處理IO事件-執(zhí)行隊列任務(wù)). 那么在輪詢到有IO事件, 準(zhǔn)確說當(dāng)有客戶端連接的事件時, 接下來就是處理IO事件, 也就是在處理IO事件的過程中, 讀取客戶端連接, 那么每次讀取多少個呢?

說明一點, 我們使用的Netty版本如下. 因為不同的版本(尤其是最新的版本)會有差異.

<dependency>      <groupId>io.netty</groupId>      <artifactId>netty-all</artifactId>      <version>4.1.5.Final</version></dependency>

當(dāng)服務(wù)端一直循環(huán)在以下代碼時

io.netty.channel.nio.NioEventLoop#run

它會監(jiān)聽客戶端請求. 我們假如此時通過telnet 127.0.0.1 8080連接到服務(wù)器共19個客戶端.

服務(wù)器監(jiān)聽到ACCEPT事件后, 便會處理這些事件.

io.netty.channel.nio.NioEventLoop#processSelectedKeys

進(jìn)而調(diào)用到如下主要代碼

io.netty.channel.nio.AbstractNioMessageChannel.NioMessageUnsafe#read

此方法內(nèi)會有一個循環(huán)

do {    int localRead = doReadMessages(readBuf);    if (localRead == 0) {        break;    }    if (localRead < 0) {        closed = true;        break;    }    allocHandle.incMessagesRead(localRead);} while (allocHandle.continueReading());

我們通過debug方式調(diào)試. 為了模擬實現(xiàn)并發(fā)同時有19個客戶端到達(dá), 我們先在輪詢IO事件地方打個斷點, 讓服務(wù)端線程'停止'. 當(dāng)我們通過telnet執(zhí)行了19個命令后再'放行'服務(wù)端線程.

Netty每次讀取客戶端數(shù)量有多少

斷點打好之后, 我們便通過telnet 連接到服務(wù)器, 共連接19次.

連接好之后, 我們'放行'服務(wù)端線程.

我們在上面說的代碼中打個斷點

Netty每次讀取客戶端數(shù)量有多少

此時還沒有讀取客戶端連接, 目前size = 0

當(dāng)我們繼續(xù)'放行'

Netty每次讀取客戶端數(shù)量有多少

可以看到size = 16

我們先繼續(xù)'放行', 最后分析

服務(wù)器處理完上一波之后, 會再次輪詢IO事件, 結(jié)果又輪詢到ACCEPT事件, 繼續(xù)處理IO事件. 這一次的size = 3

Netty每次讀取客戶端數(shù)量有多少

第一次size = 16 第二次size = 3 兩個加起來正好等于我們的客戶端連接數(shù)19. 于是我們猜測, 服務(wù)器每次讀取客戶端連接數(shù)是16. 雖然客戶端同一時刻有19個客戶端連接到服務(wù)器, 服務(wù)器也監(jiān)聽輪詢到有客戶端連接請求, 于是服務(wù)器在第一次循環(huán)過程只讀取16個客戶端. 剩下的3個客戶端等到第二次輪詢的時候再讀取. 我們進(jìn)入

allocHandle.continueReading()

查詢一下.

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle#continueReading

public boolean continueReading() {    return config.isAutoRead() &&           attemptedBytesRead == lastBytesRead &&           totalMessages < maxMessagePerRead &&           totalBytesRead < Integer.MAX_VALUE;}

我們可以看到有個 maxMessagePerRead屬性, 它就是控制每次讀取客戶端數(shù)量. 我們通過debug追蹤下這個值 . 我們在如下代碼中打個斷點.

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator#maxMessagesPerRead(int)

Netty每次讀取客戶端數(shù)量有多少

重啟服務(wù)器

Netty每次讀取客戶端數(shù)量有多少

我們發(fā)現(xiàn)它最后被賦值16, 我們通過堆?？梢宰粉櫟剿膩碓?

Netty每次讀取客戶端數(shù)量有多少

最后我們發(fā)現(xiàn), 在創(chuàng)建NioServerSocketChannel的時候, 同時創(chuàng)建config(每個Channel對應(yīng)一個Config). 每個Config對應(yīng)一個RecvByteBufAllocator. 而maxMessagesPerRead屬性屬于 RecvByteBufAllocator類. 而那個具體的16是在哪里呢?

Netty每次讀取客戶端數(shù)量有多少

每個Channel都有meta

Netty每次讀取客戶端數(shù)量有多少

源碼中可知, 將這個16賦值給了 RecvByteBufAllocator的 maxMessagesPerRead屬性.

結(jié)論: 服務(wù)端每次讀取16個客戶端請求

關(guān)于“Netty每次讀取客戶端數(shù)量有多少”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學(xué)到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。

向AI問一下細(xì)節(jié)

Netty每次讀取客戶端數(shù)量有多少

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽