クイックスタート

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 エンドポイントがあります。現在、3 つが実装されています。最初の /busenv は、キーと値のペアを送信して、各ノードの Spring 環境を更新します。2 番目の /busrefresh は、すべてのアプリケーションが /refresh エンドポイントで ping されたかのように、各アプリケーションの構成を再読み込みします。3 番目の /busshutdown は、シャットダウンイベントを送信して、アプリケーションインスタンスを正常にシャットダウンします。

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