rabbitmq-exchange

0熱度

1回答

爲了使用延遲交換，我通過發送「INT：網關」消息的RabbitMQ用這種方法： void send(@Payload Notification request, @Header(MessageProperties.X_DELAY) Integer delay, @Header("routingKey") String routingKey); 我可以在RabbitMQ的看到，標題正確顯示： x

-4熱度

2回答

RabbitMQ/AMQP交換路由策略

我有一個場景，發佈者需要向已知交換機發送消息（他們不會直接知道下游隊列）。大部分消息應該傳遞給每個綁定隊列（如扇出），但有些消息只需要傳遞給特定的綁定隊列。我想避免多次交換以及多個隊列債券。我當前的解決方案使用頭部路由，其中消息具有兩個頭中的一個，將其標識爲「全局」或「特定於某個特定子」，其中下游隊列綁定在匹配上 - 頭。我認爲這會起作用，但我覺得應該有一個更簡單的解決方案。我試圖找到一個

0熱度

1回答

如何動態擴展RabbitMQ中的隊列？

我可以使用RabbitMQ動態創建隊列嗎？在我的應用程序中，我希望隊列在隊列滿時動態擴展。我可以使用RabbitMQ來實現嗎？在此先感謝。

0熱度

1回答

RabbitMQ - 當訂閱服務失敗並出現一些錯誤時如何停止發佈服務

我在C＃中有2個窗口服務。服務1將消息發佈到RabbitMQ隊列。服務2訂閱RabbitMQ隊列。服務2還連接到TCP服務器，並將它從RabbitMQ收到的消息發送到此服務器。我的問題是，是否有任何方法來阻止服務1發佈消息到隊列中，當服務2使用此消息由於某些錯誤而失敗（大多數是SocketException，如果它無法連接到服務器）。任何指針都會非常有幫助。如果需要更多信息，請讓我知道

0熱度

1回答

RabbitMq中每個消息使用者的單獨死信隊列

我有一個使用RabbitMQ構建的發佈 - 訂閱場景。有一個交換機，發佈者正在發送消息，任何訂閱該交換機的消費者都會在其各自的隊列中接收這些消息。這是一個只有一個生產者但有多個消費者的粉絲場景。現在我願意將死信隊列整合到系統中，以便稍後可以處理被拒絕的消息。我的問題是 1）我應該爲每個消費者配置一個單獨的死信隊列，還是應該有一個處理所有消費者的所有被拒絕消息？ 2）如果兩者都可能，哪一個更好？

3熱度

1回答

Rabbitmq頭交換和確認交付

我想在RabbitMQ上使用頭交換，混合java和python組件，我需要確認交付。我似乎從python（pika）和java客戶端獲得不同的行爲。在蟒蛇： channel.exchange_declare(exchange='headers_test', ¦ ¦ ¦ ¦ ¦ ¦ ¦type='headers', ¦ ¦ ¦ ¦ ¦ ¦ ¦durable=True) channel.co

0熱度

1回答

的RabbitMQ - 聯合隊列Vs的交流聯合會

我已經建立了一個兔羣，我將消息發佈到扇出交換數據庫中的每一次有新的變化。我有一些專用的隊列綁定到這個交換中去了一些使用這些更新的微服務，我最初也爲外部客戶設置了一個專用的隊列，這樣他們就可以將它與自己的rabbit基礎架構聯合起來，每一條消息。現在我不知道是否允許交換聯盟，而不是創建爲每個新的外部消費者一個新的專用隊列會是一個更好的辦法，因爲越來越多的用戶會來的。有什麼優點和缺點？謝謝

0熱度

1回答

如何使用rabbitmqctl創建交換

rabbitmqctl的子命令list_exchanges列出所有交換。如何使用rabbitmqctl創建交換，因爲我沒有看到add_exchanges子命令？

1熱度

1回答

通過RPC中的RabbitMQ

得到錯誤的Pyspark通信我剛使用從遠程PC通過RPC.For測試目的pyspark通信的RabbitMQ我已經開發了是給我的錯誤我跟了一個測試代碼超過pyspark 這裏實現RPC RabbitMQ的文檔教程是我的火花RPC服務器代碼 import pika from tkinter import* from pyspark.sql import SparkSession from

1熱度

1回答

我可以綁定來自不同虛擬主機的隊列嗎？

我與來自交換機的虛擬主機，用戶等進行了交換，我綁定了不同的隊列。交換和隊列在同一個虛擬主機中。現在我想爲不同的隊列創建一個不同的虛擬主機，但是我無法將這個新的隊列綁定到前一個交換中，因爲它在不同的虛擬主機中。什麼是最好的解決方案呢？謝謝