SpringBoot事件机制

一、简介

Spring Boot 的事件机制基于 Spring 框架的事件发布-订阅模型，允许应用在不同组件之间通过事件进行松耦合的通信。开发者可以发布自定义事件，并由监听器处理这些事件，从而实现业务逻辑的解耦，增强了代码的可维护性和扩展性。

二、优势 解耦：事件发布者和监听者之间无需直接依赖。扩展性：可轻松添加新事件和监听器。灵活性：支持同步和异步事件处理。 三、核心组件 ApplicationEvent： 所有事件的基类，自定义事件需要继承此类。例如：ApplicationStartingEvent, ApplicationReadyEvent 等。 ApplicationListener： 监听器接口，用于处理特定类型的事件。可以通过实现 ApplicationListener 接口或使用 @EventListener 注解来定义监听器。 ApplicationEventPublisher： 用于发布事件。Spring 容器会自动提供此接口的实现，开发者可以通过依赖注入来使用它。 四、内置事件

Spring Boot 提供了一些内置事件，这些事件在应用程序的生命周期中的不同阶段触发：

ApplicationStartingEvent：在应用启动时触发，但在任何处理之前。ApplicationEnvironmentPreparedEvent：在环境准备好后触发，但在上下文创建之前。ApplicationContextInitializedEvent：在应用上下文初始化后触发，但在任何 bean 定义加载之前。ApplicationPreparedEvent：在 bean 定义加载后触发，但在上下文刷新之前。ApplicationStartedEvent：在上下文刷新后触发，但在任何应用程序和命令行运行器调用之前。ApplicationReadyEvent：在应用程序准备就绪后触发，表示应用已启动并可以接收请求。ApplicationFailedEvent：在应用启动失败时触发。 五、事件机制的工作流程 定义事件：创建自定义事件类，继承 ApplicationEvent。发布事件：通过 ApplicationEventPublisher 发布事件。监听事件：通过 ApplicationListener 接口或 @EventListener 注解定义监听器。事件传播：Spring 容器将事件传播给所有匹配的监听器。处理事件：监听器接收到事件后，执行相应的处理逻辑。异步处理（可选）：通过 @Async 注解实现异步事件处理。 六、自定义事件

定义事件：继承 ApplicationEvent。

public class CustomEvent extends ApplicationEvent { private String message; public CustomEvent(Object source, String message) { super(source); this.message = message; } public String getMessage() { return message; } }

发布事件：使用 ApplicationEventPublisher。

@Autowired private ApplicationEventPublisher publisher; public void publishEvent(String message) { publisher.publishEvent(new CustomEvent(this, message)); }

监听事件：实现 ApplicationListener 或使用 @EventListener 注解。

// 实现 ApplicationListener 接口 @Component public class CustomEventListener implements ApplicationListener<CustomEvent> { @Override public void onApplicationEvent(CustomEvent event) { System.out.println("Received event: " + event.getMessage()); } } // 使用注解： @Component public class CustomEventListener { @EventListener public void handleCustomEvent(CustomEvent event) { System.out.println("Received event: " + event.getMessage()); } } 七、异步事件

Spring 支持异步事件处理，可以通过 @Async 注解来实现：

启用异步支持：

在配置类上添加 @EnableAsync 注解。 @Configuration @EnableAsync public class AsyncConfig { }

定义异步监听器：

在监听器方法上添加 @Async 注解。 @Component public class CustomEventListener { @EventListener @Async public void handleCustomEventAsync(CustomEvent event) { System.out.println("Received async event: " + event.getMessage()); } }