分布式事务TCC框架

https://github.com/yu199195/happylifeplat-tcc
支持spring cloud， dubbo

tcc 定义

服务层分布式事务 TCC，基于服务层面的
在TCC中这些接口为：try、confirm、cancel（缩写为TCC）。TCC事务管理器会使用try、confirm、cancel接口协调多个服务进行事务处理

image.png

       Try: 尝试执行业务
             • 完成所有业务检查(一致性)
             • 预留必须业务资源(准隔离性)          
        Confirm:确认执行业务
             • 真正执行业务
             • 不作任何业务检查
             • 只使用Try阶段预留的业务资源 
             • Confirm操作要满足幂等性
        Cancel: 取消执行业务
             • 释放Try阶段预留的业务资源 
             • Cancel操作要满足幂等性

流程图

image.png

分析

/**
     * 订单支付接口（注意这里模拟的是创建订单并进行支付扣减库存等操作）
     * @param count 购买数量
     * @param amount 支付金额
     * @return
     */
    @Override
    public String orderPay(Integer count, BigDecimal amount) {
        final Order order = buildOrder(count, amount);
        final int rows = orderMapper.save(order);

        if (rows > 0) {
            paymentServiceImpl.makePayment(order);
        }


        return "success";
    }

@Tcc(confirmMethod = "confirmOrderStatus", cancelMethod = "cancelOrderStatus")
    public void makePayment(Order order) {
        order.setStatus(OrderStatusEnum.PAYING.getCode());
        orderMapper.update(order);
        //扣除用户余额
        AccountDTO accountDTO = new AccountDTO();
        accountDTO.setAmount(order.getTotalAmount());
        accountDTO.setUserId(order.getUserId());

        LOGGER.debug("===========执行springcloud扣减资金接口==========");
        accountClient.payment(accountDTO);


        //进入扣减库存操作
        InventoryDTO inventoryDTO = new InventoryDTO();
        inventoryDTO.setCount(order.getCount());
        inventoryDTO.setProductId(order.getProductId());
        inventoryClient.decrease(inventoryDTO);
    }

1：创建订单并进行支付扣减库存等操作
2：创建订单
3：更改订单状态，扣减用户余额 [账户服务]
4：扣减库存操作 [库存服务]
看当前订单系统，的tcc的确认和取消方法

/**
     * 确认提交成功 订单为支付成功的状态
     * @param order
     */
    public void confirmOrderStatus(Order order) {

        order.setStatus(OrderStatusEnum.PAY_SUCCESS.getCode());
        orderMapper.update(order);
        LOGGER.info("=========进行订单confirm操作完成================");
    }

    /**
     * 提交失败，更新订单为 支付失败的状态
     * @param order
     */
    public void cancelOrderStatus(Order order) {

        order.setStatus(OrderStatusEnum.PAY_FAIL.getCode());
        orderMapper.update(order);
        LOGGER.info("=========进行订单cancel操作完成================");
    }