Spring Cloud Stream-例程KeyExpress属性不起作用

Question

我正在使用带有RabbitMQ的Spring Cloud stream。（Spring cloud版本是Greenwich）我有一个主题和两个队列，我想使用路由键向每个队列发送消息。

但它不能正常工作。

当我通过每个@输出通道发送消息时，消息会同时发送到两个队列。（我希望1个队列有1条消息，但1条消息会转到2个队列）

我的生产者配置如下（实际代码为yaml）

Spring.cloud.stream.bindings.output1.destination=topic-a
Spring.cloud.stream.bindings.output1.producer.requiredGroups=queue1
Spring.cloud.stream.bindings.output1.producer.bindingRoutingKey=queue1
Spring.cloud.stream.bindings.output1.producer.routingKeyExpression=queue1

Spring.cloud.stream.bindings.output2.destination=topic-a
Spring.cloud.stream.bindings.output2.producer.requiredGroups=queue2
Spring.cloud.stream.bindings.output2.producer.bindingRoutingKey=queue2
Spring.cloud.stream.bindings.output2.producer.routingKeyExpression=queue2

我的消费者配置在下面

spring.cloud.stream.bindings.input1.destination=topic-a
spring.cloud.stream.bindings.input1.group=queue1
spring.cloud.stream.bindings.input1.consumer.durableSubscription=true
spring.cloud.stream.bindings.input1.consumer.bindingRoutingKey=queue1

spring.cloud.stream.bindings.input2.destination=topic-a
spring.cloud.stream.bindings.input2.group=queue2
spring.cloud.stream.bindings.input2.consumer.durableSubscription=true
spring.cloud.stream.bindings.input2.consumer.bindingRoutingKey=queue2

我也尝试没有要求的Gorup和bindingRoutingKey只留下在生产者配置中的例程KeyExpress单独。

我在yaml中为“queue1”或“queue1”提供了例程KeyExpress值。

如果我发送带有output1的“第一条”消息和带有output2的“第二条”消息，

“first”和“second”消息位于topic-a.queue1中。（路由键显示为“topic-a”），而topic-a.queue2中也有相同的两条消息。

共生成4条消息。

我怎么了？

任何帮助都将不胜感激。

Answer 1

您缺少。rabbitmq特定粘合剂属性的rabbitmq元素。

请参阅文档。

以下属性仅适用于Rabbit生产者，并且必须以spring作为前缀。云流动兔子绑定。