java消息機制

最近學習java消息相關的內容，整理了下學習內容：
一、問： 什麼是 Java 消息服務？
答: Java 消息服務(Java Message Service，JMS) API 是一個用於訪問企業消息傳遞系統的 API。是 Java 2 Platform, Enterprise（J2EE）的一部分。

二、目前流行的消息傳送產品有哪些？
答：目前流行的有ActiveMQ、IBM WebSphere MQ、SonicMQ等

三、何時能夠用到java消息機制？
答：（1）異構系統集成，整合現有資源，提升資源的利用率
       （2）異步請求處理，減輕或消除系統瓶頸，提升用戶生產率和系統的總體可伸縮性
       （3）組件解偶，增長系統的靈活性

四、消息傳送的兩種模型
發佈/訂閱模型
客戶端發送消息到一個名爲主題（topic）的虛擬通道中，每一個訂閱該主題的消費者都會接收到每條消息的一個副本。
點對點模型
客戶端經過隊列（queue）這個虛擬通道來同步和異步發送、接收消息，發送到隊列的消息只能被一個接收者所接收，即便有多個消費者時也只能有一個消費者處理消息

五、JMS包含哪些接口？
JMS API能夠分爲3個主要部分：公共API、點對點API和發佈/訂閱API。在JMS1.1中，公共API可被用於向一個隊列或一個主題發送消息，或從其中接收消息。點對點API專門用於使用隊列的消息傳送，而發佈/訂閱API則專門用於使用主題的消息傳送。
在JMS公共API內部，和發送和接收JMS消息有關的JMS API接口主要有7個：
l          ConnectionFactory
l          Destination
l          Connection
l          Session
l          Message
l          MessageProducer
l          MessageConsumer
在這些公共接口中，ConnectionFactory和Destination必須使用JNDI（遵守JMS規範要求）從提供者處得到。其餘接口則能夠 經過工廠方法在不一樣的API接口中建立。舉例來講，一旦有了一個ConnectionFactory，就能夠建立一個 Connection。一旦有了一個Connection，就能夠建立一個Session。而一旦有了一個Session，就能夠建立一個 Message、MessageProducer和MessageConsumer。這7個主要的JMS公共API接口之間的關係如圖1-5所示。
在JMS中，是Session對象保存着用於消息傳送的事務性工做單元（transactional unit），而不是Connection對象。這和JDBC不一樣，JDBC中是Connection對象保存事務性工做單元。這就意味着在使用JMS時， 一個應用程序一般只會有一個Connection對象，可是它能夠有一個Session對象池。
另外，還有和異常處理、消息優先級及消息持久性有關的其餘接口




六、java消息分爲哪些部分？
消息頭、消息屬性、消息自身

七、消息過濾
消息訂閱者須要對消息進行過濾，不然訂閱者就會接受到主題或隊列的每一條消息，浪費了沒必要要的資源（CPU、內存等），而使用消息過濾技術，能讓訂閱者只 接受它須要的消息。（消息過濾對於隊列消費尤爲重要，由於一個隊列消費者消費消息後其餘消費者就再也不可用，此時若是不對消息進行過濾處理，這條消息就很可 能被浪費掉）。
消息選擇器使用消息屬性和消息頭做爲條件表達式的傳送載體（消息體不能做爲消息選擇器的參考對象）。
消息選擇器由標識符、常量和比較運算符組成：
例：
     建立一個消息以下：
        TextMessage textMessage = Session.createTextMessage();
         textMessage.setText(「mytestMsg」);
         textMessage.setStringProperty(「city」,」hangzhou」);
         textMessage.setStringProperty(「company」,」mycompany」);
         這條消息中設置的消息屬性名「city」和「company」表明消息選擇器的標識符，」hangzhou」和」mycompany」表明常量

          在消費端建立一個選擇器：
          String selector = 「city = 'hangzhou' AND company='mycompany'」;
          QueueReceiver qReceiver = qSession.createReceiver(testQ,selector);
          其中「=」和「AND」爲比較運算符，其餘經常使用比較運算符還有：
          算數比較運算符（=、>、<、<=、<>等）
          like運算符、BETWEEN運算符、IN運算符、IS NULL運算符等
         

8 、消息過濾

消息訂閱者須要對消息進行過濾，不然訂閱者就會接受到主題或隊列的每一條消息，浪費了沒必要要的資源（ CPU 、內存等），而使用消息過濾技術，能讓訂閱者只接受它須要的消息。（消息過濾對於隊列消費尤爲重要，由於一個隊列消費者消費消息後其餘消費者就再也不可用，此時若是不對消息進行過濾處理，這條消息就極可能被浪費掉）。

消息選擇器使用消息屬性和消息頭做爲條件表達式的傳送載體（消息體不能做爲消息選擇器的參考對象）。

消息選擇器由標識符、常量和比較運算符組成：

