消息发送到topic多个MessageQueue
生活随笔
收集整理的這篇文章主要介紹了
消息发送到topic多个MessageQueue
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
接下來演示一下對topic創建多個messageQueue的演示
1. 創建一個隊列,設置2個寫隊列以及2個讀隊列,如果讀和寫隊列不一致,會存在消息無法消費到
的問題
2. 構建生產者和消費者:參考上面寫的生產者消費者代碼
3. 消費者數量控制對于隊列的消費情況
?? ?a) 如果消費隊列為2,啟動一個消費者,那么這個消費者會消費者兩個隊列,?
?? ?
?? ?b) 如果兩個消費者消費這個隊列,那么意味著消息會均衡分攤到這兩個消費者中
?? ?
?? ?c) 如果消費者數大于readQueueNumbs,那么會有一些消費者消費不到消息,浪費資源
?
總結
以上是生活随笔為你收集整理的消息发送到topic多个MessageQueue的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RocketMQ消息发送及消费的基本原理
- 下一篇: 消息的顺序消费