关于@Transactional(Propagation.REQUIRES_NEW)事务控制的问题求助

核心问题分析 #

你当前的矛盾点在于：completeTask用REQUIRES_NEW会提前提交事务，导致后续sendTaskAfterInsertToOtherService出错时无法回滚它的操作；但不用REQUIRES_NEW又查不到刚插入的数据。其实根本原因是误解了事务内数据可见性——只要在同一个事务内执行flush操作，就能让后续查询获取到未提交的数据，不需要提前提交事务。

针对需求的事务调整方案 #

根据你的三个需求，重新设计事务传播行为和代码逻辑：

1. 每个任务独立事务，不互相影响：给completeTaskOrDoSomethingElse保留REQUIRES_NEW，确保循环中每个任务的事务完全独立，一个失败只回滚自身，不影响其他任务。
2. completeTask与sendTask共享事务，保证同时回滚：把completeTask和sendTaskAfterInsertToOtherService放在同一个事务中，放弃completeTask的REQUIRES_NEW，改为默认的REQUIRED（继承上层事务），这样两者的操作在同一个事务上下文里，任意一步出错都能整体回滚。
3. 解决事务内查询数据的问题：在completeTask中用saveAndFlush替代普通的save，强制把数据刷入数据库（但事务未提交），这样sendTaskAfterInsertToOtherService就能在同一个事务内查询到这条数据。

调整后的代码示例 #

// 主函数：无事务，循环调用独立事务的方法
void mainFunction() {
    for(Task task : listOfTasks) {
        try {
            completeTaskOrDoSomethingElse(task);
        } catch (Exception e) {
            // 捕获异常，保证循环继续执行其他任务
            log.error("处理任务{}失败", task.getId(), e);
        }
    }
}

// 每个任务的独立事务入口
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
void completeTaskOrDoSomethingElse(Task task) {
    // 执行任务完成逻辑，共享当前事务
    Task newTask = completeTask(task);
    
    // 执行后续服务调用，共享当前事务
    sendTaskAfterInsertToOtherService(newTask.getId());
}

// 取消REQUIRES_NEW，加入上层事务
@Transactional(rollbackFor = Exception.class)
Task completeTask(Task task) {
    // 插入数据并刷入数据库（事务未提交）
    Task savedTask = taskDao.saveAndFlush(task);
    return savedTask;
}

// 加入上层事务，出错时整体回滚
@Transactional(rollbackFor = Exception.class)
void sendTaskAfterInsertToOtherService(Long taskId) {
    // 同一个事务内，能查询到刚flush的未提交数据
    Task task = taskDao.getById(taskId);
    
    // 执行数据库插入操作（同属当前事务）
    otherDao.insert(task);
    
    // 调用外部服务
    callOtherService(task);
}

方案对需求的满足验证 #

• 需求1：completeTaskOrDoSomethingElse用REQUIRES_NEW，每个任务的事务独立，某一个任务执行出错时，仅回滚该任务的所有操作，循环会继续处理其他任务。
• 需求2：completeTask出错时，会触发completeTaskOrDoSomethingElse的事务回滚，但因为每个任务的事务独立，仅影响当前任务的completeTask操作，不波及其他任务。
• 需求3：sendTaskAfterInsertToOtherService和completeTask共享同一个事务，一旦前者出错，整个事务会回滚，包含两者的所有数据库操作。

关键注意事项 #

• 必须用saveAndFlush：普通save只是把数据放在ORM框架的一级缓存，不会立即写入数据库，同事务内的查询也无法获取；saveAndFlush会强制刷入数据库，保证同事务内可见。
• 外部服务的幂等性：如果callOtherService已经调用成功，但后续数据库操作回滚，可能导致外部服务的数据与本地不一致，需要给外部服务实现幂等性逻辑，或者考虑分布式事务（如果业务要求强一致性）。

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