目前场景为有一个topic模式交换机,多个消费者订阅一个队列,当一条消息进入,保证该消息推送给所有消费者一次,随后销毁该消息(确认消费),尝试过很多方案都不可行,请问有什么好的方案么。现在有一个方案是使用fanout模式广播,每个消费者单独监听一个队列。
目前场景为有一个topic模式交换机,多个消费者订阅一个队列,当一条消息进入,保证该消息推送给所有消费者一次,随后销毁该消息(确认消费),尝试过很多方案都不可行,请问有什么好的方案么。现在有一个方案是使用fanout模式广播,每个消费者单独监听一个队列。
15 回答8.4k 阅读
8 回答6.2k 阅读
1 回答4k 阅读✓ 已解决
3 回答6k 阅读
3 回答2.2k 阅读✓ 已解决
2 回答3.1k 阅读
2 回答3.8k 阅读
你说的这种就是广播模式 fanout,每个消费者监听一个队列。
参考 https://www.rabbitmq.com/tuto...
不清楚这种方式是否会占用额外的内存空间,如果是基于引用计数的,不会有额外的内存占用。