Py学习  »  MQ

rabbitmq:当使用者关闭时发布消息,并且之后的使用者不能在没有命名队列的情况下使用消息

Niloy Datta • 5 年前 • 964 次点击  

我有生产者和消费者。 多个实例 的消费者正在运行。当producer发布消息时,我的意图是通过所有实例使用消息。所以,我用的是直接交换。生产者将消息发布到与主题的直接交换。消费者正在使用独占队列收听该主题。当用户启动并且生产者发布消息时,此过程运行良好。但当消费者情绪低落,生产者发布一条消息时,消费者不会在情绪高涨时消费这条消息。

我在谷歌上搜索了这个问题。建议使用命名队列。但是如果我使用命名队列,消息将按照循环算法被消耗。这不符合我的期望,即所有的消费者都会使用相同的信息。

还有别的办法吗?

感谢你的帮助。

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/40519
 
964 次点击  
文章 [ 1 ]  |  最新文章 5 年前