如何为 RabbitMQ 设置每个队列的内存限制？

Question

我有 3 个使用 RabbitMQ 的应用程序 A、B 和 C，其中我有队列 Q1 和 Q2。

1. 应用程序 A 在 Q1 中发布消息。

2. 应用程序 B 使用来自 Q1 的消息，进行一些处理，并在 Q2 中发布其他消息。 B 仅在 Q2 成功发布消息后才确认来自 Q1 的消息。

3. 应用程序 C 使用来自 Q2 的消息，进行一些处理并将某些内容写入数据库。

如果应用 A 发布的速度快于 B 的消耗速度，它最终会填满 RabbitMQ 服务器的内存或磁盘，will block any clients that try to publish messages。

B 在确认来自 Q1 的消息之前被阻止发布到 Q2，从而导致死锁。

如果我可以限制每个队列而不是整个 RabbitMQ 的内存和磁盘使用量，我认为这可以解决。 有没有办法做到这一点，或者其他方式来解决我的问题？

如果需要，我可以切换到另一个支持此类功能的消息代理。

Answer 1

不，设置每个队列的磁盘或内存限制不是在 RabbitMQ 中可以完成的（至少现在是这样）。

如果消息不会丢失并且是关键任务，则让应用程序 B 以与 A 相同或更快的速度进行消费，例如，通过增加消费者数量可能是解决方案。

另一种方法是通过Per-Queue Message TTL 或Queue Length Limit 丢弃额外消息。

当然，该消息可以是 dead-lettered 用于警报通知和/或备份。

您还可以不时检查队列长度并进行一些启发式方法来监控并关联您的工作流程（注意，queue.declare 将返回当前队列中的消息编号，但此 AMQP 方法本身是幂等的）。