在 Spring 中使用事务处理异步执行：一个常见的陷阱以及如何解决它

在现代 spring 应用程序中，将异步执行与事务行为相结合是很常见的。但是，使用 @async 和 @transactional(propagation = propagation.requires_new) 注解方法可能会导致意外行为，因为 spring 管理异步任务和事务。

在本文中，我们将详细探讨该问题并演示正确处理异步执行和事务管理的解决方案。

问题：@async 和 @transactional(propagation = propagation.requires_new)

考虑以下代码片段：

@async
@transactional(propagation = propagation.requires_new)
public void savesomething() {
    // save-point one
    // save-point two
}

乍一看，似乎一切都按预期进行。但是，此配置存在一些关键问题，可能会导致意外行为。

幕后发生了什么？

• @async 注解：

@async 注解告诉 spring 在单独的线程中异步运行该方法。这意味着该方法不会在调用它的原始线程中运行，而是会被卸载到线程池中的另一个线程。
spring 使用代理来管理异步方法。当您调用使用 @async 注解的方法时，spring 将执行委托给在不同线程中运行该方法的内部 executor。

• @transactional(propagation = propagation.requires_new) 注释：

@transactional(propagation = propagation.requires_new) 注释可确保为该方法启动一个新事务，无论任何现有事务如何。它挂起调用线程中的任何活动事务并为该方法开始一个新事务。

spring 中的事务管理通常是线程绑定的，这意味着事务上下文与当前线程绑定。

冲突

出现这个问题是因为@async在不同的线程中运行该方法，而spring的事务管理依赖于线程来绑定事务。当该方法异步执行时，来自调用线程的事务上下文不会传播到新线程，这会导致以下问题：

• @transactional 注解不会在异步线程中创建新事务，任何事务行为（如回滚、提交等）都不会被正确处理。
• requires_new 传播设置将不适用，因为异步方法在原始事务上下文之外运行。

解决方案：解耦异步执行和事务

为了解决这个问题，您可以通过在单独的服务方法中处理事务来将异步执行与事务逻辑解耦。具体方法如下：

• 第 1 步：为事务逻辑创建新的同步服务
  创建一个处理事务逻辑的新服务。该方法将同步执行（不使用@async）以确保事务管理按预期工作。

• 第2步：异步调用同步方法
  然后，您可以使用 @async 异步调用同步事务方法。这确保了在主线程中正确处理事务逻辑，并且仍然保持异步行为。

重构后的代码如下所示：

@Service
public class MyService {

    private final TransactionalService transactionalService;

    public MyService(TransactionalService transactionalService) {
        this.transactionalService = transactionalService;
    }

    @Async
    public void saveSomethingAsync() {
        transactionalService.saveSomething();  // Call the synchronous transactional method asynchronously
    }
}

@Service
public class TransactionalService {

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void saveSomething() {
        // save-point one
        // save-point two
    }
}

它是如何运作的？

重构后的解决方案中，通过使用 @async 注解 savesomethingasync() 方法来实现异步执行。这意味着当调用 savesomethingasync() 时，它将在由 spring 的异步任务执行器管理的单独线程中运行。在不同的线程中运行它允许主线程继续执行，而无需等待 savesomethingasync() 完成。这种方法对于您想要卸载长时间运行的任务、提高响应能力或同时处理独立操作的场景很有用。

对于事务行为，transactionalservice 中的 savesomething() 方法用 @transactional(propagation = propagation.requires_new) 进行注释。这确保每次调用 savesomething() 都会创建一个独立于调用方法中任何现有事务的新事务。 requires_new 传播启动一项新事务并暂停任何现有事务，从而允许 savesomething() 在隔离的事务上下文中进行操作。这意味着即使原始调用方法有事务，savesomething() 也将在其自己的单独事务中工作，从而仅针对此操作启用受控提交和回滚。

通过将异步执行与事务逻辑解耦，我们确保事务管理按预期工作。在此设置中，事务上下文在 savesomething() 方法中保持正确处理，而 savesomethingasync() 方法继续在单独的线程中执行。这种关注点分离可以兼具异步处理和可靠事务管理的优点，即使在并发处理时也能实现独立且安全的数据操作。

何时使用此方法？

• 当事务隔离至关重要时：如果您需要确保某些操作在单独的事务中执行（即 requires_new），则此方法效果很好。

• 异步操作：如果您有长时间运行的独立任务，需要异步执行，但也需要自己的事务边界。

替代方案：使用消息队列实现完全解耦

如果您需要更高级的解耦或希望处理重试、错误处理和长时间运行的流程，请考虑将任务卸载到 kafka 或 rabbitmq 等消息队列。通过使用消息队列，可以确保每个任务在自己的上下文中运行，并且可以独立管理事务。

以上就是在 Spring 中使用事务处理异步执行：一个常见的陷阱以及如何解决它的详细内容，更多请关注其它相关文章！