馬老師過濾器監(jiān)聽器
生產(chǎn)者流控
1）commitLog 文件被鎖時間超過 osPageCacheBusyTimeOutMills 時，參數(shù)默認為1000ms，發(fā)生流控。
2）如果開啟 transientStorePoolEnable = true，且Broker為異步刷盤的主機，且transientStorePool中資源不足，拒絕當(dāng)前send請求，發(fā)生流控。
注意：生產(chǎn)者流控，不會嘗試消息重投。
Broker每隔10ms檢查send請求隊列頭部請求的等待時間，如果超過 waitTimeMillsInSendQueue，默認200ms，拒絕當(dāng)前send請求，發(fā)生流控。
Broker通過拒絕 send 請求方式實現(xiàn)流量控制。
標(biāo)簽：
