配置
最后，我们需要为Spring在 Spring Cloud Bus 中，我们还可以发送自定义事件，这些事件将被传递给所有订阅者，订阅者可以监听并进行处理。
首先，我们需要创建一个自定义事件类。假设我们要创建一个事件类来表示订单支付完成事件：
代码语言：javascript复制public class OrderPaidEvent {
private Long orderId;
private BigDecimal amount;
public OrderPaidEvent(Long orderId, BigDecimal amount) {
this.orderId = orderId;
this.amount = amount;
}
public Long getOrderId() {
return orderId;
}
public BigDecimal getAmount() {
return amount;
}
}接下来，我们需要在应用程序中发布该事件。我们可以使用 Spring Framework 提供的 ApplicationEventPublisher 接口来发布事件。在 Spring Boot 应用程序中，我们可以直接在 Bean 中注入该接口：
代码语言：javascript复制@RestController
public class PaymentController {
@Autowired
private ApplicationEventPublisher applicationEventPublisher;
@PostMapping("/pay")
public String pay(@RequestBody PaymentRequest request) {
// do payment
// ...
// publish order paid event
applicationEventPublisher.publishEvent(new OrderPaidEvent(request.getOrderId(), request.getAmount()));
return "Payment success!";
}
}在上面的代码中，当用户提交支付请求时，我们将创建 OrderPaidEvent 对象并使用 ApplicationEventPublisher.publishEvent() 方法将其发布。当该事件被发布时，Spring Cloud Bus 将会接收到该事件，并将其传播给所有订阅者。
最后，我们需要在订阅者应用程序中处理该事件。我们可以定义一个事件监听器来处理该事件。在 Spring Boot 应用程序中，我们可以使用 @EventListener 注解来定义事件监听器：
代码语言：javascript复制@Component
public class OrderPaidEventListener {
private static final Logger LOGGER = LoggerFactory.getLogger(OrderPaidEventListener.class);
@EventListener
public void handleOrderPaidEvent(OrderPaidEvent event) {
LOGGER.info("Received OrderPaidEvent: orderId={}, amount={}", event.getOrderId(), event.getAmount());
// process the event
// ...
}
}在上面的代码中，我们定义了一个名为 OrderPaidEventListener 的事件监听器，并使用 @EventListener 注解标记了一个名为 handleOrderPaidEvent() 的方法。当 OrderPaidEvent 事件被发布时，该方法将会被调用。
在方法中，我们可以获取事件的数据并进行处理。例如，在上面的代码中，我们只是简单地记录了事件的 orderId 和 amount 属性。
到这里，我们就完成了在 Spring Cloud Bus 中传递自定义事件的演示。通过使用自定义事件，我们可以在不同的服务之间传递复杂的消息，从而实现更多的应用场景。
