ActiveMQ之java Api

ActiveMQ 安全機制

activemq的web管理界面：http://127.0.0.1:8161/admin

         activemq管控臺使用jetty部署，因此須要修改密碼則須要修改相應的配置文件，apache-activemq-5.11.1\conf\jetty.xml

activemq應該設置有安全機制，只有符合認證的用戶才能進行發送和獲取消息，因此咱們能夠在activemq.xml添加安全驗證配置。一個插件，配置一下便可

配置完成後，須要從新啓動mq。

而後在Receive和Sender中配置相關的認證信息。

Connection方法使用

在成功建立正確的ConnectionFactory後，下一步將是建立一個鏈接，它是JMS定義的一個接口，ConnectionFactory負責返回能夠與底層消息傳遞系統進行通訊的Connection實現，一般客戶端只使用單一鏈接。根據JMS文檔，Connection的目的是「利用JMS提供者封裝開發的鏈接」，以及表示「客戶端與提供者服務例程之間開發TCP/IP套接字」。該文檔還指出Connection應該是進行客戶端身份驗證的地方等等，

當一個Connection被建立時，它的傳輸默認是關閉的，必須使用start方法開啓。一個Connection能夠創建一個或多個的Session。

當一個程序執行完成後，必須關閉以前建立的Connection，不然ActiveMq不能釋放資源，關閉一個Connection一樣也關閉了Session，MessageProducer和MessageConsumer。

Connection.createConnection();

Connection.createConnection(String userName, String password ,String url);

Session方法使用

一旦從ConnectionFactory中得到一個Connection，必須從Connection中建立一個或者多個Session。Session是一個發送或者接收消息的線程，可使用Session建立MessageProducer,MessageConsumer和Message

Session能夠被事務化，也能夠不被事務化，一般，能夠經過向Connection上的適當建立方法傳遞一個布爾參數對此進行設置。

Session createSession(boolean transacted ，int acknowledgeMode)

　　其中transacted爲使用事務標識，acknowledgeMode爲簽收模式。

　　結束事務有兩種方法：提交或者回滾，當一個事務提交，消費被處理、出入事務中有一個步驟失敗，事務就回滾，這個事務中的意見執行的動做將被撤銷。在發送消息最後也必需要使用session.commit()方法表示提交事務。

　　簽收模式有三種形式：

　　Session.AUTO_ACKNOWLEDGE 當客戶端從receive或onMessage成功返回時，Session自動簽收客戶端的這條消息的收條。

　　Session.CLIENT_ACKNOWLEDGE客戶端經過調用消息(Message)的acknowledgeMode方法簽收消息。這種狀況下，簽收發生在Session層面：簽收一個已消費的消息會自動簽收這個Session全部已消費的收條。

　　Session.DUPS_OK_ACKNOWLEDGE此選項指示Session沒必要確保對傳送消息的簽收。它可能引發消息的重複，可是下降了Session的開銷，因此只有客戶端能容忍重複的消息，纔可以使用。

 MessageProducer

 MessageProducer : MessageProducer是一個由Session建立的對象，用來向Destination發送消息。

void send(Destination destination,Message message);

void send(Destination destination,Message message ,int deliveryMode,int priority . long timeToLive);

void send(Message message);

void send(Message message , int deliveryMode,int priority . long timeToLive)

其中deliveryMode爲傳送模式，priority爲消息優先級，timeToLive爲消息過時時間。

ActiveMQ支持兩種消息傳送模式：PERSISTEN和NON_PERSISTENT兩種。若是不指定傳送模式，那麼默認是持久化消息，若是容忍消息丟失，那麼使用非持久性消息能夠改善性能和減小存儲的開銷。

消息優先級從0-9石哥級別。0-4是普通消息，5-9是加急消息。若是不指定優先級，則默認爲4.JMS不要求嚴格按照這10個優先級發送消息，但必須保證加急消息要先於普通消息到達。(消費順序和優先級不一致)

固然ActimeMQ還有一種獨有消費模式，能夠確保消息順序

默認狀況下，消息永不過時，若是消息在特定週期內失去意義，那麼能夠設置過時時間，時間單位爲毫秒。

 MessageConsumer

MessageConsumer是一個由Session建立的對象，用來從Destination接收消息。

MessageConsumer createConsumer(Destination destination)

MessageConsumer createConsumer(Destination destination,String messageSelector)

MessageConsumer createConsumer(Destination destination,String messageSelector,boolean noLocal)

TopicSubscriber createDurableSubscriber(Topic topic,String name);

TopicSubscriber createDurableSubscriber(Topic topic,String name,String messageSelector,boolean noLocal);

其中messageSelector爲消息選擇器，noLocal標誌默認爲false，當設置爲true時限制消費者只能接收和本身相同的鏈接(Conneciton)所發佈的消息。此標誌只適用於主推，不適用於隊列；name標識訂閱主題所對應的訂閱名稱，持久訂閱時須要設置此參數。

public final String SELECTOR ="JMS_TYPE = 'MY_TAG1'";該選擇器檢查了傳入消息的JMS_TYPE屬性，並肯定了這個屬性，並肯定了這個屬性的值是否等於MY_TAG1.若是相等，則消息被消費，若是不相等，那麼消息會被忽略。

 消息的同步和異步接收：

消息的同步接收是指客戶端主動去接收消息，客戶端能夠採用MessageConsumer的receive方案區接收下一個消息。

　　Message receive()

　　Message receive(long timeout)

　　Message receiveNoWait()

消息的異步接收是指當消息到達時，ActiveMQ主動通知客戶端，能夠經過註冊一個實現MessageListener接口的對象到MessageConsumer，MessageListener只有一個必須實現的方案---onMessage，它只接收一個參數，即Message，在爲每一個發送到Destination的消息實現onMessage時，將調用該方法。