Spring bootr2dbc transactional：注释哪种方法

Question

我正在使用带有webflux的spring boot 2.4.2连接到postgres数据库。我在使用事务性代码时观察到了一个我不理解的行为。

为了展示这种行为，我创建了一个示例应用程序，试图将行添加到两个表中；表“a”和表“b”。对表“a”的插入预计将失败，并出现重复密钥冲突。考虑到使用了事务性，我希望不会向表“b”中添加任何行。

然而，根据我用哪个方法注释事务，我会得到不同的结果。

如果我对controller方法进行注释，事情会按预期进行，并且表B中不会添加任何行。

    @PostMapping("/")
    @Transactional
    public Mono<Void> postEntities() {
        return demoService.doSomething();
    }

DemoService如下所示：

    public Mono<Void> doSomething() {
        return internal();
    }


    public Mono<Void> internal() {
        Mono<EntityA> clash = Mono.just(EntityA.builder().name("clash").build()).flatMap(repositoryA::save);
        Mono<EntityB> ok = Mono.just(EntityB.builder().name("ok").build()).flatMap(repositoryB::save);
        return ok.and(clash);
    }

如果我将事务注释从控制器移动到doSomething（），则事务仍按预期工作。但是，如果我将@事务性注释移动到内部（）。表“b”中添加了一行。

此示例的完整代码如下：https://github.com/alampada/pg-spring-r2dbc-transactional

我不明白为什么将注释移动到内部（）方法会导致事务处理问题。你能解释一下吗？




Answer 1

来自Spring参考文档：使用@Transactional

在代理模式（默认）下，只有通过代理传入的外部方法调用被拦截。这意味着自我调用（实际上，目标对象内的一个方法调用目标对象的另一个方法）即使调用的方法标记为@Transactional，也不会在运行时导致实际事务。此外，必须完全初始化代理以提供预期的行为，因此您不应该在初始化代码（即@PostConstruct）中依赖此功能。

这里，从doSomething（）到internal（）的调用是一个自调用。

请注意，Spring框架的声明性事务支持是通过AOP代理启用的。

Spring参考文档：了解AOP代理将清楚地说明为什么自调用不能在代理上工作。一定要通读这一节，首先要理解的关键是main（..）中的客户机代码