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