Spring云流-并发

Question

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

Answer 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) {

    }

}

和

立即，不发送任何消息