當(dāng)前位置:
首頁 >
消息发送到topic多个MessageQueue
發(fā)布時間:2024/4/13
44
豆豆
生活随笔
收集整理的這篇文章主要介紹了
消息发送到topic多个MessageQueue
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
接下來演示一下對topic創(chuàng)建多個messageQueue的演示
1. 創(chuàng)建一個隊列,設(shè)置2個寫隊列以及2個讀隊列,如果讀和寫隊列不一致,會存在消息無法消費到
的問題
2. 構(gòu)建生產(chǎn)者和消費者:參考上面寫的生產(chǎn)者消費者代碼
3. 消費者數(shù)量控制對于隊列的消費情況
?? ?a) 如果消費隊列為2,啟動一個消費者,那么這個消費者會消費者兩個隊列,?
?? ?
?? ?b) 如果兩個消費者消費這個隊列,那么意味著消息會均衡分?jǐn)偟竭@兩個消費者中
?? ?
?? ?c) 如果消費者數(shù)大于readQueueNumbs,那么會有一些消費者消費不到消息,浪費資源
?
總結(jié)
以上是生活随笔為你收集整理的消息发送到topic多个MessageQueue的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RocketMQ消息发送及消费的基本原理
- 下一篇: 消息的顺序消费