RocketMQ 消費端限流機制

RocketMQ 消息消費端會從 3 個維度進行限流： 消息消費端隊列中積壓的消息超過 1000 條 消息處理隊列中儘管積壓沒有超過 1000 條，但最大偏移量與最小偏移量的差值超過 2000 消息處理隊列中積壓的消息總大小超過 100M 爲了方便理解上述三條規則的設計理念，我們首先來看一下消費端的數據結構，如下圖所示： PullMessageService 線程會按照隊列向 Broker 拉取一

>>阅读原文<<