快速入門

Spring Cloud Bus 透過在類路徑上檢測到自身時新增 Spring Boot 自動配置來工作。要啟用匯流排,請將 spring-cloud-starter-bus-amqpspring-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 一起使用。