最新の安定バージョンについては、spring-cloud-bus 5.0.2 を使用してください。

クイックスタート

Spring Cloud Bus は、クラスパス上でそれ自体を検出した場合、Spring Boot 自動構成を追加することで機能します。バスを有効にするには、spring-cloud-starter-bus-amqp または spring-cloud-starter-bus-kafka を依存関係管理に追加します。残りは Spring Cloud が処理します。ブローカー (RabbitMQ または Kafka) が利用可能で構成されていることを確認してください。localhost で実行する場合は、何もする必要はありません。リモートで実行する場合は、次の Rabbit の例に示すように、Spring Cloud Connectors または Spring Boot の規則を使用してブローカーの資格情報を定義します。

application.yml

spring:
  rabbitmq:
    host: mybroker.com
    port: 5672
    username: user
    password: secret

現在、バスは、リッスンしているすべてのノード、または特定のサービス (Eureka で定義されている) のすべてのノードへのメッセージの送信をサポートしています。/bus/* アクチュエーターの名前空間には、いくつかの HTTP エンドポイントがあります。現在、2 つが実装されています。最初の /bus/env は、キーと値のペアを送信して、各ノードの Spring 環境を更新します。2 番目の /bus/refresh は、あたかも /refresh エンドポイントですべてのアプリケーションが ping されたかのように、各アプリケーションの構成をリロードします。

Spring Cloud Bus スターターは Rabbit と Kafka をカバーしています。これら 2 つは最も一般的な実装です。ただし、Spring Cloud Stream は非常に柔軟であり、バインダーは spring-cloud-bus で動作します。