1、確認JMS訊息

        只有在被確認之後，才認為已經被成功地消費了。訊息的成功消費通常包含三個階段：客戶接收訊息、客戶處理訊息和訊息被確認。 在事務性會話中，當一個事務被提交的時候，確認自動發生。在非事務性會話中，訊息何時被確認取決於建立會話時的應答模式（acknowledgement mode）。該引數有以下三個可選值：
         

          • Session.AUTO_ACKNOWLEDGE。

                   當客戶成功的從receive方法返回的時候，或者從MessageListener.onMessage方法成功返回的時候，會話自動確認客戶收到的訊息。
         • Session.CLIENT_ACKNOWLEDGE。

                   客戶通過訊息的acknowledge方法確認訊息。需要注意的是，在這種模式中，確認是在會話層上進行：確認一個被消費的訊息將自動確認所有已被會話消費的訊息。例如，如果一個訊息消費者消費了10個訊息，然後確認第5個訊息，那麼所有10個訊息都被確認。

1、生產者，設定簽收模式為Session.CLIENT_ACKNOWLEDGE
// 通過Connection物件建立Session會話（上下文環境物件），
// 引數一，表示是否開啟事務
// 引數二，表示的是簽收模式，一般使用的有自動簽收和客戶端自己確認簽收
Session session = connection.createSession(Boolean.FALSE,
Session.CLIENT_ACKNOWLEDGE);

2、消費者，設定簽收模式為Session.CLIENT_ACKNOWLEDGE
// 通過Connection物件建立Session會話（上下文環境物件），
		// 引數一，表示是否開啟事務
		// 引數二，表示的是簽收模式，一般使用的有自動簽收和客戶端自己確認簽收
		Session session = connection.createSession(Boolean.FALSE,
				Session.CLIENT_ACKNOWLEDGE);

3、消費者，在消費訊息的時候，返回一個確認
// 使用Session來建立訊息物件的生產者或者消費者
MessageConsumer createConsumer = session.createConsumer(destination);
while (true) {
TextMessage textMessage = (TextMessage) createConsumer.receive();
if (textMessage == null)
break;
// 客戶端的簽收模式，
textMessage.acknowledge();
System.out.println("收到的內容為" + textMessage.getText());
}



 

                   該選擇只是會話遲鈍的確認訊息的提交。如果JMS Provider失敗，那麼可能會導致一些重複的訊息。如果是重複的訊息，那麼JMS Provider必須把訊息頭的JMSRedelivered欄位設定為true。

2、持久化

      JMS 支援以下兩種訊息提交模式：
            • PERSISTENT。

                       指示JMS Provider持久儲存訊息，以保證訊息不會因為JMS Provider的失敗而丟失。
            • NON_PERSISTENT。

                       不要求JMS Provider持久儲存訊息。

3、優先順序

         可以使用訊息優先順序來指示JMS Provider首先提交緊急的訊息。優先順序分10個級別，從0（最低）到9（最高）。如果不指定優先順序，預設級別是4。需要注意的是，JMS Provider並不一定保證按照優先順序的順序提交訊息。

4、訊息過期

        可以設定訊息在一定時間後過期，預設是永不過期。

#在生產者傳送訊息的過程中，可以指定deliveryMode傳輸模式，priority訊息優先順序，timeToLive訊息過期時間

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

         ActiveMQ支援兩種訊息的傳送模式，PERSISTENT和NON_PERSISTENT兩種。如果不指定傳輸模式，預設的就是持久化訊息。如果容忍訊息丟失，那麼可以使用非持久化的訊息機制以改善效能和減少開銷。

         訊息優先順序從0-9十個級別，0-4是普通訊息，5-9是加急訊息。如果不指定優先順序，預設為4.JMS不要求嚴格按照這十個優先順序傳送訊息，但必須保證加急訊息要優先於普通訊息到達。

         預設情況下，訊息永不會過期。如果訊息在特定週期內失去意義，那麼可以設定過期時間，單位為毫秒。

               // 5、使用Session來建立訊息物件的生產者或者消費者
		MessageProducer messageProducer = session.createProducer(null);

		// 6、最後使用JMS規範的TextMessage形式建立資料(通過Session物件)
		// 並利用MessageProducer的send方法傳送資料
		for (int i = 0; i < 5; i++) {
			TextMessage textMessage = session.createTextMessage();
			textMessage.setText("我是訊息" + i);

			// 7、在傳送訊息的時候，指定訊息的目的地,持久化方式，優先順序，以及訊息的過期時間

			messageProducer.send(destination, textMessage,
					DeliveryMode.NON_PERSISTENT, i, 1000 * 60);
		}

5、臨時目的地

         可以通過會話上的createTemporaryQueue方法和createTemporaryTopic方法來建立臨時目的地。它們的存在時間只限於建立它們的連線所保持的時間。只有建立該臨時目的地的連線上的訊息消費者才能夠從臨時目的地中提取訊息。

6、持久訂閱

        首先訊息生產者必須使用PERSISTENT提交訊息。客戶可以通過會話上的createDurableSubscriber方法來建立一個持久訂閱，該方法的第一個引數必須是一個topic，第二個引數是訂閱的名稱。 JMS Provider會儲存釋出到持久訂閱對應的topic上的訊息。如果最初建立持久訂閱的客戶或者任何其它客戶使用相同的連線工廠和連線的客戶ID、相同的主題和相同的訂閱名再次呼叫會話上的createDurableSubscriber方法，那麼該持久訂閱就會被啟用。JMS Provider會象客戶傳送客戶處於非啟用狀態時所釋出的訊息。 持久訂閱在某個時刻只能有一個啟用的訂閱者。持久訂閱在建立之後會一直保留，直到應用程式呼叫會話上的unsubscribe方法。

7、本地事務

         在一個JMS客戶端，可以使用本地事務來組合訊息的傳送和接收。JMS Session介面提供了commit和rollback方法。事務提交意味著生產的所有訊息被髮送，消費的所有訊息被確認；事務回滾意味著生產的所有訊息被銷燬，消費的所有訊息被恢復並重新提交，除非它們已經過期。 事務性的會話總是牽涉到事務處理中，commit或rollback方法一旦被呼叫，一個事務就結束了，而另一個事務被開始。關閉事務性會話將回滾其中的事務。 需要注意的是，如果使用請求/回覆機制，即傳送一個訊息，同時希望在同一個事務中等待接收該訊息的回覆，那麼程式將被掛起，因為知道事務提交，傳送操作才會真正執行。 需要注意的還有一個，訊息的生產和消費不能包含在同一個事務中。