Spring Transactional遇UnexpectedRollbackException问题求解

问题根源 #

你遇到的UnexpectedRollbackException，本质是因为AgentService的方法抛出异常后，其@Transactional(rollbackFor = [Throwable::class])会把当前事务（包括外层DocumentService的事务，默认REQUIRED传播级别）标记为回滚状态。哪怕后续Payment添加成功，外层事务尝试提交时，发现事务已被标记回滚，就会抛出这个异常。

同时你的核心需求是：

• 代理添加成功/失败转默认后，必须执行支付添加
• 支付失败则回滚所有已执行的代理操作

核心解决方案：统一外层事务控制 #

移除AgentService和PaymentService对应方法上的@Transactional，仅在DocumentService的入口方法保留事务注解，让整个流程处于同一个事务中，在外层方法里捕获代理添加的异常，处理默认代理逻辑，最后统一管控支付结果：

// DocumentService.kt
@Service
class DocumentService(
    private val agentService: AgentService,
    private val paymentService: PaymentService
) {

    @Transactional(rollbackFor = [Throwable::class])
    fun handleBusinessLogic(customAgentDto: AgentDto) {
        val agent = try {
            // 尝试添加自定义代理
            agentService.addAgent(customAgentDto)
        } catch (e: Exception) {
            // 添加失败，切换为默认代理
            agentService.addDefaultAgent()
        }

        // 强制执行支付添加，失败则触发全量回滚
        paymentService.addPayment(agent.id)
    }
}

// AgentService.kt
@Service
class AgentService(private val agentRepo: AgentRepository) {
    // 移除事务注解，由外层事务统一管控
    fun addAgent(dto: AgentDto): Agent {
        return agentRepo.save(Agent.fromDto(dto))
    }

    fun addDefaultAgent(): Agent {
        return agentRepo.save(Agent.default())
    }
}

// PaymentService.kt
@Service
class PaymentService(private val paymentRepo: PaymentRepository) {
    // 移除事务注解，由外层事务统一管控
    fun addPayment(agentId: Long) {
        paymentRepo.save(Payment(agentId = agentId))
    }
}

方案可行性说明 #

1. 全流程单事务保证：只要支付添加失败，抛出的异常会触发外层事务回滚，无论之前是添加了自定义代理还是默认代理，都会被回滚，满足场景b要求；
2. 代理异常处理：自定义代理添加失败时，捕获异常后继续执行默认代理添加，只要后续支付成功，整个事务提交，满足场景a“无论代理是否成功都必须添加支付”的要求；
3. 避免回滚异常：代理添加失败的异常被外层捕获，不会触发事务回滚标记，只有支付失败时才会标记事务回滚，彻底解决UnexpectedRollbackException。

补充：保留内层事务的兼容方案 #

如果因其他场景需要保留内层服务的事务控制，可以将AgentService和PaymentService的方法设置为propagation = Propagation.MANDATORY（强制要求在外层事务中执行，禁止单独开启事务），既保证内层方法的事务由外层管控，又能避免误操作：

// AgentService的方法修改
@Transactional(propagation = Propagation.MANDATORY, rollbackFor = [Throwable::class])
fun addAgent(dto: AgentDto): Agent {
    return agentRepo.save(Agent.fromDto(dto))
}

注意：此时必须在外层方法中捕获内层抛出的异常，否则异常会传播并标记事务回滚，依然会出现之前的问题。

为什么之前的方案不适用 #

1. REQUIRES_NEW：内层事务独立提交，导致支付失败时无法回滚已提交的代理，违反场景b；同时占用额外连接池资源，无法共享上下文数据，完全不符合需求；
2. 手动保存点：需要脱离@Transactional注解手动管理事务，开发效率低，违背Spring声明式事务的设计理念；
3. NESTED：Hibernate的JpaTransactionManager默认不允许嵌套事务，需手动设置nestedTransactionAllowed = true，且嵌套事务仅支持部分回滚到保存点，而你的需求是全量提交/回滚，统一事务方案更简单直接。

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