rabbitmq - Spring Cloud Bus，以更易读的方式重命名MQ

Question

我的 Cleint 有 2 个实例，我正在使用下面的代码段重命名队列，可以看到 testExchange.testQueue 已创建，我可以在其中看到 2 个消费者，即我的客户端实例，但是 /bus/refresh 我只能看到单个实例正在刷新而且我没有在 /bus/refresh 上获得 Cloud Bus 功能，即所有实例都应该刷新，如果我缺少任何配置以将队列重命名为可读格式，请告诉我。

spring:
 cloud:
   stream:
     bindings:
       springCloudBusInput:
         destination: testExchange
         group: testQueue
   config:
     bus:
       enabled: true
     uri: https://Config-Server-offshore.com/
     name: ClientApp

Answer 1

使用 spring-cloud-stream，使用group在同一个队列上创建竞争消费者。

如果您删除group每个实例将获得自己的队列。

您可以在组中使用占位符使其独一无二...

spring.cloud.stream.bindings.input.group=${instanceIndex}
instanceIndex=1

...如果您在 Cloud Foundry 上运行，则可以使用 vcap 实例索引。