使用Spring Data与Neo4j 4.x时反应式仓库链式调用事务异常问题

问题场景 #

使用Neo4j 4.x搭配Spring Data Reactive，多个反应式仓库链式调用时触发异常：

IllegalStateException: Already value ReactiveNeo4JTransactionHolder for key InternalDriver bound to context

单独调用findById或save操作均正常，但通过flatMap链式执行时出现事务冲突。

解决方案 #

1. 用反应式事务注解包裹整个操作链 #

给包含该链式调用的方法添加@Transactional注解（Spring 5+支持反应式事务），确保整个操作在同一个事务上下文内执行：

import org.springframework.transaction.annotation.Transactional;

@Transactional
public Mono<Void> linkWheelToCar(String id) {
    return carsRepository.findById(id)
            .flatMap(car -> {
                // 此处添加wheel与car的关系绑定逻辑
                Wheel wheelNode = new Wheel();
                // 设置wheel属性
                return wheelRepository.save(wheelNode);
            })
            .then();
}

2. 验证仓库接口的正确性 #

确保所有仓库接口都正确继承ReactiveNeo4jRepository，避免混合非反应式操作导致的上下文冲突：

public interface CarsRepository extends ReactiveNeo4jRepository<Car, String> {
}

public interface WheelRepository extends ReactiveNeo4jRepository<Wheel, String> {
}

3. 避免手动事务上下文操作 #

不要在代码中手动创建或切换事务上下文，让Spring的声明式事务管理统一处理上下文绑定，防止重复绑定TransactionHolder。

原因说明 #

Spring Data Neo4j的反应式操作会将ReactiveNeo4JTransactionHolder绑定到Reactor的Context中。链式调用时，如果没有统一的事务管理，前一个操作的事务上下文未释放，后续操作尝试创建新事务时就会触发"已绑定事务持有者"的冲突。通过@Transactional注解可以让整个操作链共享同一个事务上下文，避免重复绑定。

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