在运行时向rabbit侦听器动态添加队列

Question

我有一个项目，我们将在rabbit中有数百个（可能数千个）队列，每个队列都需要一个消费者池来使用。

在rabbit（使用spring amqp）中，您有rabbitlistener注释，它允许我静态地分配这个特定消费者将处理的队列。

我的问题是，对于rabbit和spring，是否有一种干净的方法可以让我获取一段队列（比如以a-c开头的队列），然后还可以侦听消费者运行时创建的任何队列。

示例（开始时）：

• 蚂蚁队列
• 苹果队列
• 猫队列

消费者运行时：

• 添加bat队列

这是我目前拥有的（非常简单的）代码：

    @Component
    public class MessageConsumer {

        public MessageConsumer() {
            // ideally grab a section of queues here, initialize a parameter and give to the rabbitlistener annotation
        }

        @RabbitListener(queues= {"ant-queue", "apple-queue", "cat-queue"})
        public void processQueues(String messageAsJson) {
            < how do I update the queues declared in rabbit listener above ? >
        }
    }

编辑：

我应该补充一点，我已经浏览了我在网上找到的spring amqp文档，除了静态（硬编码或通过属性）声明队列之外，我没有找到任何东西

Answer 1

>

注入（@自动连线或其他方式）RabbitListenerEndpointRegistry。

获取对监听器容器的引用（使用注释上的id属性为其提供一个已知的id）（registry.getListenerContainer（id））。

将容器强制转换为AbstractMessageListenerContainer，并调用addQueues（）或addQueueNames（）。

请注意，在动态添加队列时，使用DirectMessageListenerContainer更有效；使用SimpleMessageListenerContainer，消费者将停止并重新启动。使用直接容器，每个队列都有自己的使用者。

请参见选择容器。