SpringBoot JPA事务方法内多线程实现多独立插入同事务的咨询

Spring 声明式事务@Transactional基于ThreadLocal实现事务上下文绑定，事务相关的数据库连接、状态信息仅存在于当前调用方法的线程中，子线程无法继承父线程的事务上下文。你写的这段标注@Transactional的methodA，事务仅对当前线程内的save操作生效，新开线程执行的save操作完全脱离原事务管控，自然会出现事务失效的问题。

@Transactional
public void methodA(){
    repo1.save(A);
    repo2.save(B);
    repo3.save(C);
    repo4.save(D);
}

方案1：优先尝试单线程批量插入（成本最低，优先推荐） #

绝大多数场景下不需要引入多线程，仅需配置JPA批量插入参数，性能就能超过未做批量优化的多线程方案，同时完全保留事务特性：

• 修改项目配置文件，开启Hibernate批量插入能力：

spring:
  jpa:
    properties:
      hibernate:
        jdbc:
          batch_size: 50 # 每攒满50条SQL执行一次批量操作
        order_inserts: true # 按实体类型排序插入语句，保证批量生效
        order_updates: true

• 原方法无需其他修改，单线程批量插入的IO开销远低于多线程事务协调的开销，适合绝大多数业务场景。

方案2：多线程独立事务 + 补偿机制（性能最高，适合可接受最终一致性的场景） #

如果单线程批量性能确实无法满足要求，且业务允许短时间的数据不一致，可采用该方案：

• 移除methodA的@Transactional注解
• 将单个save操作封装为独立的事务方法，每个子线程执行时会开启独立事务
• 主线程用CountDownLatch等工具等待所有子线程执行结果：
  • 所有子线程执行无异常，无需额外操作
  • 任意子线程执行失败，调用补偿方法删除其他线程已插入成功的数据，保证最终一致性

注意：该方案不满足强一致性要求，会存在部分数据已插入、部分未插入的中间状态，需业务场景允许该情况。

方案3：JTA分布式事务（强一致，性能损耗较大） #

如果必须要求多个线程的插入操作严格同成功同失败，满足强一致性，可采用基于XA协议的JTA分布式事务：

• 引入Atomikos、Bitronix等JTA实现依赖，将Spring默认的单数据源事务管理器替换为JtaTransactionManager
• 每个子线程的save方法标注@Transactional(propagation = Propagation.REQUIRES_NEW)，作为分布式事务的分支事务
• 原methodA标注@Transactional(rollbackFor = Exception.class)，作为全局事务的发起者
• 全局事务管理器会通过两阶段提交协调所有分支事务，保证所有操作要么全部提交要么全部回滚

注意：该方案的两阶段提交会带来很高的性能开销，如果单次插入操作本身耗时较短，实际运行性能可能比单线程批量插入更低。

不要尝试在多个线程之间共享同一个数据库连接来复用父线程事务：数据库连接本身是线程不安全的，多线程并发操作会导致连接状态混乱，出现不可预期的SQL执行错误。

内容的提问来源于stack exchange，提问作者Kashish Aneja