怎么在Java中利用JMS實現一個消息隊列

今天就跟大家聊聊有關怎么在Java中利用JMS實現一個消息隊列，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

一、什么是JMS

JMS即Java消息服務（Java Message Service）應用程序接口，是一個Java平臺中關于面向消息中間件（MOM）的API，用于在兩個應用程序之間，或分布式系統中發送消息，進行異步通信。Java消息服務是一個與具體平臺無關的API，絕大多數MOM提供商都對JMS提供支持（百度百科給出的概述）。我們可以簡單的理解：兩個應用程序之間需要進行通信，我們使用一個JMS服務，進行中間的轉發，通過JMS 的使用，我們可以解除兩個程序之間的耦合。

二、為什么需要JMS

在JAVA中，如果兩個應用程序之間對各自都不了解，甚至這兩個程序可能部署在不同的大洲上，那么它們之間如何發送消息呢？舉個例子，一個應用程序A部署在印度，另一個應用程序部署在美國，然后每當A觸發某件事后，B想從A獲取一些更新信息。當然，也有可能不止一個B對A的更新信息感興趣，可能會有N個類似B的應用程序想從A中獲取更新的信息。

　 在這種情況下，JAVA提供了最佳的解決方案-JMS，完美解決了上面討論的問題。

　 JMS同樣適用于基于事件的應用程序，如聊天服務，它需要一種發布事件機制向所有與服務器連接的客戶端發送消息。JMS與RMI不同，發送消息的時候，接收者不需要在線。服務器發送了消息，然后就不管了；等到客戶端上線的時候，能保證接收到服務器發送的消息。這是一個很強大的解決方案，能處理當今世界很多普遍問題。

三、JMS的優勢

1、異步

JMS天生就是異步的，客戶端獲取消息的時候，不需要主動發送請求，消息會自動發送給可用的客戶端。

2、可靠

JMS保證消息只會遞送一次。大家都遇到過重復創建消息問題，而JMS能幫你避免該問題。

四、JMS的消息模型

JMS具有兩種通信模式：

1、Point-to-Point Messaging Domain （點對點）

2、Publish/Subscribe Messaging Domain （發布/訂閱模式）

在JMS API出現之前，大部分產品使用“點對點”和“發布/訂閱”中的任一方式來進行消息通訊。JMS定義了這兩種消息發送模型的規范，它們相互獨立。任何JMS的提供者可以實現其中的一種或兩種模型，這是它們自己的選擇。JMS規范提供了通用接口保證我們基于JMS API編寫的程序適用于任何一種模型。

1、Point-to-Point Messaging Domain（點對點通信模型）

點對點的模式主要建立在一個隊列上面，當連接一個列隊的時候，發送端不需要知道接收端是否正在接收，可以直接向ActiveMQ發送消息，發送的消息，將會先進入隊列中，如果有接收端在監聽，則會發向接收端，如果沒有接收端接收，則會保存在activemq服務器，直到接收端接收消息，點對點的消息模式可以有多個發送端，多個接收端，但是一條消息，只會被一個接收端給接收到，哪個接收端先連上ActiveMQ，則會先接收到，而后來的接收端則接收不到那條消息。

在點對點消息傳送模型中，應用程序由消息隊列，發送者，接收者組成。每一個消息發送給一個特殊的消息隊列，該隊列保存了所有發送給它的消息(除了被接收者消費掉的和過期的消息)。

（1）模式圖：

（2）特點：

每個消息只有一個消費者；

發送者和接收者在時間上是沒有時間的約束，也就是說發送者在發送完消息之后，不管接收者有沒有接受消息，都不會影響發送方發送消息到消息隊列中；

發送方不管是否在發送消息，接收方都可以從消息隊列中取到消息；

接收方在接收完消息之后，需要向消息隊列應答成功。

2、Publish/Subscribe Messaging Domain（發布/訂閱通信模型）

訂閱/發布模式，同樣可以有著多個發送端與多個接收端，但是接收端與發送端存在時間上的依賴，就是如果發送端發送消息的時候，接收端并沒有監聽消息，那么ActiveMQ將不會保存消息，將會認為消息已經發送，換一種說法，就是發送端發送消息的時候，接收端不在線，是接收不到消息的，哪怕以后監聽消息，同樣也是接收不到的。這個模式還有一個特點，那就是，發送端發送的消息，將會被所有的接收端給接收到，不類似點對點，一條消息只會被一個接收端給接收到。

在發布/訂閱消息模型中，發布者發布一個消息，該消息通過topic傳遞給所有的客戶端。該模式下，發布者與訂閱者都是匿名的，即發布者與訂閱者都不知道對方是誰。并且可以動態的發布與訂閱Topic。Topic主要用于保存和傳遞消息，且會一直保存消息直到消息被傳遞給客戶端。

（1）模式圖：

（2）特點：

一個消息可以傳遞個多個訂閱者（即：一個消息可以有多個接收方）；

發布者與訂閱者具有時間約束，針對某個主題（Topic）的訂閱者，它必須創建一個訂閱者之后，才能消費發布者的消息，而且為了消費消息，訂閱者必須保持運行的狀態；

