91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Netty每次讀取客戶端數量有多少

發布時間:2021-12-28 15:41:04 來源:億速云 閱讀:172 作者:小新 欄目:大數據

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

當許多客戶端同時連接服務端時, Netty默認每次讀取多少連接呢? 接下來我們 就結合源碼和實戰分析下.  
之前我們講到NioEventLoop在進行三部曲之后(創建-啟動-執行), 就會一直無限循環在執行過程. 而執行過程又分為三個步驟(輪詢IO事件-處理IO事件-執行隊列任務). 那么在輪詢到有IO事件, 準確說當有客戶端連接的事件時, 接下來就是處理IO事件, 也就是在處理IO事件的過程中, 讀取客戶端連接, 那么每次讀取多少個呢?
說明一點, 我們使用的Netty版本如下. 因為不同的版本(尤其是最新的版本)會有差異.
<dependency>      <groupId>io.netty</groupId>      <artifactId>netty-all</artifactId>      <version>4.1.5.Final</version></dependency>

當服務端一直循環在以下代碼時  
io.netty.channel.nio.NioEventLoop#run
它會監聽客戶端請求. 我們假如此時通過telnet 127.0.0.1 8080連接到服務器共19個客戶端.  
服務器監聽到ACCEPT事件后, 便會處理這些事件.   
io.netty.channel.nio.NioEventLoop#processSelectedKeys
進而調用到如下主要代碼  
io.netty.channel.nio.AbstractNioMessageChannel.NioMessageUnsafe#read
此方法內會有一個循環
do {    int localRead = doReadMessages(readBuf);    if (localRead == 0) {        break;    }    if (localRead < 0) {        closed = true;        break;    }    allocHandle.incMessagesRead(localRead);} while (allocHandle.continueReading());
我們通過debug方式調試. 為了模擬實現并發同時有19個客戶端到達, 我們先在輪詢IO事件地方打個斷點, 讓服務端線程'停止'. 當我們通過telnet執行了19個命令后再'放行'服務端線程.  

Netty每次讀取客戶端數量有多少

斷點打好之后, 我們便通過telnet 連接到服務器, 共連接19次.
連接好之后, 我們'放行'服務端線程.
我們在上面說的代碼中打個斷點

Netty每次讀取客戶端數量有多少

此時還沒有讀取客戶端連接, 目前size = 0  
當我們繼續'放行'  

Netty每次讀取客戶端數量有多少

可以看到size = 16  
我們先繼續'放行', 最后分析  
服務器處理完上一波之后, 會再次輪詢IO事件, 結果又輪詢到ACCEPT事件, 繼續處理IO事件. 這一次的size = 3  

Netty每次讀取客戶端數量有多少

第一次size = 16 第二次size = 3 兩個加起來正好等于我們的客戶端連接數19. 于是我們猜測, 服務器每次讀取客戶端連接數是16. 雖然客戶端同一時刻有19個客戶端連接到服務器, 服務器也監聽輪詢到有客戶端連接請求, 于是服務器在第一次循環過程只讀取16個客戶端. 剩下的3個客戶端等到第二次輪詢的時候再讀取. 我們進入
allocHandle.continueReading()
查詢一下.  
io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle#continueReading
public boolean continueReading() {    return config.isAutoRead() &&           attemptedBytesRead == lastBytesRead &&           totalMessages < maxMessagePerRead &&           totalBytesRead < Integer.MAX_VALUE;}
我們可以看到有個  maxMessagePerRead屬性, 它就是控制每次讀取客戶端數量.   我們  通過debug追蹤下這個值  . 我們在如下代碼中打個斷點.
io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator#maxMessagesPerRead(int)

Netty每次讀取客戶端數量有多少

重啟服務器

Netty每次讀取客戶端數量有多少

我們發現它最后被賦值16, 我們通過堆棧可以追蹤到它的來源.  

Netty每次讀取客戶端數量有多少

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

Netty每次讀取客戶端數量有多少

Netty每次讀取客戶端數量有多少

每個Channel都有meta  

Netty每次讀取客戶端數量有多少

源碼中可知, 將這個16賦值給了  RecvByteBufAllocator的  maxMessagesPerRead屬性.
結論: 服務端每次讀取16個客戶端請求

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

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

老河口市| 定襄县| 朝阳市| 望城县| 永顺县| 余干县| 蕲春县| 紫阳县| 乐业县| 磐安县| 迁安市| 文昌市| 平安县| 柘荣县| 理塘县| 澜沧| 陈巴尔虎旗| 吉林省| 肇庆市| 嘉禾县| 深州市| 广德县| 桑植县| 通城县| 芦山县| 南雄市| 南岸区| 许昌县| 睢宁县| 偏关县| 南木林县| 武邑县| 石河子市| 西贡区| 临湘市| 扬中市| 新巴尔虎右旗| 聊城市| 阿拉善左旗| 本溪| 泰宁县|