39. 快速入门

Spring Cloud Bus 的工作原理是,如果它在 classpath 上检测到自身,则添加 Spring Boot 自动配置。启用 bus 所需要做的就是将spring-cloud-starter-bus-amqpspring-cloud-starter-bus-kafka添加到您的依赖 management 和 Spring Cloud 来处理 rest。确保 broker(RabbitMQ 或 Kafka)可用并配置:running on localhost 您不必执行任何操作,但如果您远程运行 Spring Cloud Connectors,或 Spring Boot 约定来定义 broker 凭据,e.g. 为 Rabbit

application.yml.

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

bus 目前支持向所有侦听节点或特定服务的所有节点发送消息(由 Eureka 定义)。将来可以添加更多选择器标准(即,仅数据中心 Y 中的服务 X 节点等)。 /bus/* actuator 命名空间下还有一些 http endpoints。目前有两个已实施。第一个/bus/env发送 key/value 对来更新每个节点的 Spring 环境。第二个/bus/refresh将重新加载每个 application 的 configuration,就好像它们都已经被 ping 到了/refresh端点一样。

Bus starters 涵盖了 Rabbit 和 Kafka,因为它们是两个最常见的 implementation,但 Spring Cloud Stream 非常灵活,binder 将与spring-cloud-bus结合使用。