RocketMQ消息支持的模式-OrderProducer(顺序)
生活随笔
收集整理的這篇文章主要介紹了
RocketMQ消息支持的模式-OrderProducer(顺序)
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
前面我們學習kafka的時候有說到,消息可以通過自定義分區策略來失效消息的順序發送,實現原理就是把同一類消息都發送到相同的分區上。
在RocketMQ中,是基于多個Message Queue來實現類似于kafka的分區效果。如果一個Topic 要發送和接收的數據量非常大, 需要能支持增加并行處理的機器來提高處理速度,這時候一個Topic 可以根據需求設置一個或多個Message Queue。Topic 有了多個Message Queue 后,消息可以并行地向各個
Message Queue 發送,消費者也可以并行地從多個Message Queue 讀取消息并消費。
要了解RocketMQ消息的順序消費,還得對RocketMQ的整體架構有一定的了解
?
?
總結
以上是生活随笔為你收集整理的RocketMQ消息支持的模式-OrderProducer(顺序)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RocketMQ消息支持的模式-消息异步
- 下一篇: RocketMQ消息发送及消费的基本原理