1.點對點
消息生產者消息發送到queue中,然后消費者從queue中取。 注意:消息被消費以后,隊列中不再有存儲, 所以消費者不能 消費已經被消費的消息了 。 也就是不能重復消費。
2.發布/訂閱
生產者將消息發送到topic中,同事多個消費者消費這個消息。 和點對點不同,發布到topic的消息會被所有訂閱在消費。
2.二者分析與區別
2.1 點對點模式
生產者發送一條消息到 queue,只有一個消費者能收到。
2.2 發布訂閱模式
發布者發送到 topic 的消息,只有訂閱了 topic 的訂閱者才會收到消息。
小結
queue 實現了負載均衡,一個消息只能被一個消費者接受,當沒有消費者可用時,這個消息會被保存直到有 一個可用的消費者,一個 queue 可以有很多消費者,他們之間實現了負載均衡,
所以 Queue 實現了一個可靠的負載均衡。
topic 實現了發布和訂閱,當你發布一個消息,所有訂閱這個 topic 的服務都能得到這個消息,所以從 1 到 N 個訂閱者都能得到一個消息的拷貝,
只有在消息代理收到消息時有一個有效訂閱時的訂閱者才能得到這個消息的拷貝。
疑問
發布訂閱模式下,能否實現訂閱者負載均衡消費呢?當發布者消息量很大時,顯然單個訂閱者的處理能力是不足的。實際上現實場景中是多個訂閱者節點組成一個訂閱組負載均衡消費 topic 消息即分組訂閱,
這樣訂閱者很容易實現消費能力線性擴展。
3 流行消息隊列模型比較
傳統企業型消息隊列 ActiveMQ 遵循了 JMS 規范,實現了點對點和發布訂閱模型,但其他流行的消息隊列 RabbitMQ、Kafka 並沒有遵循老態龍鍾的 JMS 規范,是通過什么方式實現消費負載均衡、多訂閱呢?
3.1 RabbitMQ
RabbitMQ 實現了 AQMP 協議,AQMP 協議定義了消息路由規則和方式。生產端通過路由規則發送消息到不同 queue,消費端根據 queue 名稱消費消息。此外 RabbitMQ 是向消費端推送消息,訂閱關系和消費狀態保存在服務端。
生產端發送一條消息通過路由投遞到 Queue,只有一個消費者能消費到。
當 RabbitMQ 需要支持多訂閱時,發布者發送的消息通過路由同時寫到多個 Queue,不同訂閱組消費此消息。
RabbitMQ 既支持內存隊列也支持持久化隊列,消費端為推模型,消費狀態和訂閱關系由服務端負責維護,消息消費完后立即刪除,不保留歷史消息。所以支持多訂閱時,消息會多個拷貝。
3.2 Kafka
Kafka 只支持消息持久化,消費端為拉模型,消費狀態和訂閱關系由客戶端端負責維護,消息消費完后不會立即刪除,會保留歷史消息。因此支持多訂閱時,消息只會存儲一份就可以了。