Spring @Transactional 挂起功能

Question

我现在有点沮丧，因为我认为这会容易得多，并且问题会得到更好的记录，但我就是找不到解决方案。因此我在这里寻求帮助。

我正在开发一个 Kotlin 项目，该项目利用 spring boot 版本 2.5.3 并使用 spring data jpa 进行数据库访问和模式定义。非常常见且直接。现在假设我们有某种

UserService

，其中包含一个方法

updateUsername

，该方法获取

username

作为参数，并在通过外部服务验证其有效性后更新用户名。为了演示该问题，我想强调一下，在验证用户名之前，我们将用户名手动设置为

"foo"

。整个工作单元应该在事务中发生，这就是为什么该方法用

@Transactional

进行注释。但由于调用外部服务，当我们等待 http 响应时，该方法将挂起（请注意这两个方法上的

suspend

关键字）。

@Service
class UserService(private val userRepository: UserRepository) {
    @Transactional
    suspend fun setUsername(id: UUID, username: String): Person {
        logger.info { "Updating username..." }
        val user = userRepository.findByIdentityId(identityId = id)
            ?: throw IllegalArgumentException("User does not exist!")

        // we update the username here but the change will be overridden after the verification to the actual username!
        user.userName = "foo"

        verifyUsername(username)

        user.userName = username
        return userRepository.save(user)
    }
    
    private suspend fun verifyUsername(username: String) {
        // assume we are doing some kind of network call here which will suspend while waiting got a response
        logger.info { "Verifying..." }
        delay(1000)
        logger.info { "Finished verifying!" }
    }
}

编译成功，我也可以执行该方法，它会启动一个新事务，但是一旦我们在调用

verifyUsername

时暂停对

delay(1000)

方法的调用，该事务就会立即提交。因此，我们的数据库实际上将保留值“foo”作为用户名，直到它被覆盖。但是，如果

verifyUsername

之后的代码失败并抛出异常，我们将无法回滚此更改，因为事务已经提交，并且 foo 将永远保留在数据库中！这绝对不是预期的行为，因为我们只想在方法的最后提交事务，因此如果出现问题，我们可以随时回滚事务。在这里您可以看到日志：

DEBUG o.s.orm.jpa.JpaTransactionManager - Creating new transaction with name [x.x.x.UserService.setUsername]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
DEBUG o.s.orm.jpa.JpaTransactionManager - Opened new EntityManager [SessionImpl(1406394125<open>)] for JPA transaction
DEBUG o.s.orm.jpa.JpaTransactionManager - Exposing JPA transaction as JDBC [org.springframework.orm.jpa.vendor.HibernateJpaDialect$HibernateConnectionHandle@9ec4d42]
INFO  x.x.x.UserService - Updating username...
DEBUG org.hibernate.SQL - select person0_.id as id1_6_, person0_.email as email2_6_, person0_.family_name as family_n3_6_, person0_.given_name as given_na4_6_, person0_.identity_id as identity5_6_, person0_.user_name as user_nam6_6_ from person person0_ where person0_.identity_id=?
INFO  x.x.x.UserService - Verifying...
DEBUG o.s.orm.jpa.JpaTransactionManager - Initiating transaction commit
DEBUG o.s.orm.jpa.JpaTransactionManager - Committing JPA transaction on EntityManager [SessionImpl(1406394125<open>)]
DEBUG org.hibernate.SQL - update person set email=?, family_name=?, given_name=?, identity_id=?, user_name=? where id=?
DEBUG o.s.orm.jpa.JpaTransactionManager - Closing JPA EntityManager [SessionImpl(1406394125<open>)] after transaction
INFO  x.x.x.UserService - Finished verifying
DEBUG o.s.orm.jpa.JpaTransactionManager - Creating new transaction with name [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
DEBUG o.s.orm.jpa.JpaTransactionManager - Opened new EntityManager [SessionImpl(319912425<open>)] for JPA transaction
DEBUG o.s.orm.jpa.JpaTransactionManager - Exposing JPA transaction as JDBC [org.springframework.orm.jpa.vendor.HibernateJpaDialect$HibernateConnectionHandle@1dd261da]
DEBUG org.hibernate.SQL - select person0_.id as id1_6_0_, person0_.email as email2_6_0_, person0_.family_name as family_n3_6_0_, person0_.given_name as given_na4_6_0_, person0_.identity_id as identity5_6_0_, person0_.user_name as user_nam6_6_0_ from person person0_ where person0_.id=?
DEBUG o.s.orm.jpa.JpaTransactionManager - Initiating transaction commit
DEBUG o.s.orm.jpa.JpaTransactionManager - Committing JPA transaction on EntityManager [SessionImpl(319912425<open>)]
DEBUG org.hibernate.SQL - update person set email=?, family_name=?, given_name=?, identity_id=?, user_name=? where id=?
DEBUG o.s.orm.jpa.JpaTransactionManager - Closing JPA EntityManager [SessionImpl(319912425<open>)] after transaction

在这篇 spring 文章中，它说“通过 Spring Framework 5.2 提供的反应式事务管理的编程变体支持协程上的事务。对于挂起功能，提供了

TransactionalOperator.executeAndAwait

扩展。”

这是否意味着

@Transactional

不能用于挂起方法，而您应该以编程方式处理事务管理？更新：此线程指出

@Transactional

应该适用于挂起函数。

我也知道，我的所有数据库操作都是同步运行的，我可以使用 r2dbc 使它们异步运行（只要我的数据库提供实现规范的驱动程序），但我认为我的问题与我如何与数据库通信，但更多关于 spring 如何使用

@Transactional

带注释的方法处理挂起调用。

您对此有何想法和建议？我绝对不是第一个在 Kotlin 中以事务方法暂停工作的开发人员，而且我仍然无法找到有关此问题的有用资源。

谢谢大家！

Answer 1

协程事务不支持 JPA，因为 JPA 是完全同步的。协程事务传播仅适用于提供反应式集成的技术，例如 MongoDB、R2DBC 或 Neo4j。

JPA 采用命令式编程模型，因此其事务管理器将事务状态存储在

ThreadLocal

存储中。反应式集成，特别是协程，使用协程上下文/Reactor 的订阅上下文来跟踪事务状态。

ThreadLocal

和 Coroutines/Project Reactor 的上下文功能之间没有任何联系。

展望未来，在协程上下文中使用 JPA 等阻塞集成需要特别注意，并且它们的事务范围需要限制在单个线程上。

Answer 2

如果你真的想做事务性的事情，比如在单个事务中更新多个表，同时保留你的功能

suspend

- 你可以这样做。

就我个人而言，我不会在

@Transactional

方法上使用

suspend

，而是以编程方式打开事务，如下所示：

@Autowired
val tx: org.springframework.transaction.support.TransactionOperations

suspend fun doTransactionStuff(...) = withContext(IO) {
 tx.execute {
    dao1.updateSomething(...)
    // downside is that you cannot suspend here, but you can block
    dao2.updateSomethingElse(...)
 }
}