快速入門
Spring Cloud Bus 透過在類路徑上檢測到自身時新增 Spring Boot 自動配置來工作。要啟用匯流排,請將 spring-cloud-starter-bus-amqp
或 spring-cloud-starter-bus-kafka
新增到您的依賴項管理。Spring Cloud 會處理剩下的事情。確保 broker(RabbitMQ 或 Kafka)可用並已配置。在 localhost 上執行時,您無需執行任何操作。如果遠端執行,請使用 Spring Cloud Connectors 或 Spring Boot 約定來定義 broker 憑據,如下面的 Rabbit 示例所示
application.yml
spring: rabbitmq: host: mybroker.com port: 5672 username: user password: secret
該匯流排當前支援將訊息傳送到所有正在偵聽的節點或特定服務的所有節點(由 Eureka 定義)。/bus*
執行器名稱空間具有一些 HTTP 端點。目前,實現了三個。第一個 /busenv
傳送鍵/值對以更新每個節點的 Spring 環境。第二個 /busrefresh
重新載入每個應用程式的配置,就像它們都在其 /refresh
端點上被 ping 過一樣。第三個 /busshutdown
傳送關閉事件以正常關閉應用程式例項。
Spring Cloud Bus 啟動器涵蓋 Rabbit 和 Kafka,因為這是兩個最常見的實現。但是,Spring Cloud Stream 非常靈活,並且 binder 可以與 spring-cloud-bus 一起使用。 |