Apache Ignite嵌套事务：如何不终止已有事务时启动新事务？

你写的嵌套事务代码会抛出异常，核心原因是Apache Ignite默认不支持嵌套事务——Ignite事务与当前线程强绑定，同一线程内只能存在一个活跃事务，直接在已有事务的线程中再次调用txStart()会触发冲突异常。

以下是两种可行的替代实现方案：

方案一：同一事务内划分逻辑块（推荐） #

不需要开启嵌套事务，而是在同一个事务中处理多段逻辑，通过setRollbackOnly()控制事务整体回滚：

IgniteCache<Integer, String> cache = Ignition.ignite().cache("myCache");

try (Transaction tx = Ignition.ignite().transactions().txStart()) {
    // 外层事务逻辑
    cache.put(1, "outer-data");

    try {
        // 内层业务逻辑，无需开启新事务
        cache.put(2, "inner-data");
        // 模拟业务异常
        throw new RuntimeException("Inner logic error");
    } catch (Exception e) {
        // 标记整个事务回滚，后续提交会失效
        tx.setRollbackOnly();
        // 可根据业务需求添加日志、异常处理逻辑
    }

    // 事务会因被标记回滚而无法提交
}

方案二：新线程中独立启动事务（适合完全独立的业务场景） #

如果内层事务需要完全独立于外层事务执行，可以在新线程中启动事务（Ignite事务绑定线程，新线程不受外层事务影响）：

IgniteCache<Integer, String> cache = Ignition.ignite().cache("myCache");

try (Transaction tx = Ignition.ignite().transactions().txStart()) {
    // 外层事务逻辑
    cache.put(1, "outer-data");

    // 启动新线程执行独立事务
    CompletableFuture.runAsync(() -> {
        try (Transaction innerTx = Ignition.ignite().transactions().txStart()) {
            cache.put(2, "inner-data");
            innerTx.commit(); // 独立提交内层事务
        } catch (Exception e) {
            // 处理内层事务异常
        }
    }).get(); // 等待内层事务执行完成

    tx.commit(); // 提交外层事务
} catch (Exception e) {
    // 处理外层事务异常
}

关键说明 #

Ignite的事务模型基于线程本地存储，每个线程同一时间只能持有一个活跃事务。如果业务场景必须实现类似嵌套事务的逻辑，优先采用方案一调整业务流程；若内层事务需完全独立，再考虑方案二的多线程实现。

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