rocketmq怎麼作流量控制

rocketmq內部的每個messagequeue都有一個processqueue做爲快照，processqueue內部維護了一個treemap，保存着從messagequeue獲取了可是還未被消費的消息。key=messagequeue的offset，value=消息內容引用. pushConsumer會經過processqueue來判斷獲取但未被消費但消息個數，消息總大小，offset但跨度，

>>阅读原文<<