為了緩和這樣嚴格的時間相關性，JMS允許訂閱者創建一個可持久化的訂閱。這樣，即使訂閱者沒有被激活（運行），它也能接收到發布者的消息。

五、JMS接收消息

在JMS中，消息的接收可以使用以下兩種方式：

（1）同步

使用同步方式接收消息的話，消息訂閱者調用receive()方法。在receive()中，消息未到達或在到達指定時間之前，方法會阻塞，直到消息可用。

（2）異步

使用異步方式接收消息的話，消息訂閱者需注冊一個消息監聽者，類似于事件監聽器，只要消息到達，JMS服務提供者會通過調用監聽器的onMessage()遞送消息。

六、JMS編程模型

（1）管理對象（Administered objects）-連接工廠（Connection Factories）和目的地（Destination）

（2）連接對象（Connections）

（3）會話（Sessions）

（4）消息生產者（Message Producers）

（5）消息消費者（Message Consumers）

（6）消息監聽者（Message Listeners）

（1）JMS管理對象

管理對象（Administered objects）是預先配置的JMS對象，由系統管理員為使用JMS的客戶端創建，主要有兩個被管理的對象：

連接工廠（ConnectionFactory）目的地（Destination）

這兩個管理對象由JMS系統管理員通過使用Application Server管理控制臺創建，存儲在應用程序服務器的JNDI名字空間或JNDI注冊表。

① 連接工廠（ConnectionFactory）

創建Connection對象的工廠，針對兩種不同的jms消息模型，分別有QueueConnectionFactory和TopicConnectionFactory兩種。可以通過JNDI來查找ConnectionFactory對象。客戶端使用一個連接工廠對象連接到JMS服務提供者，它創建了JMS服務提供者和客戶端之間的連接。JMS客戶端（如發送者或接受者）會在JNDI名字空間中搜索并獲取該連接。使用該連接，客戶端能夠與目的地通訊，往隊列或話題發送/接收消息。讓我們用一個例子來理解如何發送消息：

QueueConnectionFactory queueConnFactory = (QueueConnectionFactory) initialCtx.lookup ("primaryQCF");
Queue purchaseQueue = (Queue) initialCtx.lookup ("Purchase_Queue");
Queue returnQueue = (Queue) initialCtx.lookup ("Return_Queue");

② 目的地（Destination）

目的地指明消息被發送的目的地以及客戶端接收消息的來源。JMS使用兩種目的地，隊列和話題。如下代碼指定了一個隊列和話題。

創建一個隊列Session

QueueSession ses = con.createQueueSession (false, Session.AUTO_ACKNOWLEDGE); //get the Queue object
Queue t = (Queue) ctx.lookup ("myQueue"); //create QueueReceiver
QueueReceiver receiver = ses.createReceiver(t);

創建一個話題

TopicSession ses = con.createTopicSession (false, Session.AUTO_ACKNOWLEDGE); // get the Topic object
Topic t = (Topic) ctx.lookup ("myTopic"); //create TopicSubscriber
TopicSubscriber receiver = ses.createSubscriber(t);

（2）JMS連接對象（Connection）

Connection表示在客戶端和JMS系統之間建立的連接（對TCP/IP socket的包裝）。Connection可以產生一個或多個Session。跟ConnectionFactory一樣，Connection也有兩種類型：QueueConnection和TopicConnection。

連接對象封裝了與JMS提供者之間的虛擬連接，如果我們有一個ConnectionFactory對象，可以使用它來創建一個連接。

Connection connection = connectionFactory.createConnection();

創建完連接后，需要在程序使用結束后關閉它：connection.close();

（3）JMS會話（Session）

Session 是我們對消息進行操作的接口，可以通過session創建生產者、消費者、消息等。Session 提供了事務的功能，如果需要使用session發送/接收多個消息時，可以將這些發送/接收動作放到一個事務中。

我們可以在連接創建完成之后創建session：

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

這里面提供了參數兩個參數，第一個參數是是否支持事務，第二個是事務的類型。

（4）JMS消息生產者（Producer）

消息生產者由Session創建，用于往目的地發送消息。生產者實現MessageProducer接口，我們可以為目的地、隊列或話題創建生產者。

MessageProducer producer = session.createProducer(dest);
MessageProducer producer = session.createProducer(queue);
MessageProducer producer = session.createProducer(topic);

創建完消息生產者后，可以使用send方法發送消息：

復制代碼 代碼如下:

producer.send(message);

（5）JMS消息消費者（Consumer）

消息消費者由Session創建，用于接收被發送到Destination的消息。消費者實現MessageConsumer接口，我們可以為目的地、隊列或話題創建消費者。

MessageConsumer consumer = session.createConsumer(dest);MessageConsumer consumer = session.createConsumer(queue);MessageConsumer consumer = session.createConsumer(topic);

（6）JMS消息監聽器

JMS消息監聽器是消息的默認事件處理者，他實現了MessageListener接口，該接口包含一個onMessage方法，在該方法中需要定義消息達到后的具體動作。通過調用setMessageListener方法，我們給指定的消費者定義了消息監聽器。

Listener myListener = new Listener();consumer.setMessageListener(myListener);

看完上述內容，你們對怎么在Java中利用JMS實現一個消息隊列有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。