Spring Boot 的 ApplicationEvent + @EventListener 可实现轻量可靠异步解耦，但需显式配置 @EnableAsync、自定义线程池及 TransactionalEventListener(AFTER_COMMIT) 避免事务陷阱；跨服务场景应改用消息中间件。
直接用 Spring Boot 的 ApplicationEvent + @EventListener 就能实现轻量、可靠、开箱即用的异步事件解耦，不需要手写观察者列表或管理线程。
为什么不用自己实现 Subject/Observer 类
自己维护 observers 列表、调用 notify()、处理并发安全、支持异步、失败重试、事务边界……这些在 Spring Event 里全是现成的。手动实现容易踩坑：比如在事务未提交时就发事件，导致监听器查不到最新数据；或者没加 @Async，把耗时逻辑卡在主线程里。
- Spring 默认是同步执行监听器，
@EventListener方法和发布方在同一个线程、同一事务中 - 要异步，必须显式加
@Async，且确保配置了@EnableAsync - 若监听器依赖数据库最终一致性（如订单创建后发通知），需用
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
如何让监听器真正异步执行
只加 @Async 不够——Spring 的 @Async 默认使用 SimpleAsyncTaskExecutor，每次新建线程，不复用、无队列、无拒绝策略，压测时容易 OOM。必须配一个真正的线程池。
- 定义 Bean：
@Bean("taskExecutor") public Executor taskExecutor()，返回ThreadPoolTaskExecutor -
@EventListener方法上加@Async("taskExecutor")，指定执行器 - 线程池核心数建议设为 CPU 核数，队列类型选
LinkedBlockingQueue（避免无界内存增长） - 别忘了在主类或配置类上加
@EnableAsync，否则@Async不生效
事务内事件发布的陷阱
常见错误：在 @Transactional 方法里直接 publishEvent()，监听器立刻执行，但此时数据库还没 commit，查不到刚插入的记录。
- 解决方法是换用
@TransactionalEventListener，并指定phase = TransactionPhase.AFTER_COMMIT - 它底层靠 Spring 的事务同步器（
TransactionSynchronizationManager）注册回调，确保 commit 成功后再触发 - 注意：该注解仅对当前事务有效，跨服务调用或消息队列场景不适用
- 如果监听器本身也操作数据库，建议开启独立事务（
@Transactional(propagation = Propagation.REQUIRES_NEW)）
什么时候不该用 Spring Event
当模块间物理隔离（如不同 JVM、不同服务）、需要跨网络、要求高可靠或有重试/死信能力时，ApplicationEvent 就不合适了——它只在单 JVM 内有效，崩溃即丢失。
- 此时应切到消息中间件：RabbitMQ、Kafka 或 RocketMQ
- Spring 提供
spring-boot-starter-amqp和spring-kafka，API 风格和 Event 高度相似，迁移成本低 - 关键区别：事件发布即完成，不等消费结果；而消息发送后可确认、可重试、可持久化
最易被忽略的一点：Spring Event 的异步不是“自动”的，它是配置驱动的——漏配 @EnableAsync 或线程池 Bean，所有 @Async 都会退化成同步调用，问题在线上压测时才暴露。
