使用Spring Boot实现分布式事务

在Spring Boot中实现分布式事务通常涉及到使用两阶段提交（2PC, Two-Phase Commit）协议或者基于消息的最终一致性实现。以下是一个使用Seata作为分布式事务解决方案的简单示例。

1. 添加Seata依赖到pom.xml：

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

2. 配置application.yml以使用Seata：

spring:
  cloud:
    alibaba:
      seata:
        tx-service-group: my_tx_group
        service:
          grouplist:
            default: 127.0.0.1:8091

3. 在业务代码中使用@GlobalTransactional注解来标注需要参与分布式事务的方法：

import io.seata.spring.annotation.GlobalTransactional;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
@Service
public class BusinessService {
 
    @Autowired
    private JdbcTemplate jdbcTemplate;
 
    @GlobalTransactional
    @Transactional
    public void purchaseCommodity(int userId, int commodityCode, int orderCount) {
        // 扣减用户账户余额
        jdbcTemplate.update("update account_tbl set balance = balance - ? where user_id = ?", orderCount * 10, userId);
        
        // 减少商品库存
        jdbcTemplate.update("update commodity_tbl set count = count - ? where code = ?", orderCount, commodityCode);
        
        // 记录订单
        jdbcTemplate.update("insert into orders_tbl (user_id, commodity_code, count) values (?, ?, ?)", userId, commodityCode, orderCount);
    }
}

确保所有涉及到的数据库操作都使用了Seata的分布式事务管理。在实际部署时，需要确保Seata Server正在运行并且客户端可以连接到它。