升级后异步事务保存在 Spring 中不起作用

Question

我们将 Spring Boot 从 1.5.8 升级到 2.6.2。它引入了一个让我们困惑的问题：事务保存不是从生成的线程内部进行处理的。

我们在 Mysql 数据库上使用 JPA 托管实体，并调用 CrudRepository 来保存它们。

主线程内的事务工作正常。然而，当从异步操作调用时，事情就会出错：

• 异步和同步调用都通过 Spring SimpleJpaRepository.save() 方法。但在异步操作的情况下，entityManager 返回的对象以 null id 持久保存。
• 我跟踪了这​​两种类型的调用流程，可以看到保存传播到了 org.hibernate.internal.SessionImpl 服务。
• 从那里它进入 AbstractSaveEventListener.class，这就是出现差异的地方。在 PerformSaveOrReplicate 方法 (hibernate-core:5.6.3) 中，inTrx 布尔值在异步工作流程中为 false，而在同步工作流程中为 true。因此，shouldDelayIdentityInserts 标志被设置，并且似乎不会为该线程中的任何实体生成 id。

我们尝试了不同的方法来使其发挥作用。例如，我们在这里使用 transactionTemplate 进行一些特定的控制，但这并没有改变行为。

我们最初是通过使用 ApplicationEventPublisher 创建事件来创建此异步流程。我们还尝试使用 completablefuture 和其他具有相同结果的构造，以及使用 @Async 注释该方法并直接调用它。

Answer 1

问题是，随着升级到 Spring Boot 2.6，Spring Batch 实现了新的事务管理器。

我们没有意识到的是，这个事务管理器被自动连接到我们的其他服务中，并且在这个线程上下文中不起作用。您不想与 API/杂项服务共享批处理 Tx 管理器。在那里声明一个特定的事务管理器以将它们分开解决了这个问题。

下面是一个使用 Primary 注释标记 PlatformTransactionManager 以显式测试其用法的示例。

@Primary
@Bean
public PlatformTransactionManager platformTransactionManager(DataSource dataSource) {
    JpaTransactionManager transactionManager = new JpaTransactionManager();
    transactionManager.setEntityManagerFactory(entityManagerFactory(dataSource).getObject());
    return transactionManager;
}