NMS.ActiveMQ 獨佔消費者

獨佔消費者

在 4.x 及以上版本中，我們有一個稱為「獨佔消費者」或「獨佔佇列」的新功能，它可以避免最終用戶必須釘選任何東西。Broker 將選擇一個訊息消費者來取得佇列的所有訊息，以確保順序。如果該消費者失敗，Broker 將會自動故障轉移並選擇另一個消費者。

因此，效果是一個異質叢集，其中每個用戶端都具有相同的設定和配置；Broker 會選擇一個消費者作為主節點，並依序將所有訊息發送到它，直到它停止運作；然後您會立即故障轉移到另一個消費者。

對於那些在叢集中掙扎於釘選 NMS 消費者的人來說，您會立即意識到這對於建立叢集化、高可用分散式服務有多麼有用。

範例

使用 ActiveMQ URI 配置建立獨佔消費者，如下所示

var queue = session.GetQueue("TEST.QUEUE?consumer.exclusive=true");
var consumer = session.CreateConsumer(queue);