Spring Cloud Bus 是 Spring Cloud 微服务框架中的一个组件，可以用于在微服务之间传递消息，从而实现微服务之间的协调和通信。
传递消息
在微服务之间传递消息，需要使用 Spring Cloud Bus 提供的 MessageSender 接口。MessageSender 接口提供了发送消息的方法，可以发送任意类型的消息。
首先，我们需要定义一个消息类型，例如：
代码语言：javascript复制public class MyMessage implements Serializable {
private static final long serialVersionUID = 1L;
private String content;
public MyMessage(String content) {
this.content = content;
}
public String getContent() {
return content;
}
public void setContent(String content) {
this.content = content;
}
}在这个例子中，我们定义了一个 MyMessage 类型，该类型包含一个字符串类型的 content 属性，表示消息内容。
然后，在需要发送消息的微服务中，可以使用 Spring Cloud Bus 提供的 MessageSender 接口来发送消息，例如：
代码语言：javascript复制@RestController
public class MyController {
@Autowired
private MessageSender messageSender;
@PostMapping("/send")
public void sendMessage(@RequestBody MyMessage message) {
messageSender.send(new GenericMessage<>(message));
}
}在这个例子中，MyController 中的 sendMessage 方法会使用 MessageSender 接口发送消息，该方法接受一个 MyMessage 类型的参数 message，表示要发送的消息。在实际应用中，我们可以将消息封装成一个对象，然后将对象作为参数传递给 sendMessage 方法。
接收消息
在微服务中接收消息，需要使用 Spring Cloud Bus 提供的 @StreamListener 注解。@StreamListener 注解用于标记一个方法，表示该方法用于处理接收到的消息。
首先，我们需要定义一个消息监听器，例如：
代码语言：javascript复制@Component
public class MyMessageListener {
@StreamListener(target = Sink.INPUT)
public void handleMessage(MyMessage message) {
System.out.println("Received message: " message.getContent());
}
}在这个例子中，MyMessageListener 中的 handleMessage 方法使用 @StreamListener 注解标记，表示该方法用于处理接收到的消息。@StreamListener 注解中的 target 属性指定了要监听的消息队列名称，例如 Sink.INPUT 表示监听输入队列。
当有消息到达输入队列时，Spring Cloud Bus 会自动调用 handleMessage 方法，传递消息作为参数。在 handleMessage 方法中，我们可以对接收到的消息进行处理，例如打印消息内容。
配置 Spring Cloud Bus
在使用 Spring Cloud Bus 时，需要在应用程序中添加 Spring Cloud Bus 的依赖，例如：
代码语言：javascript复制<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bus-amqp</artifactId>
<version>2.2.1.RELEASE</version>
</dependency>这个例子中，我们使用 Spring Cloud Bus 与 RabbitMQ 作为消息代理。因此，需要添加 spring-cloud-starter-bus-amqp 依赖，该依赖包含了 Spring Cloud Bus 和 RabbitMQ 的相关依赖。
在应用程序中配置 Spring Cloud Bus，需要在 application.properties 或 application.yml 文件中添加以下配置：
代码语言：javascript复制spring:
cloud:
bus:
enabled: true
stream:
bindings:
input:
destination: my-destination
rabbit:
bindings:
input:
consumer:
bindingRoutingKey: my-routing-key在这个例子中，我们配置了 Spring Cloud Bus 和 RabbitMQ 的相关属性。其中，cloud.bus.enabled 属性指定启用 Spring Cloud Bus，stream.bindings.input.destination 属性指定了要监听的队列名称，rabbit.bindings.input.consumer.bindingRoutingKey 属性指定了队列绑定的路由键。
在应用程序启动时，Spring Cloud Bus 会自动与 RabbitMQ 建立连接，并监听指定的队列。当有消息到达队列时，Spring Cloud Bus 会自动调用消息监听器中的方法，处理接收到的消息。
