在我的應用程序中,我使用Spring雲流來集成Rabbit MQ。默認情況下,Spring雲流將創建目標作爲Rabbit MQ中類型主題的交換。如何配置春季雲流來創建類型扇出的交換?Spring Cloud Stream Rabbit MQ扇出交換
回答
- 您絕對應該從消費者端或代理商綁定您的隊列。這不應該是Spring Cloud流綁定器級別。爲了您的使用情況,你可以考慮結合鍵爲
#
:
當隊列綁定了「#」(哈希)結合鍵 - 它將收到的所有郵件,而不管路由關鍵的 - 就像在粉絲交流中一樣。
見https://www.rabbitmq.com/tutorials/tutorial-five-java.html
- 你仍然可以使用你的消費者需要的扇出交換,但同樣的代理綁定功能應參與綁定你的扇出交換這個SCST話題通過相同的
#
交換關鍵技巧。
謝謝@Artem Bilan。這是我提出的問題的替代解決方案/臨時解決方案。但完全符合我的要求 – auhuman
@Artem Bilan然後'Fanout'和'topic + routing key#'有什麼區別? – piechuckerr
在表演。 'Fanout'不會嘗試檢查'路由鍵'。 –
- 1. Golang Rabbit MQ扇出交換多個消費者
- 2. 交易處理Rabbit MQ和Spring AMQP
- 3. Spring Cloud Stream + Quartz
- 4. Spring Cloud Stream RabbitMQ
- 5. 如何使用Spring Cloud Stream Rabbit管理手動確認?
- 6. Spring Cloud Stream Kafka consumer with time based auto commit
- 7. Mono <>與Spring Cloud Stream
- 8. Spring Cloud Stream 1.0.0-RELEASE和Threads
- 9. spring-cloud-Hystrix Stream with just Ribbon
- 10. spring-cloud-stream kafka json content-type
- 11. Auto spawn rabbit mq listener
- 12. spring-cloud-stream生產者事務性
- 13. 在Rabbit MQ中切換路由
- 14. Spring-cloud-stream應用程序是否可以使用spring-boot?
- 15. 無法用spring-cloud-sleuth跟蹤spring-cloud-stream監聽器
- 16. spring-cloud-stream kafka錯誤處理
- 17. Spring Cloud Stream Kafka活頁夾壓縮
- 18. spring-cloud-stream-kafka配置:instanceCount&instanceIndex
- 19. Spring Cloud Stream - 編程式發佈
- 20. Spring Cloud Stream:無法將JSON數組轉換爲POJO列表
- 21. Spring Cloud Stream和RabbitMQ運行狀況檢查
- 22. 使用Spring Boot實現Rabbit MQ - (異步)RPC
- 23. Spring集成和Rabbit MQ:多個作業的聚合
- 24. 如何啓用使用雲代工的渦輪流Rabbit MQ服務
- 25. 何時通過扇出交換使用直接交換
- 26. 使用spring-cloud-dataflow時spring-cloud-stream應用中的屬性不起作用
- 27. 作爲一個應用程序的Spring Cloud Stream流
- 28. Spring Cloud/Stream/Spring Boot的依賴管理和發佈培訓
- 29. 如何退訂Rabbit Mq中的toppic?
- 30. Rabbit MQ Web UI隊列錯誤
請解釋你爲什麼需要'fanout'交換? –
我們有一個[未解決的問題](https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/34),以提供超過當前自由配置的更多選項。 –
@ArtemBilan話題需要路由模式。我的Producer應用程序是一個Java應用程序,我正在使用Spring Cloud Stream與Rabbit MQ集成。我的客戶應用程序是一個NodeJS應用程序,它訂閱隊列並將隊列綁定到由製作人創建的交換。但是當生產者向交易所發佈消息時,它不會進入隊列。隊列總是空的。我認爲一個隊列需要路由模式,而綁定到一個我無法使用spring雲流配置的交換。所以我正在使用工作正常的類型扇出交換 – auhuman