自动生成兔子 mq 侦听器

Question

我正在开发一个应用程序，其中我在 rabbit mq 队列上有一个侦听器。根据消息的种类，侦听器继续执行任务。我的问题是，如果单个侦听器无法处理队列，我需要一种方法来生成新的侦听器。据我所知，我可以使用 rabbitmq json api 找到队列的 len 并根据它采取行动。因此，我编写了一个脚本，使用 curl 检查队列长度并生成一个新的侦听器进程。我走在正确的道路上吗？有没有更好的方法来实现这一目标？我正在寻找一种至少可以随负载扩展到一定限度的解决方案。

Answer 1

检查 RabbitMQ API 以查看队列的长度是一种方法，而且肯定有效。

您应该尝试预测负载何时激增，以便您可以在需要时慢慢增加消费者数量，这样您就不会看到实例生成突然激增。同时生成多个实例可能会给您的系统带来不必要的负载。