分布式事务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操作完成================");
}
源码分析
- aop拦截注解
- 每次try会生成在每个微服务的数据库中事务记录表中添加一条记录
- 后台开启30秒线程定时对 事务记录做补偿 执行cancel或者confirm方法
- 没有一个独立的协调服务，都是在本地完成的