例：

     建立一個消息以下：

        TextMessage textMessage = Session.createTextMessage();

         textMessage.setText(「mytestMsg」);

          textMessage.setStringProperty(「city」,」hangzhou」);

         textMessage.setStringProperty(「company」,」alibaba」);

         這條消息中設置的消息屬性名 「city」 和 「company」 表明消息選擇器的標識符， 」hangzhou」 和 」alibaba」 表明常量

 

          在消費端建立一個選擇器：

          String selector = 「city = 'hangzhou' AND company='alibaba' 」;

          QueueReceiver qReceiver = qSession.createReceiver(testQ,selector);

          其中 「=」 和 「AND」 爲比較運算符，其餘經常使用比較運算符還有：

          算數比較運算符（ = 、 > 、 < 、 <= 、 <> 等）

          like 運算符、 BETWEEN 運算符、 IN 運算符、 IS NULL 運算符等

         

 

 

9 、消息傳送的可靠性

在消息的傳送過程當中因爲網絡、軟硬件故障等都會致使消息的發送失敗， jms 爲保證消息的傳送定義了 3 條法則：

（ 1 ）消息自主性，消息是自包含的自主性實體，當發送端發出這條消息後這條消息就再也不受發送端的限制，它能夠在多個進程間被屢次發送。

（ 2 ）存儲轉發，當消息被標記位持久性消息時，就由 jms 提供者利用 「 保存並轉發 」 機制，將消息保存在可信的介質上，防止發生故障時仍然能夠正常恢復

（ 3 ）消息確認機制，服務器確認已經從發送端收到了消息，消費者則從確認從服務器接收了消息，對消息傳送過程的監控，保證了消息的可靠傳送。 消息確認的 3 種模式：

1 、 AUTO_ACKNOWLEDGE 
從消息生產者角度：發送消息後就開始阻塞，直到從消息服務器收到回覆，期間如發生異常則認爲消息未被傳送  

從消息服務器角度：非持久消息在接受到消息後通知生產者，並將消息存入內存，持久性消息在接受道消息後先存入磁盤，而後通知生產者  

從消費者角度：接受到消息後就向服務器發送確認信息，若是服務器沒有收到確認，會從新發送  

2 、 CLIENT_ACKNOWLEDGE 
消費者可在處理完業務邏輯後在代碼重顯示調用 message.acknowledge() 通知 jms 提供者已成功接收道消息  
3 、 DUPS_ACKNOWLEDGE 
可將一條消息向同一目的地發送兩次以上  

 

 

這裏介紹兩個概念：

（ 1 ）持久化消息：消息持久化就是在發送者將消息發送出去後，消息中心首先將消息存儲到本地數據文件、內存數據庫或者遠程數據庫等，而後試圖將消息發送給接收 者，發送成功則將消息從存儲中刪除，失敗則繼續嘗試。消息中心啓動之後首先要檢查制定的存儲位置，若是有未發送成功的消息，則須要把消息發送出去。經過在消息頭設置來實現：如

MessageProducer producer = session.createProducer(destination);

producer.setDeliveryMode(DeliveryMode.PERSISTENT);

(2) 持久訂閱者和非持久訂閱者：非持久訂閱者是指某個訂閱者因爲某種緣由中止運行，那麼在中止運行期間發佈到該訂閱者所訂閱主題的消息就會沒法得到，持久訂閱者則恰好相反，持久訂閱者會接收發送到訂閱主題的全部消息，不管訂閱者是否正常運行，電子郵件就是相似的一個例子。

持久化消息和持久訂閱者在服務器和消費者端之間的消息傳送保證機制比較相似， 但在有一種狀況下他們仍是存在區別的，對持久訂閱者來講，當消息服務器向發送者發送確認消息以後，併爲當前未運行的持久訂閱者將消息保存到介質之間若是發 送故障，該消息就會丟失，而持久化消息則是先保存消息道介質，而後才向發送者發送確認消息，因此不存在這個問題，所以嚴格來講持久化消息的可靠性會更高。

10 、事務性消息

jms 事務性保證了一組發送的消息或接收的消息要麼所有成功要麼所有失敗，概念上和咱們在java 中使用的jta 類似，但jms 事務是由jms 提供者來管理的，而不是jta 。

使用方法以下：

   // 此處用true ，表示使用事務性消息

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

// 用來發送的3 個消息

MessageProducer sender = session.createProducer(「queue/testQueue」);

try{

    TextMessage message1 = session.createTextMessage(「 要發送的消息1」);

　　    sender.send(message);

    TextMessage message2 = session.createTextMessage(「 要發送的消息2」);

　　    sender.send(message);

    TextMessage message3 = session.createTextMessage(「 要發送的消息3」);

　　    sender.send(message);

        session.commit();

    }catch(Exception e){

        try{

          session.rollback();

       }catch(JMSException e){

       }

}