40. 快速入门

Spring Cloud Bus 的工作原理是,如果它在 classpath 上检测到自身,则添加 Spring Boot 自动配置。要启用 bus,请将spring-cloud-starter-bus-amqpspring-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一起使用。