超全Spring Boot/Spring Cloud 手动控制事务提交指南

后端

2023-06-24 05:20:44

揭秘 Spring Boot 和 Spring Cloud 中的手动事务控制：掌控数据完整性的艺术

数据完整性：软件开发的基石

在软件开发中，确保数据的准确性和一致性至关重要。为了保障这一目标，我们需要对数据的变更进行协调和管理，这就引入了事务管理 的概念。事务是一组原子操作，这些操作要么全部成功，要么全部失败，保证了数据的一致性。

Spring Boot 和 Spring Cloud 的事务管理

Spring Boot 和 Spring Cloud 为 Java 开发者提供了强大的工具来管理事务，包括自动事务提交。然而，在某些场景下，我们需要对事务提交时机进行手动控制，以实现更细粒度的控制。

Spring Boot 中手动控制事务

在 Spring Boot 中，有两种方式可以手动控制事务：

1. 使用 @Transactional 注解和显式调用 commit() 或 rollback() 方法：

@Transactional
public void transferMoney(long fromAccountId, long toAccountId, int amount) {
    Account fromAccount = accountRepository.findById(fromAccountId);
    Account toAccount = accountRepository.findById(toAccountId);
    fromAccount.setBalance(fromAccount.getBalance() - amount);
    toAccount.setBalance(toAccount.getBalance() + amount);
    accountRepository.save(fromAccount);
    accountRepository.save(toAccount);
    // 手动提交事务
    transactionManager.commit(status);
}

2. 使用 TransactionTemplate：

TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
    @Override
    protected void doInTransactionWithoutResult(TransactionStatus status) {
        Account fromAccount = accountRepository.findById(fromAccountId);
        Account toAccount = accountRepository.findById(toAccountId);
        fromAccount.setBalance(fromAccount.getBalance() - amount);
        toAccount.setBalance(toAccount.getBalance() + amount);
        accountRepository.save(fromAccount);
        accountRepository.save(toAccount);
    }
});

Spring Cloud 中手动控制分布式事务

当我们使用 Spring Cloud 进行微服务开发时，事务控制变得更加复杂，需要考虑分布式事务的因素。Spring Cloud 提供了以下方式来处理分布式事务：

1. 使用 @GlobalTransactional 注解：

@GlobalTransactional
public void transferMoney(long fromAccountId, long toAccountId, int amount) {
    Account fromAccount = accountRepository.findById(fromAccountId);
    Account toAccount = accountRepository.findById(toAccountId);
    fromAccount.setBalance(fromAccount.getBalance() - amount);
    toAccount.setBalance(toAccount.getBalance() + amount);
    accountRepository.save(fromAccount);
    accountRepository.save(toAccount);
}

2. 使用 FeignClient：

@FeignClient(name = "account-service")
public interface AccountServiceClient {
    @PostMapping("/accounts/transfer")
    void transferMoney(@RequestParam("fromAccountId") long fromAccountId,
                      @RequestParam("toAccountId") long toAccountId,
                      @RequestParam("amount") int amount);
}