rabbitmq-exchange

3熱度

1回答

（從Github Issue拾）縮放隊列，我們使用的RabbitMQ的consistent hash exchange這是從交流到多個隊列分片路由鍵有用。我們使用隊列將工作交給工人。理想情況下，我們希望動態擴展這些工作人員，但這會帶來問題。要擴大規模，您需要添加一個新的隊列和綁定。在它自己的情況下，這不是什麼大問題 - 除了分片密鑰現在可能開始進入不同隊列的事實。所以工作者A可能一直在

2熱度

1回答

RabbitMQ - 單個併發工作者每個路由密鑰

相當新的RabbitMQ，我試圖看看我能否實現我所需要的。我正在尋找工作隊列模式，但有一個警告。我想只有一個工作者同時運行每個路由鍵。澄清一個例子：如果我的順序發送具有路由鍵下面的消息：a，a，b，c，我想只有3個工人同時運行。當收到第一個a消息時，工作人員將其拿起並處理。當收到下一個a消息並且之前的a消息仍然處理（未確認）時，新的a消息應在隊列中等待。當接收到b和c消息時，他們每個都會得

0熱度

1回答

RabbitMQ消費者沒有收到生產者發送的消息

嗨我想通過rabbitMQ發送消息。我宣佈直接交換並將其路由到我在生產者隊列的隊列中，但我無法在消費者處收到消息。以下是我的消費代碼： package com.rabbit.consumer; import java.io.IOException; import java.util.concurrent.TimeoutException; import com.rabbitmq.clie

1熱度

2回答

如何訪問在Bunny會話中打開的通道/隊列？

我使用兔MQ的Ruby客戶端（兔子）。我移動在初始化孔兔子配置和初始化處理。如何訪問通道/隊列從控制器或LIB內的兔子連接上打開？我得到「真」當我打電話Bunny::Session#open?但我似乎無法弄清楚如何獲得我需要的一切在這屆會議。

0熱度

1回答

兔子MQ（兔子）中的消費者太多

我通過JMeter向我的應用發送大量數據。我的訂閱塊和出版商是這樣的： BunnyStarter.start_bunny_components cons = BunnyStarter.queue.subscribe do |delivery_info, metadata, payload| method_calling (payload) cons.cancel

-1熱度

1回答

WARN o.s.a.r.l.ConditionalRejectingErrorHandler - 執行Rabbit消息偵聽器失敗

有2個Spring項目'A'和'B'。他們都使用單獨的數據庫。這個想法是保持這些數據庫在同步。同步是通過在項目之間交換Jav POJO對象來完成的。 'A'有一個java web api來處理請求。當進行API調用時，'A'使用Rabbit MQ通過消息傳送通道將POJO傳送到'B'。但Iam在執行上述操作時得到以下例外： 2016-05-21 10:29:02,335 INFO o.mmc.bb

0熱度

2回答

從IBM MQ遷移到RabbitMQ

我們可以從IBM MQ遷移到Rabbit MQ嗎？這可能嗎？是否有任何依賴關係？我們需要考慮哪些因素。

3熱度

1回答

RabbitMq：有沒有辦法在集羣環境中的所有虛擬主機上應用策略來進行隊列鏡像？

在RabbitMQ的，如果我想在鏡像集羣環境隊列我使用下面的命令： rabbitmqctl set_policy ha-all "" '{"ha-mode":"all","ha-sync-mode":"automatic"}' 此命令將策略應用於虛擬主機"\"的所有隊列。如果我要申請特定虛擬主機的政策說「富」我用： rabbitmqctl set_policy -p "foo" ha-al

0熱度

1回答

RabbitMQ - 手動將生產者置於流量控制中

在我們的一個應用程序中，背壓無法工作，RabbitMQ上的隊列中出現巨大的堆積。這導致RMQ節點窒息。在這種情況下，是否有辦法在該隊列上應用流量控制（手動）？這會降低製作人的能力，並給我們提供空間。

0熱度

1回答

RabbitMQ的路由行爲

我試圖通過的RabbitMQ發佈消息到2個不同的queueus，但事情並沒有表現爲我所期待的，這裏是細節：我有一個交換：amq.fanout，類型：扇出，並且綁定是隊列：Q1，路由密鑰：密鑰1和隊列：Q2，路由密鑰：密鑰2。在我的客戶端，我有這樣的代碼 var model = connection.CreateModel(); model.ExchangeDeclare("amq.fanout