1、简介
Spring Cloud Bus 是 Spring Cloud 的一个组件，用于在分布式系统中使用轻量级消息代理来传递消息。它使用轻量级消息代理（如 RabbitMQ 或 Kafka）来传递消息，并为各个服务之间的配置变更、路由信息等提供一种简单的分布式发布/订阅模式。
Spring Cloud Bus 是一个全局事件总线，通过 AMQP（高级消息队列协议）消息代理或 Redis 来链接 Spring Boot 应用程序。这使得在多个节点上运行的 Spring Boot 应用程序之间的通信变得简单而可靠，从而消除了重复代码和复杂的配置。
2、基本概念和用途
2.1、事件总线
Spring Cloud Bus 提供了一个全局事件总线，可以在应用程序之间广播事件。应用程序可以使用总线订阅事件，也可以发布事件到总线上。事件总线可以是 RabbitMQ 或 Kafka，也可以是基于 Redis 的简单实现。
2.2、消息代理
Spring Cloud Bus 使用轻量级消息代理（如 RabbitMQ 或 Kafka）来传递消息。它利用了这些消息代理提供的高吞吐量、高可靠性和多种语言支持的特性，来实现分布式系统中的事件通信。
2.3、分布式配置
Spring Cloud Bus 提供了一种简单的分布式配置方式，可以通过发布/订阅模式来实现各个服务之间的配置变更。例如，如果某个服务的配置发生了变化，它可以将这个变更发布到总线上，然后其他服务就可以订阅这个事件，并相应地更新它们的配置。
2.4、消息广播
Spring Cloud Bus 提供了一种简单的方式，让您可以广播消息到所有节点。您可以使用总线来发布一个消息，然后所有订阅了该消息的应用程序都会收到该消息。这对于通知所有应用程序进行某项操作非常有用。
3、示例
下面是一个示例，展示了如何使用 Spring Cloud Bus 在分布式系统中传递消息：
3.1、创建 Spring Boot 项目
首先，创建两个 Spring Boot 项目，一个作为消息的发布者，一个作为消息的订阅者。
3.2、添加依赖
在这两个项目的 pom.xml 文件中添加以下依赖：
代码语言：javascript复制<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>这将为项目添加 Spring Cloud Bus 的 AMQP 实现。
3.3、配置 RabbitMQ
在消息发布者和订阅者项目的 application.properties 文件中，添加 RabbitMQ 的配置信息，如下所示：
代码语言：javascript复制spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest3.4、创建消息发布在消息发布者项目中，创建一个 REST 接口，用于发布消息：
代码语言：javascript复制@RestController
public class MessageController {
@Autowired
private ApplicationContext context;
@PostMapping("/publish")
public void publishMessage(@RequestParam String message) {
context.publishEvent(new MyEvent(this, message));
}
}在这个示例中，我们创建了一个名为 MessageController 的 REST 控制器，并添加了一个名为 publishMessage 的方法。该方法接收一个字符串类型的参数 message，并使用 ApplicationContext 的 publishEvent 方法来发布一个名为 MyEvent 的事件。
3.5、创建消息订阅者
在消息订阅者项目中，创建一个事件监听器，用于订阅消息：
代码语言：javascript复制@Component
public class MyEventListener {
@EventListener
public void handleMessage(MyEvent event) {
System.out.println("Received message: " event.getMessage());
}
}在这个示例中，我们创建了一个名为 MyEventListener 的组件，并添加了一个名为 handleMessage 的方法，该方法使用 @EventListener 注解来订阅 MyEvent 事件，并在收到消息时打印消息内容。
3.6、测试应用程序
现在，我们可以启动这两个应用程序，并使用 REST 接口来发布消息。在消息发布者项目中，使用以下命令启动应用程序：
代码语言：javascript复制mvn spring-boot:run在消息订阅者项目中，使用以下命令启动应用程序：
代码语言：javascript复制mvn spring-boot:run然后，在消息发布者项目中，使用以下命令来发布消息：
代码语言：javascript复制curl -X POST http://localhost:8080/publish?message=Hello在消息订阅者项目的控制台中，应该会看到类似以下内容的输出：
代码语言：javascript复制Received message: Hello这表明订阅者已经成功订阅了消息，并且收到了发布者发布的消息。
