Spring Boot事件机制
Spring框架的事件处理是其核心特性之一，通过ApplicationEvent类和ApplicationListener接口实现。在Spring Boot应用中，事件机制是实现模块间消息传递的重要方式，通常用于业务逻辑内部通信。
内置事件类型
Spring应用上下文在启动时会触发多种内置事件：
- ContextRefreshedEvent：上下文刷新完成时触发
- ContextStartedEvent：上下文启动后触发
- ApplicationReadyEvent：应用准备就绪时触发（此时CommandLineRunner/ApplicationRunner已执行）
- ApplicationFailedEvent：应用启动失败时触发
这些事件形成完整的生命周期监控体系，开发者可以通过监听这些事件实现初始化逻辑。例如监听ApplicationReadyEvent可确保所有Bean初始化完成后再执行特定操作。
自定义事件开发流程
标准的事件处理包含四个关键步骤：
- 定义事件类：继承ApplicationEvent基类
public class CustomEvent extends ApplicationEvent {private String message;public CustomEvent(Object source, String message) {super(source);this.message = message;}
}
- 发布事件：实现ApplicationEventPublisherAware接口
@Service
public class EventPublisherService implements ApplicationEventPublisherAware {private ApplicationEventPublisher publisher;@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher publisher) {this.publisher = publisher;}public void publishEvent(String message) {publisher.publishEvent(new CustomEvent(this, message));}
}
- 创建监听器：实现ApplicationListener接口
@Component
public class CustomEventListener implements ApplicationListener {@Overridepublic void onApplicationEvent(CustomEvent event) {System.out.println("Received: " + event.getMessage());}
}
简化开发模式
Spring提供了更简洁的注解驱动方式：
@Component
public class AnnotatedEventListener {@EventListenerpublic void handleCustomEvent(CustomEvent event) {// 处理事件逻辑}@Async@EventListenerpublic void asyncEventHandler(CustomEvent event) {// 异步处理逻辑}
}
通过@EventListener注解可自动注册监听器，结合@Async实现异步处理。这种声明式编程模式大幅减少了样板代码。
实战案例：用户状态事件
以下示例展示用户状态变更的事件处理实现：
- 定义事件对象：
@Data
@AllArgsConstructor
public class UserActivatedEvent {private String email;private boolean active;
}
- 事件发布：
@Service
public class UserService {private final ApplicationEventPublisher publisher;public void updateUserStatus(String email, boolean active) {publisher.publishEvent(new UserActivatedEvent(email, active));}
}
- 事件监听：
@Slf4j
@Component
public class UserEventLogger {@EventListenerpublic void logActivation(UserActivatedEvent event) {log.info("用户{}状态变更为：{}", event.getEmail
)
