spring-cloud-stream - Spring Cloud 流 : consume from default Rabbit MQ exchange and specific queue

Question

是否可以通过 Spring Cloud Stream 从某些隐式绑定(bind)到默认 RabbitMQ 交换器的特定队列进行消费？

正如我在 BindingService.bindConsumer(...) 中的调试中看到的，如果我将 destination 指定为 bindingTargets 字符串数组为空空字符串('' in yaml)，所以没有绑定(bind)消费者(binder.bindConsumer(...))发生。

我可能的解决方法是指定一些随机目的地并将标志 queueNameGroupOnly 设置为 true。

Answer 1

默认情况下，消费者使用路由键 # 将队列 destination.group 绑定(bind)到主题交换 destination。

参见 the documentation .

queueNameGroupOnly

When true, consume from a queue with a name equal to the group. Otherwise the queue name is destination.group. This is useful, for example, when using Spring Cloud Stream to consume from an existing RabbitMQ queue.

Default: false.

要从仅绑定(bind)到默认交换器的现有队列中消费，您需要。

spring.cloud.stream.bindings.input.destination=<doesn't matter, can be omitted; defaults to input>
spring.cloud.stream.bindings.input.group=<the name of the queue>
spring.cloud.stream.rabbit.bindings.input.consumer.bind-queue=false
spring.cloud.stream.rabbit.bindings.input.consumer.queue-name-group-only=true
spring.cloud.stream.rabbit.bindings.input.consumer.declare-exchange=false

queueNameGroupOnly 是专门为此用例添加的。