40. 快速入门
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 在 localhost 上时,你不需要做任何事情。如果您远程运行,请使用 Spring Cloud Connectors 或 Spring Boot 约定来定义 broker 凭据,如 Rabbit 的以下 example 所示:
application.yml.
spring:
rabbitmq:
host: mybroker.com
port: 5672
username: user
password: secret
bus 目前支持向所有侦听节点或特定服务的所有节点发送消息(由 Eureka 定义)。 /bus/*
actuator 命名空间有一些 HTTP endpoints。目前,有两个已实施。第一个/bus/env
发送 key/value 对来更新每个节点的 Spring 环境。第二个/bus/refresh
重新加载每个 application 的 configuration,就好像它们都已经被/refresh
端点所有。
Spring Cloud Bus starters 涵盖 Rabbit 和 Kafka,因为这是最常见的两个 implementations。但是,Spring Cloud Stream 非常灵活,binder 与
spring-cloud-bus
一起使用。