43. 自定义消息 Broker

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

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