配置@JmsListener 以限制消息速率

Question

我已经实现@JmsListener 来监听来自Producer 的消息。

APP <- Consumer <- Producer

所以，如上所示，Consumer 正在消费来自生产者的消息并调用应用程序（APP）来处理这些消息，在这种情况下应用程序很慢，我们想限制我们从队列 @9​​87654324@ 消费的消息的速率

 @JmsListener(
       containerFactory = XXX destination = XXX)   public void receive(Message message) throws JMSException {
       }

找到限制Producer消息速率的方法，可以通过限制订阅或并发的东西来完成，但没有找到任何支持@JmsListener注解

Answer 1

有一个@JmsListener concurrency 选项：

侦听器的并发限制（如果有）。覆盖值 由用于创建侦听器的容器工厂定义 容器。

并发限制可以是“上下”字符串——例如， “5-10”——或简单的上限字符串——例如，“10”，其中 如果下限为 1。

请注意，底层容器可能支持也可能不支持所有 特征。例如，它可能无法扩展，在这种情况下 只使用上限。