微服务架构设计skill实战：如何解决分布式事务与数据一致性难题

3次阅读

没有评论

共计 2738 个字符，预计需要花费 7 分钟才能阅读完成。

在电商系统中，用户下单往往涉及多个微服务的协同操作。例如：

订单服务 创建订单记录
库存服务 扣减商品库存
支付服务 处理支付流程
积分服务 增加用户积分

这种场景下，如果某个服务调用失败（如库存不足），系统必须保证所有服务的数据状态能够回滚，否则会出现 ” 已支付但无库存 ” 的业务异常。这就是典型的分布式事务强一致性需求。

优点：强一致性保证
缺点：
同步阻塞（性能差，通常 QPS<500）
协调者单点故障风险
不适合长事务

实现方式：
将事务拆分为多个本地事务
通过事件 / 命令驱动执行
失败时触发补偿操作
特点：
最终一致性（QPS 可达 3000+）
业务侵入性中等
需设计完善的补偿机制

核心阶段：
Try：预留资源
Confirm：确认操作
Cancel：取消预留
优势：
高并发支持（QPS 可达 5000+）
避免长事务锁竞争
挑战：
业务代码复杂度高
需处理空回滚和悬挂问题

适用场景：
对实时性要求不高的业务
跨系统最终一致性
局限：
消息积压风险
需额外维护消息状态

# application.yml 关键配置
seata:
  enabled: true
  application-id: order-service
  tx-service-group: my_tx_group
  service:
    vgroup-mapping:
      my_tx_group: default
  registry:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      namespace: ""
      cluster: default
  config:
    type: nacos
    nacos:
      server-addr: 127.0.0.1:8848
      namespace: ""
      group: SEATA_GROUP

// 库存服务 TCC 接口
public interface InventoryTccService {@TwoPhaseBusinessAction(name = "prepareDeduct", commitMethod = "confirm", rollbackMethod = "cancel")
    boolean prepareDeduct(@BusinessActionContextParameter(paramName = "productId") String productId,
                         @BusinessActionContextParameter(paramName = "count") int count);

    boolean confirm(BusinessActionContext context);

    boolean cancel(BusinessActionContext context);
}

// 实现类（关键防悬挂处理）@Service
public class InventoryTccServiceImpl implements InventoryTccService {

    @Autowired
    private InventoryMapper inventoryMapper;

    @Override
    public boolean prepareDeduct(String productId, int count) {
        // 检查悬挂：如果已有 confirm/cancel 记录则直接返回
        if(checkTransactionExists(productId)) {return false;}

        // 预扣减（实际是冻结库存）return inventoryMapper.freezeStock(productId, count) > 0;
    }

    @Override
    @Transactional
    public boolean confirm(BusinessActionContext context) {String productId = context.getActionContext("productId");
        int count = (int) context.getActionContext("count");

        // 幂等检查
        if(checkConfirmed(productId)) {return true;}

        // 实际扣减库存
        inventoryMapper.reduceStock(productId, count);
        // 释放冻结
        inventoryMapper.unfreezeStock(productId, count);

        return true;
    }

    @Override
    @Transactional
    public boolean cancel(BusinessActionContext context) {String productId = context.getActionContext("productId");
        int count = (int) context.getActionContext("count");

        // 空回滚检查（没有 prepare 记录）if(!checkPrepareExists(productId)) {
            // 插入空回滚记录
            insertCancelRecord(productId);
            return true;
        }

        // 恢复冻结库存
        inventoryMapper.unfreezeStock(productId, count);

        return true;
    }
}