Spring 云流 - 并发

Question

使用 Spring Cloud Stream Version 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) {

    }

}

和

立即，不发送任何消息

Spring 云流 - 并发

Spring Cloud Stream - Concurrency

spring-cloud-stream