消息隊列兩種模式：點對點與發佈訂閱
- 2019 年 12 月 24 日
- 筆記
來源：和大黃 blog.csdn.net/HEYUTAO007/article/details/50131089
- 1、定義
- 1.1、點對點：Queue，不可重複消費
- 1.2、發佈/訂閱：Topic，可以重複消費
- 2、區別
- 2.1、點對點模式
- 2.2、發佈訂閱模式
- 3、流行模型比較
- 3.1、RabbitMQ
- 3.2、Kafka
Java消息服務（Java Message Service，JMS）應用程序接口是一個Java平台中關於面向消息中間件（MOM）的API，用於在兩個應用程序之間，或分佈式系統中發送消息，進行異步通信。點對點與發佈訂閱最初是由JMS定義的。這兩種模式主要區別或解決的問題就是發送到隊列的消息能否重複消費(多訂閱)
1、定義
JMS規範目前支持兩種消息模型：點對點（point to point， queue）和發佈/訂閱（publish/subscribe，topic）。
1.1、點對點：Queue，不可重複消費
消息生產者生產消息發送到queue中，然後消息消費者從queue中取出並且消費消息。消息被消費以後，queue中不再有存儲，所以消息消費者不可能消費到已經被消費的消息。Queue支持存在多個消費者，但是對一個消息而言，只會有一個消費者可以消費。
1.2、發佈/訂閱：Topic，可以重複消費
消息生產者（發佈）將消息發佈到topic中，同時有多個消息消費者（訂閱）消費該消息。和點對點方式不同，發佈到topic的消息會被所有訂閱者消費。
支持訂閱組的發佈訂閱模式：發佈訂閱模式下，當發佈者消息量很大時，顯然單個訂閱者的處理能力是不足的。實際上現實場景中是多個訂閱者節點組成一個訂閱組負載均衡消費topic消息即分組訂閱，這樣訂閱者很容易實現消費能力線性擴展。可以看成是一個topic下有多個Queue，每個Queue是點對點的方式，Queue之間是發佈訂閱方式。
2、區別
2.1、點對點模式
生產者發送一條消息到queue，一個queue可以有很多消費者，但是一個消息只能被一個消費者接受，當沒有消費者可用時，這個消息會被保存直到有 一個可用的消費者，所以Queue實現了一個可靠的負載均衡。
2.2、發佈訂閱模式
發佈者發送到topic的消息，只有訂閱了topic的訂閱者才會收到消息。topic實現了發佈和訂閱，當你發佈一個消息，所有訂閱這個topic的服務都能得到這個消息，所以從1到N個訂閱者都能得到這個消息的拷貝。
3、流行模型比較
傳統企業型消息隊列ActiveMQ遵循了JMS規範，實現了點對點和發佈訂閱模型，但其他流行的消息隊列RabbitMQ、Kafka並沒有遵循JMS規範。
3.1、RabbitMQ
RabbitMQ實現了AQMP協議，AQMP協議定義了消息路由規則和方式。生產端通過路由規則發送消息到不同queue，消費端根據queue名稱消費消息。RabbitMQ既支持內存隊列也支持持久化隊列，消費端為推模型，消費狀態和訂閱關係由服務端負責維護，消息消費完後立即刪除，不保留歷史消息。
（1）點對點 生產端發送一條消息通過路由投遞到Queue，只有一個消費者能消費到。
（2）多訂閱 當RabbitMQ需要支持多訂閱時，發佈者發送的消息通過路由同時寫到多個Queue，不同訂閱組消費不同的Queue。所以支持多訂閱時，消息會多個拷貝。
3.2、Kafka
Kafka只支持消息持久化，消費端為拉模型，消費狀態和訂閱關係由客戶端端負責維護，消息消費完後不會立即刪除，會保留歷史消息。因此支持多訂閱時，消息只會存儲一份就可以了。但是可能產生重複消費的情況。
（1）點對點&多訂閱 發佈者生產一條消息到topic中，不同訂閱組消費此消息。
歡迎加入我的知識星球，一起探討架構，交流源碼。加入方式，長按下方二維碼噢：
已在知識星球更新源碼解析如下：
最近更新《芋道 SpringBoot 2.X 入門》系列，已經 20 余篇，覆蓋了 MyBatis、Redis、MongoDB、Elasticsearch、分庫分表、讀寫分離、SpringMVC、SpringWebflux、WebSocket、Dubbo、RocketMQ、Kafka、性能測試等等內容。
提供近 2W 行代碼的 SpringBoot 示例，以及超 4W 行代碼的電商微服務項目。
