使用Spring云流将RabbitMQ使用者绑定到现有队列

Question

我使用RabbitMQ网络创建了一个主题交换UITX并绑定到交换两个队列TX. Q1和TX. Q2，每个队列都相应地绑定了路由密钥rk1和rk2，并向交换产生了少量消息。

现在，我想使用Spring Cloud Stream创建一个消费者，它只从Q1获取消息。我尝试使用配置：

spring.cloud.stream.bindings.input.destination=TX
spring.cloud.stream.bindings.input.group=Q1

以及使用消息的方法的注释@StreamListner（Sink. INPUT）。

因此，我可以看到使用者创建了一个同名TX.Q1的队列（或绑定），但新队列/绑定的路由键是#
如何通过Spring Cloud Stream配置一个消费者，该消费者将使用预定义队列中的消息（仅使用rk1路由的消息）。

Answer 1

Spring Cloud Stream在内部将消费者endpoint的路由器密钥设置为目标名称（交换名称）本身，或者在静态分区的情况下基于分区标头的路由。

我认为这个github问题可能与您的案例有关。

Answer 2

我想我是使用StreamListener找到了解决方案，而不是使用变通方法。一切都是在配置中完成的，而不是在代码中。

我使用的配置如下所示（它位于.yml中，但您可以轻松地将其转换为.properties）：

spring:
  cloud:
    stream:
      bindings:
        input:
          binder: <binder_name>
          destination: TX
          group: Q1
      binders:
        <binder_name>:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                host: <host>
                port: <port>
                virtual-host: <vhost>
                username: <username>
                password: <password>
      rabbit:
        bindings:
          input:
            consumer:
              binding-routing-key: rk1
              exchange-name: TX
              queue-name-group-only: true
              bind-queue: true
              exchange-durable: true
              exchange-type: topic

使用这种方法，您不必编写特定的代码来让RabbitMQ使用者连接到您的集群，这应该可以解决您的问题。

希望这有帮助。

Answer 3

所以现在，加里·拉塞尔建议的解决方案已经为我解决了这个问题

我用RabbitListener代替了streamlistener（绑定=@QueueBinding（value=@Queue（value=“TX.Q1”，durable=“true”）、exchange=@exchange（value=“TX”，type=“topic”，durable=“true”）、key=“rk1”）

因此，预定义队列TX.Q1使用绑定键rk1绑定到exchange TX。

正在等待Spring Cloud Steream问题的更新。