rabbitmq - 使用 react\stomp 仅使用来自 RabbitMQ 的 N 条消息，分别确认它们然后退出

Question

我正在使用 RabbitMQ 和 PHP react\stomp。我有两个队列——一个是“todo”，另一个是“done”。消费者从“待办事项”中读取，完成它的工作，确认消息，然后将其发布到“完成”队列。

有什么方法可以确保我只使用来自“todo”的 N 条消息(并分别确认它们)然后退出？这样做的主要原因是我们不希望有长时间运行的消费者，我们希望在 N 条消息后重新启动它们。

Answer 1

您可以为目标设置预取计数:

The prefetch count for all subscriptions is set to unlimited by default. This can be controlled by setting the prefetch-count header on SUBSCRIBE frames to the desired integer count.

https://www.rabbitmq.com/stomp.html

所以要只使用十条消息，请添加 header

prefetch-count:10

到 SUBSCRIBE 框架。

您可以将 ack 模式设置为 client-individual 以逐条消息手动确认。