本文介绍如何在保证 web 请求快速响应的前提下，确保订单异步处理逻辑严格按顺序、单线程执行，避免并发导致的数据竞争与重复提交问题。
本文介绍如何在保证 web 请求快速响应的前提下，确保订单异步处理逻辑严格按顺序、单线程执行，避免并发导致的数据竞争与重复提交问题。
在 Spring Boot 应用中，常需满足「快速响应客户端 + 异步后台处理」这一典型需求。但若异步任务本身存在共享状态（如数据库写入、库存扣减、幂等校验等），盲目使用 @Async 可能引发严重的竞态条件（race condition）——例如两个几乎同时到达的订单被并发执行 processJsonOrder()，导致重复插入或业务逻辑错乱，即使有数据库唯一约束，也可能因事务未提交而失效。
直接在 @Async 方法上加 synchronized 是无效的：因为 @Async 默认使用线程池（如 SimpleAsyncTaskExecutor 或 ThreadPoolTaskExecutor）派发新线程，而 synchronized 实例方法锁的是当前对象实例（this），多个线程调用同一 Bean 的 synchronized 方法时，若 Bean 是单例（Spring 默认作用域），确实能互斥；但该方案存在严重缺陷：
- ❌ 阻塞线程池资源：一个长耗时订单会独占一个线程，拖慢整个线程池；
- ❌ 违背异步初衷：虽“非阻塞 Controller”，但后端处理仍串行化且无队列管理能力；
- ❌ 缺乏可观测性与容错：失败任务无法重试、无监控、无积压告警。
✅ 更优雅、生产就绪的解决方案是：使用消息队列（如 RabbitMQ/Kafka）或内存级串行任务队列（如 ExecutorService 配置单线程池）解耦并强制顺序执行。
推荐采用 Spring 内置的 TaskExecutor 自定义单线程异步执行器，兼顾简洁性与可控性：
@Configuration
public class AsyncConfig {
@Bean("sequentialOrderExecutor")
public Executor sequentialOrderExecutor() {
return Executors.newSingleThreadExecutor(r -> {
Thread t = new Thread(r, "sequential-order-processor");
t.setDaemon(false); // 确保 JVM 退出前完成任务
return t;
});
}
}
然后在 Service 中显式指定该执行器，并移除 @Async 的类级别代理干扰：
@Service
public class OrderService {
@Transactional
public void processJsonOrder(WoocommerceOrder wcOrder) {
// 核心业务逻辑：校验、转换、保存、通知等
// 此处不加 synchronized —— 执行器已保证单线程串行
}
// 包装为可被 Controller 调用的异步委托方法
@Async("sequentialOrderExecutor")
public void asyncProcessOrder(WoocommerceOrder wcOrder) {
processJsonOrder(wcOrder);
}
}
Controller 改为安全调用：
@RestController
public class WebShopOrderController {
@Autowired
private OrderService orderService;
@PostMapping(value = "/wc-order", consumes = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<void> getWcOrder(@RequestBody String jsonOrder,
@RequestHeader Map<string string> headers) {
log.info("Order received");
try {
WoocommerceOrder wcOrder = parseJsonOrder(jsonOrder); // 建议封装 JSON 解析逻辑
orderService.asyncProcessOrder(wcOrder);
} catch (Exception e) {
log.error("Failed to enqueue order", e);
return ResponseEntity.unprocessableEntity().build();
}
return ResponseEntity.ok().build(); // 立即返回 200 OK
}
private WoocommerceOrder parseJsonOrder(String json) {
// 使用 ObjectMapper 安全反序列化，建议加 try-catch 和日志
return new ObjectMapper().readValue(json, WoocommerceOrder.class);
}
}</string></void>
⚠️ 关键注意事项：
- 永远不要在 @Async 方法内直接捕获并吞掉异常：单线程执行器中未处理的异常会导致后续任务全部中断。应在 asyncProcessOrder 内包裹 try-catch 并记录错误，或配置 AsyncUncaughtExceptionHandler。
- 确保 @EnableAsync 已启用：在主配置类或 @Configuration 类上添加 @EnableAsync。
- 避免事务传播陷阱：@Transactional 必须作用于实际执行方法（processJsonOrder），而非 @Async 代理方法；否则事务上下文无法传递。
- 生产环境强烈建议升级为持久化队列：如 RabbitMQ + DLQ（死信队列），支持消息持久化、重试、监控和水平扩展，彻底规避内存单点故障风险。
总结：真正的“异步但串行”不靠 synchronized，而靠执行器层面的线程隔离 + 显式任务调度。单线程 Executor 是轻量级验证方案，而消息中间件才是高可靠、可伸缩的终极答案。
