-
爲何選擇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。
- 消費者端的負載均衡。根據消費者的消費模式不一樣,負載均衡方式也不一樣。
-
消費者消費模式有幾種.net
- 集羣消費:一個 Consumer Group 中的各個 Consumer 實例分攤去消費消息,即一條消息只會投遞到一個 Consumer Group 下面的一個實例。
- 廣播消費:消息將對一個Consumer Group 下的各個 Consumer實例都投遞一遍。即便這些 Consumer 屬於同一個Consumer Group ,消息也會被 Consumer Group 中的每一個 Consumer 都消費一次。
參考(部分摘抄的文字版權屬於原做者):
https://blog.csdn.net/pzq915981048/article/details/88971356
http://www.javashuo.com/article/p-zwwedgbu-n.htmlblog