Python中关于RabbitMQ的问题请教

想请问下各位能否实现一个队列的消息被许多消费者取到,消费模式是需要 ACK.
如果能,请问该如何设置这个队列?
Python中关于RabbitMQ的问题请教

14 回复

https://www.rabbitmq.com/getstarted.html 很多时候这种基础的不能再基础的问题问出来，你的个人形象就完了


我无法理解你的问题

您可能没懂我的意思,我想要的是类似于广播方式的消费者,就是消费者能同时取到消息,但是又需要在一条队列里

如果按照 MQ 的设计,我一个消费者取到了这条队列的消息,其他消费者必须等待这个消费者释放了这条消息才能取到

很多时候这种基础的不能再基础的问题问出来，你的个人形象就完了。

用消息队列之前，请先看消息队列的消息模型设计。

pub/sub 模型 在 Broker 端应该是无状态的，所以跟没没办法 ack，因为 broker 根本不关心你是否已经消费过了。

你看看文档就会发现，fanout 其实每次是重新生成一个随机名称的队列的，在消费完直接把这个随机队列干掉。

进一步理解一下你的需求，可能是要在高并发的情况下（队列里在一瞬间进入多条重复消息），consumer 只处理一次。
这种情况就需要在 consumer 里面加个锁（比如 memcache 的 key，设定一个几秒的阈值过期，如果 val 存在就直接 return 不消费…）

没看到你的附言，如果想要有顺序执行的 pub/sub 的话，可能是你需要再 pub/sub 之前在加一个单队列。

感谢大佬,回复的很详细了,我去试试

rabbitMQ 真是不错的队列服务，不过对延时任务支持不好，插件也有点满足不了需求，最后还是上了 beanstalkd

『多个消费者同时消费，其中一个来 ACK 』根本就是一个伪需求。
我觉得需要搞清楚 2 个问题：
1. 为什么要多个消费者？是处理不同的逻辑吗？
2. 为什么只要 1 次 ACK ？消费者之间不是互相独立吗？

反正我没看懂，但是如果多个消费者之间没有任何关系的话，直接吧消息复制到 N 个 Queue，想要 ACK 的就 ACK，不想 ACK 的就设置不需要 ACK 就行了。

这么想来感觉题主是想要一个消息 -> N 个消费者处理不同的事情 -> 所有事情处理完 -> 派一个消费者去 ACK ？
这样一个 Queue 是实现不了的……

确实我没看仔细

需求是：一个消息被多个 consumer 消费，任何一个 consumer 确认消费后其他 consumer 就可以不处理了？
感觉这个设计方案有毒

两个队列，一个采用 work queue 模式，一个采用 fanout 模式。
一个队列不太可能实现。而且这个模式听起来比较奇怪。

rabbitmq 估计和 kafka 一样有组的概念

回到顶部