-
為什么選擇RocketMQ,而不是其他MQ
- 性能:阿里支撐,經受住淘寶,天貓雙11重重考驗;性能高;可靠性好;可用性高;易擴展,
- 功能:功能完善,我們需要的功能基本都夠滿足,如:事務訊息,訊息重試,死信佇列,定時訊息等,
- 易用:跨平臺:跨語言,多協議接入(支持HTTP, MQTT, TCP協議,支持Restful風格HTTP收發訊息),
-
RocketMQ 由哪些角色組成
- 生產者(Producer):負責產生訊息,生產者向訊息服務器發送由業務應用程式系統生成的訊息,
- 消費者(Consumer):負責消費訊息,消費者從訊息服務器拉取資訊并將其輸入用戶應用程式,
- 訊息服務器(Broker):是訊息存盤中心,主要作用是接收來自 Producer的訊息并存盤, Consumer 從這里取得訊息,
- 名稱服務器(NameServer):用來保存 Broker 相關 Topic 等元資訊并給 Producer ,提供 Consumer 查找Broker資訊,
-
說說你對消費者的了解
- 獲得 Topic-Broker 的映射關系,consumer 啟動時需要指定 Namesrv 地址,與其中一個 Namesrv 建立長連接,消費者每隔 30 秒從 Namesrv 獲取所有Topic 的最新佇列情況,
Consumer 跟 Broker 是長連接,會每隔 30 秒發心跳資訊到Broker, - 消費者端的負載均衡,根據消費者的消費模式不同,負載均衡方式也不同,
- 獲得 Topic-Broker 的映射關系,consumer 啟動時需要指定 Namesrv 地址,與其中一個 Namesrv 建立長連接,消費者每隔 30 秒從 Namesrv 獲取所有Topic 的最新佇列情況,
-
消費者消費模式有幾種
- 集群消費:一個 Consumer Group 中的各個 Consumer 實體分攤去消費訊息,即一條訊息只會投遞到一個 Consumer Group 下面的一個實體,
- 廣播消費:訊息將對一個Consumer Group 下的各個 Consumer實體都投遞一遍,即使這些 Consumer 屬于同一個Consumer Group ,訊息也會被 Consumer Group 中的每個 Consumer 都消費一次,
參考(部分摘抄的文字著作權屬于原作者):
https://blog.csdn.net/pzq915981048/article/details/88971356
https://blog.csdn.net/huayushuangfei/article/details/80866642
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/14368.html
標籤:其他
