Spring @Transactional方法内使用CompletableFuture出现重复记录问题咨询

Spring 中 @Transactional 注解的事务生命周期与执行该方法的主线程绑定，事务会在方法执行 return 返回响应前就完成提交/回滚，完全不会等待你提交到 CompletableFuture 的异步任务执行结束。

• 先读后写的校验逻辑本身存在竞态条件：高并发场景下多个请求同时读取到「任务不存在/执行失败」的相同状态，会同时执行任务创建逻辑，最终生成重复记录。
• 异步任务与主线程事务完全隔离：Spring 的事务上下文默认存储在 ThreadLocal 中，CompletableFuture 启动的异步线程是独立的新线程，无法共享主线程的事务信息，异步任务内的数据库操作都是独立的新事务，和主线程事务没有协同关系。
• 额外隐藏风险：如果主线程事务后续触发回滚，你提前提交的异步任务已经执行的数据库操作无法跟着回滚，会产生大量脏数据。

• 底层兜底：给任务的唯一业务标识字段添加数据库唯一索引，从存储层直接拦截重复插入请求，避免最终出现重复记录。
• 消除竞态条件：把「校验任务状态+更新/插入任务」的逻辑改成原子操作，可选方案包括：
  • 对任务查询语句加排他锁：使用 select ... for update 语法锁定查询到的记录，避免其他事务同时修改
  • 使用乐观锁：给任务表加版本号字段，更新时携带版本号校验，只有版本号匹配时才更新成功
  • 直接使用数据库原子语法（如MySQL的 insert ... on duplicate key update），插入冲突时自动执行更新逻辑，无需先查询判断
• 修复事务与异步的协同逻辑：如果异步任务需要依赖主线程的任务状态写入结果，不要直接在事务方法内提交异步任务，而是通过Spring的TransactionSynchronizationManager注册事务提交回调，等主线程事务确实提交成功后再触发异步任务，避免主线程事务回滚但异步任务已执行的脏数据问题。

内容的提问来源于stack exchange，提问作者Amit Gupta