spring cloud stream两个不同组的不同并发设置不起作用

问题描述 投票:0回答:1

我已经配置了默认并发设置,我有另一个需要不同并发级别的组,但第二个是默认的并发性为1。弹簧启动1.5.4和springCloudVersion Dalston.SR4工作得很好。当前版本是spring-boot 2.0.4,springCloudVersion是Finchley.SR1我使用的是rabbitMQ。

spring.cloud.stream.default.group=foo spring.cloud.stream.default.consumer.concurrency=3

我有另一个自定义组

spring.cloud.stream.bindings.customChannel.group=bar spring.cloud.stream.rabbit.bindings.customChannel.consumer.concurrency=5

组foo中的所有通道都是3.但是,customChannel的并发性默认为1.是否有人遇到类似的升级问题?

spring spring-boot spring-cloud spring-cloud-stream spring-rabbitmq
1个回答
1
投票

必须有其他事情发生;这对我来说很好:

@SpringBootApplication
@EnableBinding(So52172152Application.Foo.class)
public class So52172152Application {

    public static void main(String[] args) {
        SpringApplication.run(So52172152Application.class, args);
    }

    @StreamListener("one")
    public void listen1(String in) {

    }


    @StreamListener("two")
    public void listen2(String in) {

    }

    @StreamListener("three")
    public void listen3(String in) {

    }

    public interface Foo {

        @Input
        MessageChannel one();

        @Input
        MessageChannel two();

        @Input
        MessageChannel three();

    }

}

spring.cloud.stream.default.group=foo
spring.cloud.stream.default.consumer.concurrency=3

spring.cloud.stream.bindings.three.group=bar
spring.cloud.stream.bindings.three.consumer.concurrency=5

我在每个foo组队列中看到3个消费者,在bar组上看到5个消费者。

© www.soinside.com 2019 - 2024. All rights reserved.