39. 快速入门
Spring Cloud Bus 的工作原理是,如果它在 classpath 上检测到自身,则添加 Spring Boot 自动配置。启用 bus 所需要做的就是将spring-cloud-starter-bus-amqp
或spring-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
结合使用。