Spring 中处理异步的 4 个关键注解：一个订单接口的进化史

从一个订单接口说起

假设你在做一个电商项目，有一个创建订单的接口。业务逻辑很直白：保存订单、扣库存、发通知短信。

@RestController
@RequestMapping
public class OrderController {
@PostMapping
public Map createOrder {
// . 保存订单
orderService.save;// . 扣库存
inventoryService.deduct;// . 发通知短信
smsService.sendNotification,"订单已创建");return Map.of;}
}

痛点出现：测试说接口响应太慢——发短信这一步要调第三方 API。平均耗时 2-3秒，整个接口被拖慢了。

@Async: 把慢活扔到后台

没它之前

发短信是同步阻塞的。Tomcat 的工作线程在等短信 API 返回的这 2-3秒里什么都干不了——如果同时来了几百个请求，线程池很快就被打满了。

怎么用

两步操作：

1. 第一步先,在配置类或启动类上加 @EnableAsync:

2. 接下来。在需要异步执行的方法上加 @Async:

4. @Service
   public class SmsService {
   @Async
   public void sendNotification {
   System.out.println.getName
   + " | 开始发送短信...");// 模拟调用第三方短信 API
   try { Thread.sleep;} catch {}
   System.out.println;}
   }

Controller 不需要改动:

@PostMapping
public Map createOrder {
orderService.save;inventoryService.deduct;smsService.sendNotification,"订单已创建");// 异步执行了
return Map.of;}

"接口秒回，短信在后台慢慢发"

你需要知道的关键点:

• ⚠️ @Async 默认每次调用都创建新线程！生产环境必须配置线程池，否则会越开越多！:
• `ThreadPoolTaskExecutor` 配置示例:
• `setCorePoolSize` - 最小空闲线程数
• `setMaxPoolSize` - 最多可创建线程数
• `setQueueCapacity` - 队列大小
• `setRejectedExecutionHandler)` - 拒绝策略选择CallerRunsPolicy更安全!
"
• ⚠️ @Async 注解方法不能被同类中的其他方法直接调用!
"
• "如果 `sendNotification` 和调用它的方法在同一个类中,`@Async` 不会生效!"
"
⚠️ void返回值 + 异常处理极其关键!: "把 `void sendNotification` 改为返回 `CompletableFuture` 或 `Future` 并确保配置 `AsyncUncaughtExceptionHandler` 接入监控告警!" ✅ 生产级实践:"使用 `@EnableRetryableAopAspectJAutoProxy` 或结合重试机制,对失败任务进行重试!"

${title}: 按时间触发自动化任务

至于没它之前，

定时任务可能通过手动cron表达式管理或者依赖第三方工具。

需求场景这方面，

• 每天凌晨清理过期数据
• 每小时统计最近一小时的PV/UV数据

说到快速实现，

至于第一步先，

在启动类或配置类上添加 @EnableScheduling

从接下来来看。

使用三种方式定义定时任务:

java title="@Scheduled" public void taskByCron { ... }

// fixedRate方式: 上一次开始后5秒再执行 @Scheduled public void taskByFixedRate { ... }

❌ 常见错误与方法:

错误情况	原因分析	推荐方法
忽略上次未完成任务直接开始新周期	fixedRate特性导致	改用fixedDelay
大量积压未处理完毕的任务	前一次执行时间过长	添加并发控制
长时间运行导致内存泄漏	未释放资源/未清理缓存	添加finally块

✅ 常用方法:

一、添加异常处理:

