SpringBoot事务优化非数据库逻辑移出事务用途代码CR、AI评审、团队编码参考核心主题Transactional大事务优化晚开事务、早提交事务区分哪些逻辑放事务内、哪些放事务外附带正反案例、坑点、两种业务模式代码。# SpringBoot事务优化非数据库逻辑移出事务 ## 文档目标 解决业务开发中非常常见问题方法上加Transactional方法内部混杂参数校验、普通查询、RPC调用、数据组装、业务计算导致**事务开启过早、事务执行时间过长、行锁持有时间久**引发锁超时、死锁、主从延迟、数据库连接占用等线上问题。 核心原则**晚开事务早提交事务** 能放到事务外面的逻辑全部挪到事务外面事务内部尽量只保留数据库写操作。 ## 重要前置认知 1. Transactional标记在方法上整个方法为一个事务边界 2. 在同一个带Transactional方法内部做for循环分批**只是拆分SQL不会拆分事务锁不会释放仍然是大事务** 3. 只有新开启独立事务才会释放锁但拆分独立事务就丢失整体原子性业务二选一。 ## 哪些逻辑可以挪到事务外面全部优先外移 ✅可以放到事务外部 1. 参数校验、参数预处理、业务前置判断 2. RPC调用、HTTP远程调用网络IO耗时不可控 3. 普通不带锁select查询不需要行锁 4. 对象拼装、数据转换、复杂业务计算、集合处理 ## 哪些逻辑必须留在事务内部不能挪出去 ❌不能放到事务外部 1. select ... for update悲观锁查询行锁依赖事务事务外for update不会加锁 2. 需要保证原子性的写库操作insert / update / delete 注意for update之后中间不要插入RPC、网络调用紧跟着执行更新尽快提交事务。 ## 场景说明 业务场景主方法需要保证整体原子性必须使用数据库事务一部分逻辑必须写库但是存在大量校验、rpc、普通查询、数据拼装。 ### 反例错误写法禁止直接复制上线 问题一进入方法就开启事务RPC、普通查询、数据组装全部在事务内锁持有时间包含网络耗时。 java Service public class OrderService { Autowired private OrderMapper orderMapper; Autowired private UserMapper userMapper; Autowired private ItemMapper itemMapper; Autowired private UserRpc userRpc; /** * 【坏示例】事务包裹全部逻辑 */ Transactional(rollbackFor Exception.class) public void createOrder(Long orderId, Long userId){ //1.参数校验 if(orderId null || userId null){ throw new RuntimeException(参数非法); } //2.普通查询DB普通select不需要锁行 UserPO userPo userMapper.selectById(userId); if(userPo null){ throw new RuntimeException(用户不存在); } //3.RPC远程调用网络IO耗时不确定 UserDTO userDTO userRpc.getUserInfo(userId); //4.复杂数据拼凑、业务计算 OrderPO orderPO buildOrderPo(orderId,userDTO); //5.普通查询一批业务数据 ListItemPO itemList itemMapper.selectByOrderId(orderId); //6.真正写数据库操作 orderMapper.insert(orderPO); for(ItemPO item : itemList){ itemMapper.updateById(item); } } private OrderPO buildOrderPo(Long orderId, UserDTO userDTO) { OrderPO po new OrderPO(); po.setOrderId(orderId); po.setUserName(userDTO.getUserName()); return po; } }风险点RPC网络慢的时候事务一直挂住行锁长时间不释放其他线程发生锁等待超时。正例改造方案强原子场景整体要全部成功/全部失败要点外层入口方法不加Transactional参数校验、rpc、普通查询、对象组装全部放在外层全部前置逻辑执行完毕数据准备就绪再调用带Transactional的内部方法事务内部只保留数据库读写需要自注入代理对象调用事务方法不能使用this调用否则AOP事务失效。Service public class OrderService { Autowired private OrderMapper orderMapper; Autowired private UserMapper userMapper; Autowired private ItemMapper itemMapper; Autowired private UserRpc userRpc; //自注入拿到Spring代理对象不能this调用 Autowired private OrderService selfService; /** * 外层入口方法不加事务执行全部前置逻辑 */ public void createOrder(Long orderId, Long userId){ //----------全部挪到事务外面开始---------- //1.参数校验 if(orderId null || userId null){ throw new RuntimeException(参数非法); } //2.普通查询普通select不加锁可以放事务外 UserPO userPo userMapper.selectById(userId); if(userPo null){ throw new RuntimeException(用户不存在); } //3.RPC远程调用网络IO放在事务外面 UserDTO userDTO userRpc.getUserInfo(userId); if(userDTO null){ throw new RuntimeException(RPC获取用户信息失败); } //4.业务对象拼装、复杂计算 OrderPO orderPO buildOrderPo(orderId, userDTO); //5.普通查询业务数据放到事务外面 ListItemPO itemList itemMapper.selectByOrderId(orderId); if(CollectionUtils.isEmpty(itemList)){ throw new RuntimeException(没有待处理明细); } //----------全部挪到事务外面结束---------- //所有校验、RPC、查询、组装全部完成再调用事务方法做写库 selfService.createOrderDbOperate(orderPO, itemList); } /** * 内层事务方法只保留数据库写操作逻辑尽量少 * 仍然是一个完整事务保证insert/update原子性 */ Transactional(rollbackFor Exception.class) public void createOrderDbOperate(OrderPO orderPO, ListItemPO itemList){ orderMapper.insert(orderPO); // 如果循环更新明细先按数据库主键排序规避死锁 ListLong sortedItemPks itemList.stream() .map(ItemPO::getId) .sorted(Comparator.naturalOrder()) .collect(Collectors.toList()); //分批仅拆分in参数仍然同一个事务锁不会释放 ListListLong batches Lists.partition(sortedItemPks,300); for(ListLong batch : batches){ itemMapper.batchUpdateByIds(batch); } } private OrderPO buildOrderPo(Long orderId, UserDTO userDTO) { OrderPO po new OrderPO(); po.setOrderId(orderId); po.setUserName(userDTO.getUserName()); return po; } }改造收益校验、RPC失败直接在外层抛出事务根本不会打开不占用数据库连接事务开启时机延后事务内部只有DB操作执行速度快锁持有时间大幅缩短insert/update仍然在同一个事务保证业务原子性不会出现部分成功部分失败。另一种实现编程式事务 TransactionTemplate不想自注入代理对象可以使用TransactionTemplate手动控制事务边界适合定时任务、MQ消费场景。Service public class OrderService { Autowired private TransactionTemplate transactionTemplate; Autowired private OrderMapper orderMapper; Autowired private ItemMapper itemMapper; Autowired private UserRpc userRpc; public void createOrder(Long orderId, Long userId){ //【事务外】执行参数校验、rpc、普通查询、组装数据省略... //所有前置工作完成再开启事务执行写库 transactionTemplate.execute(status - { orderMapper.insert(orderPO); ListListLong batches Lists.partition(sortedItemPks,300); for(ListLong batch : batches){ itemMapper.batchUpdateByIds(batch); } return null; }); } }业务场景二允许部分成功不需要整体原子性比如数据修复、后台清理任务可以一部分批次成功一部分失败支持断点续跑。处理方式每一批次独立事务每批执行完立刻提交释放锁。Autowired private TransactionTemplate transactionTemplate; public void batchRepairBizData(ListString bizIdList){ //事务外业务id查询映射主键 ListBizEntity entityList mapper.selectByBizIds(bizIdList); //主键排序防止死锁 ListLong sortedPkList entityList.stream() .map(BizEntity::getId) .sorted() .collect(Collectors.toList()); ListListLong batches Lists.partition(sortedPkList,300); for(ListLong batch : batches){ //每一批独立事务执行完直接提交释放锁 transactionTemplate.execute(status -{ mapper.batchUpdate(batch); return null; }); } }高频疑问Q1事务外面查询的数据进到事务内部会不会被其他线程修改会会出现不可重复读。如果只是基础参数校验允许短暂不一致放事务外没问题。如果需要基于当前行数据做修改扣库存等不能在外面查询必须放到事务内部使用select ... for update加悲观锁。Q2我在外层抛出异常会不会回滚外层没有开启事务直接抛出异常不会触发任何回滚也不会占用数据库连接只有进入带Transactional方法之后才会开启事务。Q3this调用事务方法会发生什么this.createOrderDbOperate()绕过SpringAOP代理Transactional完全失效不会开启事务。解决使用自注入selfService或者使用TransactionTemplate编程式事务。CR检查清单给AI评审/人工代码审查使用RPC、HTTP远程调用是否已经移出事务参数校验、普通无锁查询、对象组装、业务计算是否放在事务外部select ... for update悲观锁查询是否保留在事务内部for update后面不允许插入RPC/网络IO紧跟着写库如果循环更新同一张表多行是否做数据库主键升序排序批量操作是否做分批建议200‑500条每批事务方法是否使用代理对象调用避免this调用区分业务是【强原子一个大事务】还是【允许部分成功多独立小事务】。总结非数据库逻辑全部挪到事务外面事务内尽量只保留写库和必要悲观锁查询。强原子业务不能拆分事务只能做事务瘦身缩短事务执行时间缓解锁超时风险。允许部分成功的业务拆分为多批独立小事务可以真正释放锁降低数据库压力。同一个事务内的分批只是拆分SQL不会释放锁不会拆分事务边界。