AMQP:按声明顺序处理不同的队列
AMQP: Process different queues in declaration order
我有一个与不同队列的 (RabbitMQ) 交换,每个队列包含顺序很重要的消息。
我想select并按创建顺序处理最早声明的队列和进度。就像交换作为另一个队列一样。
如何在 AMQP 中实现这一点?
通过创建一个新队列来存储其他队列的唯一标识符来解决。由于它是 FIFO,因此项目按顺序放入队列。对于我们推送当前处理的队列的情况,我们只需再次推送相同的标识符 - 所以如果不是所有消息都得到处理,它们的处理将排队等候稍后。
我有一个与不同队列的 (RabbitMQ) 交换,每个队列包含顺序很重要的消息。
我想select并按创建顺序处理最早声明的队列和进度。就像交换作为另一个队列一样。
如何在 AMQP 中实现这一点?
通过创建一个新队列来存储其他队列的唯一标识符来解决。由于它是 FIFO,因此项目按顺序放入队列。对于我们推送当前处理的队列的情况,我们只需再次推送相同的标识符 - 所以如果不是所有消息都得到处理,它们的处理将排队等候稍后。