Spring @Transactional在@RabbitListener方法上事务不生效问题

基于Spring Boot 2.7.1、Kotlin 1.7.0搭建的项目中，对@RabbitListener标注类下的消息处理方法添加@Transactional注解后，日志显示事务已创建，但持久化操作未被纳入事务，抛出如下异常：

• 外层异常：InvalidDataAccessApiUsageException
• 嵌套异常：javax.persistence.TransactionRequiredException: Executing an update/delete query

对应监听端实现代码：

@Component
@RabbitListener(queuesToDeclare = [Queue(name = QUEUE_NAME)], errorHandler = "RabbitErrorHandler")
class RabbitListener(
    private val repository: RepositoryImpl,
) {
    @Transactional
    @RabbitHandler
    fun receive(
        @Payload
        str: String
    ) {
        println("Message Received: $str")
        repository.save(SomeEntity()) // 执行持久化操作
    }
}

TransactionInterceptor的TRACE级别日志如下：

[ntContainer#0-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [com.asomethings.listener.RabbitListener.receive]
[ntContainer#0-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [com.asomethings.listener.RabbitListener.receive] after exception: org.springframework.dao.InvalidDataAccessApiUsageException: Executing an update/delete query; nested exception is javax.persistence.TransactionRequiredException: Executing an update/delete query

• 在Repository层方法上添加@Transactional注解
• 将@Transactional的传播级别设置为Propagation.MANDATORY

当前仅手动执行entityManager.joinTransaction()可正常完成持久化，但该实现不符合Spring事务的规范用法。

日志中已经出现TransactionInterceptor的事务拦截记录，说明@Transactional的切面代理已经生效，问题核心在于RabbitMQ默认的监听器容器没有和JPA事务管理器完成资源绑定：
JPA的EntityManagerHolder没有被绑定到当前消费线程的事务上下文中，即使事务拦截器创建了事务实例，Repository层持有的EntityManager也感知不到当前线程的活跃事务，执行写操作时就会抛出事务缺失的异常。手动调用entityManager.joinTransaction()是强制让EntityManager关联当前事务，所以能临时生效，但属于硬编码实现，没有利用Spring的自动资源绑定机制。

之前尝试的两种方案无效的原因也和这个根因相关：无论@Transactional加在Repository层还是修改传播级别，都没有解决EntityManager和事务上下文未绑定的核心问题。

1. 配置Rabbit监听器容器，显式绑定JPA事务管理器 #

自定义SimpleRabbitListenerContainerFactory，将Spring Boot自动装配的JPA事务管理器注入到容器工厂中，让监听器在消费消息时自动完成事务资源的绑定：

@Configuration
class RabbitMqConfig(
    private val connectionFactory: ConnectionFactory,
    private val jpaTransactionManager: JpaTransactionManager
) {
    @Bean
    fun rabbitListenerContainerFactory(): SimpleRabbitListenerContainerFactory {
        return SimpleRabbitListenerContainerFactory().apply {
            setConnectionFactory(connectionFactory)
            // 核心配置：关联JPA事务管理器，自动绑定线程事务资源
            setTransactionManager(jpaTransactionManager)
            // 可根据业务调整ack模式，事务回滚时消息会自动重回队列
            setAcknowledgeMode(AcknowledgeMode.AUTO)
        }
    }
}

2. 校验事务注解的生效条件 #

• 确认项目引入了kotlin-spring插件，该插件会自动给Spring托管的类、事务方法添加open修饰，避免因为Kotlin默认类/方法为final导致事务代理逻辑不完整。如果未引入该插件，需要手动给receive方法添加open修饰。
• 确认@Transactional注解导入的是Spring官方包：org.springframework.transaction.annotation.Transactional，不要误导入javax/jakarta包下的同名注解。

3. 清理临时代码 #

移除手动调用entityManager.joinTransaction()的硬编码逻辑，配置完成后JPA持久化操作会自动纳入当前事务，方法抛出异常时数据库操作会自动回滚，同时保证消息消费和数据库操作的一致性。

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