java title="@Scheduled + try-catch-finally" public void safeTask { try{ ... } catch{ logger.error;// 添加补偿机制/重试逻辑/报警机制... } finally { // 一定要释放所有资源! } }

二、性能调整技巧:

• 对于I/O密集型操作:Thread.sleep换成非阻塞IO框架
• 数据库操作使用连接池
• 大批量数据操作采用分批+事务控制

三、监控与运维:

• 日志输出标准格式包含
• 添加超时监控和告警机制
• 提供手动触发功能
注意事项

❗️ 谨慎使用cron表达式中的'/'符号!❗️ 调整时间间隔记得先关闭服务!❗️ 测试环境和生产环境配置要区分!

第三招的观点是，@EventListener — 清爽版观察者模式

传统做法是让业务代码直接依赖各种通知服务。

说到消息冲突问题，

当多个模块需要获取相同事件通知时业务代码变得臃肿难维护。

再看动态解耦方案，

定义事件对象这方面。

java title="事件对象示例" record UserCreatedEvent {} // 或传统POJO风格也可工作正常: // public class UserCreatedEvent {...}

接下来通过ApplicationEventPublisher发布事件:

java title="@Transactional方法内部安全地发布事件" @Service class UserRegistrationService {

@Autowired ApplicationEventPublisher publisher;说起来，

@Transactional public void register{ userRepository.save;// 数据库操作... // 安全地将事件延迟到事物提交后才真正触发生效!TransactionSynchronizationManager.registerSynchronization( new TransactionSynchronization{ @Override public void afterCompletion{ if{ publishUserCreated;} } })，

private void publishUserCreated{ publisher.publishEvent( new UserCreatedEvent,info.getUsername));}

}

最终使用各种Listener监听不同阶段:

① 基础版本: java title="@Component + @EventListener" @Component public class EmailNotifier{ @EventListener void handle{...} }

② 高级版本: java title="@ConditionalOnProperty + @Order" @Component public class PremiumUserNotifier{ @Order @ConditionalOnProperty void handlePremium{...} }

③ 异常处理版本: java title="@Retryable + try-catch-finally" @Component public class SmsNotifier{ @Autowired private RetryTemplate retryTemplate;

void handleWithRetry{ retryTemplate.execute(context->{ try{...}catch{throw new RuntimeException;}})，}

// 其他异常处理策略... }

高级特性展示

特性名称	用途
@Ordered	控制定义使用者顺序
@Payload	获取包装对象中的内容
@BeanFactoryScope	动态生成使用者Bean

常用方法教程

🔹 原则: 假设所有监听器都是独立失败域!不要依赖其他监听器状态，🔹 容错: 每个监听器添加重试机制。🔹 防御: 在敏感数据字段上添加校验注解。🔹 清洁: 永远不要让监听器修改原始事件对象!

注意事项

❌ EventListener默认不支持并行!❌ 时间敏感业务慎用，❌ 大量事件可能引起内存问题!

至于第四招，@TransactionalEventListener — 金牌组合套餐

为什么需要它?

场景复现: 在传统方式中经常遇到这种问题...

当A服务向B服务请求某些资源失败后。A服务已经回滚事物,但B服务由于网络原因或者其他原因没有收到A服务回滚消息,导致两边状态不一致!

完美方法架构图

左侧传统方式容易出现二者状态不一致问题;说起来，右侧通过本地事物提交+远端最终一致性来保证强一致;

实战演示代码片段

准备四阶段基础结构:

① 确保已正确引入spring-boot-starter-aop依赖;

② 在主启动类上添加这两个必选注解:@EnableTransactionManagement 和@EnableAspectJAutoProxy

③ 配置全局事物超时时间:spring.transaction.timeout

④ 准备基础表结构和实体映射文件...

接下来编写主要原因部分:

kotlin title="#Kotlin伪代码演示主要流程"

@Service class OrderProcessing{

fun process{

// 第①阶段 初始化状态位 beginTransaction

transactional{ // JD娱乐事物范围

orderRepository.updateStatus updateInventory

// 第②阶段 预留补偿记录 localCompensationRepository.addPending( CompensationRecord)

// 第③阶段 本地提交 transaction.commit

// 第④阶段 异步补偿 triggerRemoteCompensationIfNeeded

private suspend fun triggerRemoteCompensationIfNeeded{ withContext{ if){ remotePaymentApi.cancelPayment localCompensationRepository.removePending} }

}}

最终完善容错机制部分:

① 局部补偿:@Retryable ② 全局熔断:@CircuitBreaker ③ 人工干预:@ConditionalOnExpression

高级玩法展示区域

★ 分布式锁防护:RedisLockManager#doWithLock ★ 集群友好设计:DistributedPropertySourceLocator ★ 整体链路追踪:TracePropagationInterceptor

思维导图

五大黄金规则与反例教学

🛠 工具箱必备利器:

- XRebel - JProfiler
- Gatling - JMeter
- ELK Stack - Graylog
- Kafkatool - RabbitMQ Management Plugin
- SpringBoot Actuator - Promeus Blackbox Exporter

---








规则#: 避免长轮询循环 限制最小轮询间隔为s		// ❌ 错误示例: while{ if) break;Thread.sleep;} // ✅ 改进版: int maxAttempts= for{ if) break; TimeUnit.SECONDS.sleep; }

---

高级模式参考集合 th/
模式名称 th/	典型场景 th/	主要价值 th/
Observer Pattern td/	多程序联动触发表情包生成 td/	降低程序耦合度 td/ tr/trtr/bgcolor="">	Command Pattern td/	支付程序撤销回滚 td/	支持撤销操作能力 td/ tr/trtr/bgcolor="">	Chain of Responsibility Pattern td/	权限校验链条验证 td/	职责明确隔离性好 td/

---

=参考架构选型矩阵:/tr/tr/trbgColor="#">	技术维度/th< /th>/tr/trbgColor="#"> /thbgColor="#"bgColor='#E6E6FA'width=/>/tr/tbody/tbody/tbody/ tbody/tbody/

---