一、簡介

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

你將失去這個保證。因?yàn)檫@些消息是被多個線程并發(fā)的處理。有的時候，保證消息按照順序處理是很重要的。

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

??

二、使用

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

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

可以通過DestinationOptions 來創(chuàng)建一個Exclusive Consumer，如下：

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

?

還可以給consumer設(shè)置優(yōu)先級，以便針對網(wǎng)絡(luò)情況進(jìn)行優(yōu)化，如下：

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

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

B．?????????當(dāng)在接收信息的時候，有多個獨(dú)占消費(fèi)者的時候，只有一個獨(dú)占消費(fèi)者可以接收到消息。

C．?????????當(dāng)有多個備份消費(fèi)者和多個獨(dú)占消費(fèi)者的時候，當(dāng)所有的獨(dú)占消費(fèi)者均close的時候，只有一個備份消費(fèi)者接到到消息。

?

解決一個隊(duì)列并行問題：

通過排隊(duì)服務(wù)

?

拆分業(yè)務(wù)邏輯?consumer 處理不同的業(yè)務(wù)，處理完后響應(yīng)，確認(rèn)消息消費(fèi)成功，當(dāng)10條全部消費(fèi)完畢，

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

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。