春季雲流與兔活頁夾 - 源/匯隊列名稱不匹配

Question

最近，我開始玩Spring Cloud Stream和RabbitMQ活頁夾。

如果我正確理解的一切，當兩個服務想傳遞消息，一個應該配置源用於發送消息和其他應配置水槽用於接收消息 - 兩者都應該使用相同的信道。

我有頻道取名爲testchannel。我注意到，雖然，源創建RabbitMQ的結合：

• 交換testchannel，
• 路由關鍵testchannel，
• 隊列testchannel.default（耐久），

而沉創建的RabbitMQ綁定：

• 交換testchannel，
• 路由密鑰#，
• 隊列testchannel.anonymous.RANDOM_ID（excusive）。

爲了簡潔起見，我跳過了前綴。

現在，當我運行這兩個應用程序。第一個發送消息到testchannel交換，然後路由到這兩個隊列（我假設路由密鑰是testchannel）。第二個應用程序使用來自隨機隊列的消息，但來自默認隊列的消息永遠不會消耗。

我的另一個問題是 - 2應用程序只使用沉，但它也創造了輸出渠道，這是output默認綁定，因爲我還沒有任何規定。

我建立具有相同搖籃腳本這兩個應用：

buildscript { 
    ext { 
     springBootVersion = '1.3.2.RELEASE' 
    } 
    repositories { 
     mavenCentral() 
    } 
    dependencies { 
     classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}") 
    } 
} 

apply plugin: 'java' 
apply plugin: 'spring-boot' 

repositories { 
    mavenCentral() 
    maven { url 'https://repo.spring.io/snapshot' } 
    maven { url 'https://repo.spring.io/milestone' } 
} 

dependencies { 
    compile(
      'org.springframework.cloud:spring-cloud-starter-stream-rabbit', 
    ) 
} 

dependencyManagement { 
    imports { 
     mavenBom "org.springframework.cloud:spring-cloud-dependencies:Brixton.BUILD-SNAPSHOT" 
    } 
} 

第一應用特性：

server.port=8010 
spring.cloud.stream.binder.rabbit.default.prefix=z. 
spring.cloud.stream.bindings.input=start 
spring.cloud.stream.bindings.output=testchannel 
spring.rabbitmq.addresses=host1:5672,host2:5672 
spring.rabbitmq.username=user 
spring.rabbitmq.password=psw 

最前一頁應用程序的源代碼：

@EnableBinding(Processor.class) 
... 
@ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT) 
public byte[] handleIncomingMessage(byte[] payload) {} 

第二應用特性：

server.port=8011 
spring.cloud.stream.binder.rabbit.default.prefix=z. 
spring.cloud.stream.bindings.input=testchannel 
spring.rabbitmq.addresses=host1:5672,host2:5672 
spring.rabbitmq.username=user 
spring.rabbitmq.password=psw 

第二應用的源代碼：

@EnableBinding(Sink.class) 
... 
@ServiceActivator(inputChannel = Sink.INPUT) 
public void handleIncomingMessage(byte[] payload) {} 

所以我的問題是。

• 不應源和水槽使用相同的信道和作爲導致相同的代理隊列？什麼是適當的配置來實現這一目標？ （我的目標是有多個接收器服務實例，但只有一個應該消費該消息。）
• 框架創建輸出綁定當我只使用水槽？如果是的話，如何禁用它。

Answer 1

默認情況下;消費者各自獲得自己的隊列;這是一個發佈/訂閱場景。

有一個消費者的概念group所以你可以讓多個實例競爭來自同一隊列的消息。

綁定生產者時，默認隊列被綁定。如果您想訂閱default組;你必須設置組：

spring.cloud.stream.bindings.input.group=default 

如果不提供一組，你會得到一個排他性的，自動刪除隊列。

編輯

由於默認隊列是持久的，你還應該設置

spring.cloud.stream.bindings.input.durableSubscription=true 

避免警告當消費者結合並確保隊列是持久的，如果消費者結合第一併且該隊列還不存在。