RabbitMQ：收到确认后将消息移动到另一个队列

Question

我有两个队列（没有交换），比如说队列 A 和队列 B。

一个解析器将消息放在队列 A 上，由 ElasticSearch RabbitMQ 河消费。

我现在想要的是当 ES 河向队列 A 发送 ack 时将消息从队列 A 移动到队列 B，这样我就可以在 ack 的消息中进行其他处理，确保 ES 已经处理他们。

RabbitMQ 有什么方法可以做到这一点吗？如果没有，是否有任何其他设置可以保证消息在被 ES 处理后仅在队列 B 中？

提前致谢

Answer 1

我认为 AMQP 或 rabbitmq extensions 都不支持此功能。

1. 您可以放下河流，让您的消费者也发布到 elasticsearch。

2. 由于正常行为是队列为空，您只需重试几次从 elasticsearch 读取条目（使用指数退避），因此即使 elasticsearch 失去初始竞争，它也会退避一点并且然后您可以执行任务。这可能需要调整客户端中的 prefetch_size/count。