我们可以更改 rabbitmq 属性 spring 配置并流式传输 rabbit

Question

在我的 POC 中，我正在使用 Spring Cloud Config 和 Spring Stream Rabbit。我想动态更改侦听器的数量（并发）。有可能这样做吗？我想做以下事情：

1) 如果队列中的消息过多，我想提高并发级别。

2) 在我的下游系统不可用的情况下，我想停止处理来自队列的消息（简称并发级别 0）。

我怎样才能做到这一点？

感谢您的帮助。

Answer 1

binder中的listener容器运行支持这样的变化（虽然不能降到0，但是容器可以stop()ped）。

但是，spring-cloud-stream 没有提供任何机制让您获取对侦听器容器的引用。

您可能需要考虑改用 Spring AMQP 中的 @RabbitListener - 它会让您完全控制侦听器容器。