JMS和訊息驅動Bean

1.java訊息服務(JMS)程式設計：

應用程式A傳送一條訊息到訊息伺服器的某個目的地，然後訊息伺服器把訊息轉發給應用程式B，由於JMS允許訊息傳送方和接收方不同時線上，沒有程式碼關聯，從而實現應用程式的解耦，JMS的過程如下：

應用程式A——>訊息——>JMS訊息伺服器——>訊息——>應用程式B

2.JMS訊息的傳遞模型：

JMS支援兩種訊息傳遞模型：點對點(PTP)、釋出訂閱(pub/sub)。

(1).PTP：

一條訊息只能傳遞給一個接收方，採用javax.jms.Queue表示。

每個訊息被髮送到一個特定的訊息佇列中，接收者從訊息佇列中獲取訊息，佇列保留著訊息直到訊息被消費或者超時，當傳送時如果接收方不線上，則當接收方上線時還可以接收到訊息。

傳送者和接收者之間在時間上沒有依賴性，即當傳送者傳送了訊息之後，不管接收者是否在執行，都不會影響訊息被髮送到訊息佇列，接收者在成功接收訊息之後需要向佇列應答成功，若希望傳送的每條訊息都應該被成功接收處理的話，應該使用PTP方式。

(2).pub/sub：

一條訊息可以傳遞給多個接收方，採用javax.jms.Topic表示。

每條訊息可以有多個接收者，釋出者和訂閱者有時間上的依賴性，針對某個主題的訂閱者必須建立一個訂閱之後才能消費釋出者釋出的訊息，而且為了接收訊息，訂閱者必須保持執行。釋出訂閱模式的訊息不支援離線訊息，即當發生訊息時，接收方如果不線上，當接收再次上線時就無法接收到已經發送過的訊息。

為了緩和這種嚴格的時間相關性，jms執行訂閱者建立一個可持久化的訂閱，這樣，即使訂閱者沒有被啟用(執行)，也能接收到釋出者釋出的訊息。

若希望傳送的訊息可以不被做任何處理，或者被一個消費者處理，或者可以被多個消費者處理，應該使用pub/sub模型。

兩種訊息模型都繼承自：javax.jms.Destination類。

3.JMS訊息組成：

JMS中一條訊息的組成：訊息頭(header)、屬性(property)、訊息體(body)。

所有的訊息都派生自Message介面，有以下幾種型別：

(1).StreamMessage：一種主體中包含java二進位制流的訊息，其填充和讀取均按順序進行。

(2).MapMessage

(3).TextMessage：一種主體中java字串的訊息(如，普通文字，xml檔案等)。

(4).ObjectMessage：一種主體中包含序列化java物件的訊息。

(5).ByteMessage：一種主體中包含連續位元組流的訊息。

4.配置訊息到達目標地址(Destination)：

訊息目標地址是訊息傳送的目標地址，也是訊息接收者獲取訊息的目標地址，因此在傳送jms訊息之前，需要先配置訊息的目標到達地址。

Jboss中的配置如下：

名稱以”**-service.xml”命名，

(1).PTP型別訊息目標地址的配置：

<server> <mbean code=”org.jboss.mq.server.jmx.Queue” name=”jboss.mq.destination:service=Queue, name=queue訊息的目標地址”> <attribute name=”JNDIName”>queue/ queue訊息的目標地址</attribute> <depends optional-attribute-name=”DestinationManager”> Jboss:mq:service=DestinationManager</depends> </mbean> </server> 

(2).pub/sub型別訊息目標地址的配置：

<server> <mbean code=”org.jboss.mq.server.jmx.Topic” name=”jboss.mq.destination:service=Topic, name=topic訊息的目標地址”> <attribute name=”JNDIName”>topic/ topic訊息的目標地址</attribute> <depends optional-attribute-name=”DestinationManager”> Jboss:mq:service=DestinationManager</depends> </mbean> </server> 

5.傳送JMS訊息過程：

在java類中傳送jms訊息一般步驟：

(1).得到一個JNDI初始化上下文：

InitialContext context = new InitialContext(); 

(2).根據上下文查詢JMS連線工廠：

該連線工廠是由JMS提供的，每個javaEE伺服器廠商都為它繫結一個全域性的JNDI。

以QueueConnectionFactory為例(TopicConnectionFactory類似)：

QueueConnectionFactory factory = (QueueConnectionFactory)context.lookup(“ConnectionFacotry”);
(3).從連線工廠得到一個JMS連線：

以QueueConnection(TopicConnection類似)為例：

QueueConnection conn = factory.createQueueConnection(); 

(4).通過jms連線建立一個jms會話：

以QueueSession(TopicSession類似)為例：

QueueSession session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); 

第一個引數表示：不需要事物。第二個引數表示：自動確認訊息已接收的會話。

(5).查詢訊息目標地址：

Destination destination = (Destination)context.lookup(訊息目標地址的JNDI名); 

(6).根據會話及目標地址來建立訊息生產者：

MessageProducer producer = session.createProducer(destination); TextMessage msg = session.createTextMessage(訊息內容); producer.send(msg); 

(7).訊息傳送完畢後，關閉會話和連線：

conn.close(); session.close(); 

6.使用訊息驅動bean(MDB)接收訊息：

一個訊息驅動bean(MDB)通常要實現MessageListener介面，實現該介面的onMessage(Message message)方法處理接收的jms訊息(非同步方式接收jms訊息)。

在訊息驅動bean前加如下註解：

@MessageDriven(activationConfig= { @ActivateConfigProperty(propertyName=”destinationType”, propertyValue=”javax.jms.Queue”), //監聽目標地址型別 @ActivateConfigProperty(propertyName=”destination”, propertyValue=”訊息的JNDI名稱”), //目標地址JNDI名稱 @ActivateConfigProperty(propertyName=”acknowledgeNode”, propertyValue=”Auto-acknowledge”) //自動接收訊息，預設不用配置 }) 

由於訊息驅動bean使用了例項化池技術，具有處理大批量併發訊息的能力，所以非常適合應用在一些閘道器產品中。

7.JMS程式設計模型總結：

通過5，6具體學習了JMS傳送和接收處理訊息的流程後，總結jms程式設計模型如下：

8.JMS中訊息的兩種接收方式：

(1).同步方式：訂閱者或接收者呼叫receive方法來接收訊息，此方法在接收到訊息之前一直阻塞。

(2).非同步方式：訂閱者或接收者可以註冊為一個訊息監聽器，當訊息到達之後，系統自動呼叫監聽器的onMessage方法。