MessageQueue集合，然后針對(duì)每個(gè)MessageQueue批量取消息，一次取完后，記錄該隊(duì)列下一次要取的開始o(jì)ffset，直到取完了，再換另一個(gè)MessageQueue。

RocketMQ 使用長(zhǎng)輪詢機(jī)制來(lái)模擬 Push 效果，算是兼顧了二者的優(yōu)點(diǎn)。

RocketMQ 相關(guān)術(shù)語(yǔ)

• 消息模型（Message Mode）

  RocketMQ 主要由 Producer、Broker、Consumer 三部分組成，其中 Producer 負(fù)責(zé)生產(chǎn)消息，Consumer 負(fù)責(zé)消費(fèi)消息，Broker 負(fù)責(zé)存儲(chǔ)消息。Broker 在實(shí)際部署過(guò)程中對(duì)應(yīng)一臺(tái)服務(wù)器，每個(gè) Broker 可以存儲(chǔ)多個(gè)Topic的消息，每個(gè) Topic 的消息也可以分片存儲(chǔ)于不同的 Broker。MessageQueue 用于存儲(chǔ)消息的物理地址，每個(gè) Topic 中的消息地址存儲(chǔ)