45. 自定义消息 Broker

Spring Cloud Bus 使用Spring Cloud Stream来_b 广播消息。因此,要使消息流动,您只需要在 classpath 中包含您选择的 binder implementation。使用 AMQP(RabbitMQ)和 Kafka(spring-cloud-starter-bus-[amqp|kafka])的 bus 有方便的 starter。一般来说,Spring Cloud Stream 依赖于 Spring Boot 自动配置约定来配置中间件。例如,可以使用spring.rabbitmq.* configuration properties 更改 AMQP broker 地址。 Spring Cloud Bus 在spring.cloud.bus.*中有一些原生 configuration properties(对于 example,spring.cloud.bus.destination是 topic 的 name 用作外部中间件)。通常,默认值就足够了。

要了解有关如何自定义消息 broker 设置的更多信息,请参阅 Spring Cloud Stream 文档。