快速入门

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。