如果消息处理程序 (Consumer<T>) 调用用 @Transactional 注释的服务，则没有可用/创建事务

问题描述

该应用程序是一个 Spring Boot 应用程序，其中包含使用函数式编程模型定义的 Spring Data JPA 和 Spring Cloud Stream (RabbitMQ)。

函数式消息处理程序调用服务：

@Configuration
class MessageHandlerConfiguration {
    @Bean
    public Consumer<Person> consume(Service service) {
        return person -> service.process(person);
    }
}

Service 方法持久化实体并尝试获取延迟加载的关系：

@Service
class Service {
    //constructor injection
    private PersonRepo personRepo;
    
    @Transactional
    public void process(Person person) {
        // create personEntity
        // ...

        var personEntity = personRepo.save(personEntity);

        // throws org.hibernate.LazyInitializationException
        var addressEntity = personEntity.getAddress();
    }
}

通过 personEntity.getAddress() 访问延迟加载的实体会抛出 org.hibernate.LazyInitializationException: Could not initialize proxy - no Session。因此，Service 没有被代理，process 方法中没有可用的事务（和会话）。一些调试验证了这个假设。

但是，如果从 rest 控制器调用 process 方法，则事务可用且代码工作正常。

此外，可以将消息处理程序中 process 方法的调用包装到 TransactionTemplate 中，这解决了丢失事务的问题：

@Bean
public Consumer<Person> consume(Service service,TransactionTemplate transactionTemplate) {
    return person -> transactionTemplate.execute(() -> service.process(person));
}

如果从消息处理程序调用服务，为什么不代理？ Spring Cloud Stream 是否与声明式事务管理集成？

解决方法

好的，我解决了。

我创建了一个简单的项目来测试用例，它按预期工作。该代码可在 GitHub 上获得。

最初的问题发生在具有更复杂设置和依赖关系的更大项目中。