【问题标题】:Spring Cloud Stream - ConcurrencySpring Cloud Stream - 并发
【发布时间】:2018-02-23 17:25:34
【问题描述】:

使用 Spring Cloud Stream 版本 Chelsea.SR2,将 RabbitMQ 作为消息代理。要拥有多个消费者,我们使用属性并发(入站消费者的并发)。
如果我们将并发设置为 50。它从 1 开始,慢慢地增加消费者数量。是否有任何可能的解决方案以更高的数字而不是一个来启动初始消费者计数以提高消费者性能。

【问题讨论】:

    标签: spring-cloud-stream


    【解决方案1】:

    你能展示你的配置吗?我刚刚对其进行了测试,它完全符合预期......

    spring.cloud.stream.bindings.input.group=foo
    spring.cloud.stream.bindings.input.consumer.concurrency=10
    

    @SpringBootApplication
    @EnableBinding(Sink.class)
    public class So48953227Application {
    
        public static void main(String[] args) {
            SpringApplication.run(So48953227Application.class, args);
        }
    
        @StreamListener(Sink.INPUT)
        public void listen(String in) {
    
        }
    
    }
    

    立即,不发送任何消息

    【讨论】:

      猜你喜欢
      • 2016-06-21
      • 2021-12-13
      • 2021-06-12
      • 2017-03-26
      • 2018-01-24
      • 1970-01-01
      • 1970-01-01
      • 2020-10-24
      • 1970-01-01
      相关资源
      最近更新 更多