amqp

1熱度

1回答

我正在使用php-amqplib與PHP和RabbitMQ進行客戶端 - 服務器通信。我有一個生產者腳本，看起來像工作正常，但我的消費者沒有收到任何東西。我用sudo rabbitmqctl list_queues檢查了隊列中的條目，每次運行生產者後，計數器都會增加。我的消費者沒有任何PHP錯誤，看起來像等待消息。什麼看起來不錯，它會在啓動時運行回調腳本一次，並收到空的傳入消息 - 而不會

0熱度

2回答

哪一個使用RabbitTemplate或AmqpTemplate？

我有以下程序寫在Spring Boot這工作正常。但問題是，我不確定我是否應該使用RabbitTemplate或AmqpTemplate。一些在線示例/教程使用RabbitTemplate，而另一些則使用AmqpTemplate。請指導什麼是最佳實踐和應該使用哪一個。 @SpringBootApplication public class BasicApplication { pr

0熱度

1回答

在Spring AMQP

相關SimpleMessageListenerContainer一樣關閉連接我目前工作的一個基於事件的異步AMQP消息監聽器，像這樣： @Configuration public class ExampleAmqpConfiguration { @Bean(name = "container") public SimpleMessageListenerContainer m

1熱度

1回答

Python ActiveMQ：是否有可能使用pika客戶端來處理ActiveMQ？

據我所知ActiveMQ支持amqp://協議，現在我想連接python中的ActiveMQ實例。是否可以使用pika包來獲得它？當我讀到pika的文件時，它似乎只是與RabbitMQ一起使用而設計的。否則，我應該使用哪種協議最適合於Python上的ActiveMQ？

1熱度

1回答

amqp qpid 1.0協議uri格式

我試圖將我的應用程序的AMQP版本升級到1.0（QPID 0.24.0）。目前，Connectionfactory URL的格式如下。 amqp://guest:[email protected]/test?brokerlist='tcp://ip1:5672?ssl='true'&ssl_cert_alias='cert1'' 我試圖改變URL以下格式，並嘗試不同的組合（強力） amqps

0熱度

1回答

在RabbitMQ中正確處理UnknownHostException，阻止自動恢復

我已經編寫了一個Spring應用程序，該應用程序正在RabbitMQ Client API中手動實現RabbitMQ。連接工廠和連接的設置方式類似於教程： public class Recv { private final static String QUEUE_NAME = "hello"; public static void main(String[] argv)

1熱度

1回答

RabbitMq：使用auto-ack = false禁用預取（prefetch_count = 0）

是否可以使用auto-ack = false禁用預取？每次我確認一條消息時，我只想避免從隊列中讀取消息（預取）。我只想在我調用'consume_message'時讀取消息。設置prefetch_count = 0似乎不起作用，並將其視爲「無限制」。已更新：據我所知'prefetch_count'是客戶端緩存的消息數（本地讀入緩衝區）。例如，有一個用例：（假設有我們連接到一個隊列，它有消息）

2熱度

1回答

Wireshark：顯示過濾器vs嵌套解析器

我有一個通過AMQP發送JSON對象的應用程序，我想用Wireshark檢查網絡流量。 AMQP解析器將有效載荷作爲字段amqp.payload中的一系列字節提供，但我想提取並過濾JSON對象中的特定字段，所以我試圖在Lua中爲此編寫一個插件。 Wireshark已經有了JSON的解析器，所以我希望能夠捎帶，並且不必處理JSON解析自己。這裏是我的代碼： local amqp_json_p =

0熱度

1回答

RabbitMQ多服務器實例 - 只有一個活動消費者

我有node.js服務器，它也是rabbitmq使用者。我想擴展我的應用程序到多個實例，但只保持消費者活躍。我該怎麼做？感謝

0熱度

1回答

Java RabbitMQ consumer.nextMessage總是得到相同的消息

我們在分佈式服務體系結構中使用Java rabbitMq進行spring引導。一個服務獲取HTTP請求並將其轉發到未知隊列進行處理。同時，它必須等待另一個隊列上的響應，才能終止HTTP請求。（這是預覽請求，由渲染器完成其工作）。可以有多個ServiceA（HTTP接口）和ServiceB（渲染器）的實例，所以每個預覽消息都會發送一個唯一的ID用作路由密鑰。我對BlockingConsumer