一、簡介

Queue中的消息是按照順序被分發到consumers的。然而，當你有多個consumers同時從相同的queue中提取消息時，

你將失去這個保證。因為這些消息是被多個線程并發的處理。有的時候，保證消息按照順序處理是很重要的。

如，你可能不希望在插入訂單操作結束之前執行更新這個訂單的操作。

??

二、使用

ActiveMQ從4.x版本起開始支持Exclusive Consumer。 Broker會從多個consumers中挑選一個consumer來處理queue中

所有的消息，從而保證了消息的有序處理。如果這個consumer失效，那么broker會自動切換到其它的consumer。?

可以通過DestinationOptions 來創建一個Exclusive Consumer，如下：

queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true"); consumer = session.createConsumer(queue);

?

還可以給consumer設置優先級，以便針對網絡情況進行優化，如下：

queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true&consumer.priority=10");

A．?????????當在接收信息的時候有一個或者多個備份接收消息者和一個獨占消息者的同時接收時候，無論兩者創建先后，在接收的時候，均為獨占消息者接收。

B．?????????當在接收信息的時候，有多個獨占消費者的時候，只有一個獨占消費者可以接收到消息。

C．?????????當有多個備份消費者和多個獨占消費者的時候，當所有的獨占消費者均close的時候，只有一個備份消費者接到到消息。

?

解決一個隊列并行問題：

通過排隊服務

?

拆分業務邏輯?consumer 處理不同的業務，處理完后響應，確認消息消費成功，當10條全部消費完畢，

又或者是根據具體業務情況，例如只有8條消息處理成功，程序是繼續執行，記錄日志，事后處理，還是立即數據回滾？靈活處理

總結

以上是生活随笔為你收集整理的JMS学习十一 ActiveMQ Consumer高级特性之独有消费者（Exclusive Consumer）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。