Java消息服務(Java Message Service，JMS)應用程序接口是一個Java平臺中關于面向消息中間件(MOM)的API，用于在兩個應用程序之間，或分布式系統中發送消息，進行異步通信。

點對點與發布訂閱最初是由JMS定義的。這兩種模式主要區別或解決的問題就是發送到隊列的消息能否重復消費(多訂閱)

一、定義

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中，不同訂閱組消費此消息。

總結

以上是生活随笔為你收集整理的java 消息队列_java消息队列的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。