我有以下架构:
Architecture
输入源正在发送要处理的命令。这些命令由代理转发并由两个消费者之一接收。
我需要以下行为:
是否可以使用 AMQP/RabbitMQ 强制执行此行为?
最佳答案
您可以为每个队列使用一个使用者来涵盖您的场景。
每个队列可以顺序处理消息。
另一种方法是只使用一个队列并使用 envelope.getExchange()
了解源码,或tag
您的消息使用 AMQP.BasicProperties properties
这样,例如,您可以在多线程中消费消息,并为每个 tag
分配一个线程。
关于rabbitmq - AMQP/RabbitMQ - 如何避免竞争条件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37393740/