我有生产者和消费者。
多个实例
的消费者正在运行。当producer发布消息时,我的意图是通过所有实例使用消息。所以,我用的是直接交换。生产者将消息发布到与主题的直接交换。消费者正在使用独占队列收听该主题。当用户启动并且生产者发布消息时,此过程运行良好。但当消费者情绪低落,生产者发布一条消息时,消费者不会在情绪高涨时消费这条消息。
我在谷歌上搜索了这个问题。建议使用命名队列。但是如果我使用命名队列,消息将按照循环算法被消耗。这不符合我的期望,即所有的消费者都会使用相同的信息。
还有别的办法吗?
感谢你的帮助。
