我正在使用node-amqp。對於每個隊列,都有一個發件人和一個消費者。在發件人方面,我需要維護一個活躍消費者的列表。問題是消費者電腦何時崩潰,我將如何收到通知並將其從發件人列表中刪除?隊列發送者如何知道消費者崩潰?
3
A
回答
2
我想你可能沒有正確使用MQ概念。整個觀點是將消費者與生產者分開。總的來說,除了消費者的消息類型之外,生產者不需要了解消費者的任何信息。如果消費者崩潰並且消息將繼續積聚在隊列中,那麼製片人將繼續製作。
1
有一種方法使用的RabbitMQ的HTTP API來做到這一點(在http:// 服務器名稱:55672/API /)來獲取連接列表,但實在是太殘酷了頻繁的查詢。理論上另一種方法是使用備用交換機來檢測未傳送的消息,但我還沒有嘗試過這種方式。 另外,通過使用如下所述的死信交換來檢測意外的消費者斷開可能是可能的:http://www.rabbitmq.com/dlx.html
相關問題
- 1. 消費者過濾的生產者 - 消費者阻塞隊列
- 2. 生產者/消費者工作隊列
- 3. 生產者消費者阻止隊列
- 4. 生產者 - 消費者多個生產者多個隊列單個消費者
- 5. 卡夫卡:消費者崩潰
- 6. Java生產者 - 消費者:生產者不「通知()」消費者
- 7. 阻塞隊列和多線程消費者,如何知道何時停止
- 8. 當消費者未確認消息時,ActiveMQ停止向隊列消費者發送消息
- 9. c#生產者/消費者隊列發佈
- 10. ActiveMQ如何保持未能發送給消費者隊列/主題的消息?
- 11. 如何知道哪個隊列被分配給哪個消費者-RocketMQ?
- 12. 鎖定免費隊列 - 單個生產者,多個消費者
- 13. 生產者 - 消費者:怎麼知道通知prodcution完成
- 14. 同步生產者,消費者和生產者隊列
- 15. 雙排隊的消費者生產者
- 16. Azure工作者角色+消息隊列消費者的數量
- 17. 如何讓消費者知道生產者已完成將所有消息發送給經紀人?
- 18. 多個消費者一個隊列
- 19. AMQP - 隊列中有多少消費者?
- 20. 消費者如何知道在ChannelSet中使用什麼渠道?
- 21. 如何在Mule中創建排隊隊列消費者?
- 22. JMS - 消費者在消費之前瀏覽隊列消息
- 23. RabbitMQ消費者沒有收到生產者發送的消息
- 24. 當在rabbitmq上刪除隊列時通知消費者
- 25. 如何從隊列/訂閱向接收者發送消息?
- 26. 生產者和消費者的Java同步隊列線程
- 27. Clojure中的生產者消費者隊列
- 28. 隊列:N生產者到N消費者
- 29. 單個生產者多個消費者 - 隊列包含null
- 30. JMS - 一個隊列和很多接收者(消費者)