事务在方法退出前提前提交问题求助（Atomikos事务管理器）

问题场景与代码 #

现有基于Spring + Atomikos JTA的事务代码如下（已修正原代码中的语法错误）：

@Service
public class MyHandlerService {

    @Inject
    private MyRepoService myRepoService;

    @Transactional(value = "manager1", propagation = Propagation.REQUIRES_NEW)
    public void handle(final String message) {
        myRepoService.save(message);
    }

}


@Service
@Transactional("manager1")
public class MyRepoService {
    @Inject
    private final VehicleService vehicleService;

    public void save(String message) {
        MYVEHICLELIST.getEntries(message).forEach(vehicleEntry -> {
            Vehicle vehicle = vehicleService.findById(vehicleEntry.getId());
            if (vehicle == null) {
                vehicleService.save(vehicleEntry);
            }
        });
    }

}

@Service
public class VehicleService {
    @Inject
    private final VehicleRepository repo;

    @Transactional(value = "manager1", readOnly = true)
    public Vehicle findById(final String id) {
        return repo.findById(id);
    }

    public void save(Vehicle obj) {
        repo.save(obj);
    }
}

当前出现的问题：

• 处理MYVEHICLELIST的第一个条目后，数据暂存于事务未提交
• 处理第二个条目调用vehicleService.findById()时，第一个车辆的数据被提前提交到数据库

期望效果：所有数据仅在MyHandlerService.handle()方法执行完成后才统一持久化。

问题根源 #

1. 只读事务触发隐式提交：VehicleService.findById()的@Transactional(readOnly = true)在Atomikos JTA环境下，会触发当前读写事务的隐式提交。因为JTA规范中，只读事务需要保证数据一致性，Atomikos会强制提交之前的读写操作，再启动只读事务，导致第一个条目的数据提前落地。
2. 事务边界不明确：VehicleService.save()未标注事务注解，虽然会继承上层MyRepoService的事务，但结合只读事务的调用，会破坏事务上下文的连续性，加剧提前提交的问题。

修复方案 #

方案一：统一事务传播行为，消除只读事务的干扰 #

修改VehicleService的事务配置，确保所有操作都加入主事务，避免触发新事务或隐式提交：

@Service
public class VehicleService {
    @Inject
    private final VehicleRepository repo;

    // 使用MANDATORY强制依赖当前主事务，不允许无事务调用
    @Transactional(value = "manager1", propagation = Propagation.MANDATORY)
    public Vehicle findById(final String id) {
        return repo.findById(id);
    }

    // 明确标注事务，继承主事务的属性
    @Transactional(value = "manager1")
    public void save(Vehicle obj) {
        repo.save(obj);
    }
}

同时确认MyRepoService的事务传播行为与主事务保持一致（默认REQUIRED即可，无需额外修改）：

@Service
@Transactional(value = "manager1")
public class MyRepoService {
    @Inject
    private final VehicleService vehicleService;

    public void save(String message) {
        MYVEHICLELIST.getEntries(message).forEach(vehicleEntry -> {
            Vehicle vehicle = vehicleService.findById(vehicleEntry.getId());
            if (vehicle == null) {
                vehicleService.save(vehicleEntry);
            }
        });
    }
}

方案二：保留只读属性，调整主事务与传播行为 #

如果业务需要保留findById的只读属性，可调整主事务隔离级别，并将只读事务的传播行为改为SUPPORTS（仅在已有事务时加入）：

// 修改MyHandlerService的主事务配置
@Service
public class MyHandlerService {

    @Inject
    private MyRepoService myRepoService;

    @Transactional(value = "manager1", propagation = Propagation.REQUIRES_NEW, isolation = Isolation.REPEATABLE_READ)
    public void handle(final String message) {
        myRepoService.save(message);
    }

}

// 修改VehicleService的findById方法
@Service
public class VehicleService {
    @Inject
    private final VehicleRepository repo;

    @Transactional(value = "manager1", readOnly = true, propagation = Propagation.SUPPORTS)
    public Vehicle findById(final String id) {
        return repo.findById(id);
    }

    @Transactional(value = "manager1")
    public void save(Vehicle obj) {
        repo.save(obj);
    }
}

关键注意事项 #

• 确保所有参与事务的方法都明确标注@Transactional，避免隐式事务上下文切换
• 在Atomikos JTA环境中，尽量避免在同一事务流中混合读写与只读事务，如需混合必须明确配置传播行为
• 修复代码中的语法错误（如漏写@Inject、变量名错误、方法访问权限），这类错误可能导致Spring事务代理失效

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