如何在 spring amqp (rabbitmq) 中动态增加消费者对象

Question

我有一个将消息发送到队列的发送器 class 和一个具有接收消息的方法的接收器 class，它工作正常。如果我向队列发送 10 条消息，这些消息将被 Receiver 成功使用。 现在的问题是如果我发送 1000 条消息然后单个接收者实例（对象） 处理 1000 条消息需要更多时间，然后我创建两个接收方实例以快速处理。它也工作正常，但我想动态地增加这个接收者对象，就像如果我的队列有超过 1000 条消息然后动态地，应该再创建一个接收者 class 的实例（对象）。 像工作队列

Answer 1

您使用的是 SimpleMessageListenerContainer 吗？如果是这样，您可以设置concurrentConsumers和maxConcurrentConsumers，它们会根据一些配置选项按需增加。

参见the documentation。