微服务框架 SpringCloud微服务架构分布式事务 38 动手实践 38.8 案例实现TCC 模式【实现】

news2024/11/28 0:39:12

微服务框架

【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】

分布式事务

文章目录

- - 微服务框架
  - 分布式事务
  - 38 动手实践
  - - 38.8 案例实现TCC 模式【实现】
    - - 38.8.1 声明TCC 接口

38 动手实践

38.8 案例实现TCC 模式【实现】

38.8.1 声明TCC 接口

TCC的Try、Confirm、Cancel方法都需要在接口中基于注解来声明，语法如下：

在这里插入图片描述

直接试试

在account-service 中

新创建接口

package cn.itcast.account.service;

import io.seata.rm.tcc.api.BusinessActionContext;
import io.seata.rm.tcc.api.BusinessActionContextParameter;
import io.seata.rm.tcc.api.LocalTCC;
import io.seata.rm.tcc.api.TwoPhaseBusinessAction;

/**
 * ClassName: AccountTCCService
 * date: 2022/11/7 9:53
 *
 * @author DingJiaxiong
 */

@LocalTCC
public interface AccountTCCService {

    @TwoPhaseBusinessAction(name = "deduct", commitMethod = "confirm", rollbackMethod = "cancel")
    void deduct(@BusinessActionContextParameter(paramName = "userId") String userId,
                @BusinessActionContextParameter(paramName = "money") int money);

    boolean confirm(BusinessActionContext ctx);

    boolean cancel(BusinessActionContext ctx);

}

OK，这样T、C、C 就有了

创建新的 “冻结表 ”

老师已经给了资料

在这里插入图片描述

将其导入到微服务使用的数据库 seata-demo 中

在这里插入图片描述

其实两个实体类，虎哥都写好了

账户表

在这里插入图片描述

冻结表

在这里插入图片描述

mapper 也写好了【两个】

冻结表的数据层接口

在这里插入图片描述

账户表的数据层接口

在这里插入图片描述

OK，实现TCC 的业务层接口【就我们最开始写那个】

package cn.itcast.account.service.impl;

import cn.itcast.account.entity.AccountFreeze;
import cn.itcast.account.mapper.AccountFreezeMapper;
import cn.itcast.account.mapper.AccountMapper;
import cn.itcast.account.service.AccountTCCService;
import io.seata.core.context.RootContext;
import io.seata.rm.tcc.api.BusinessActionContext;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * ClassName: AccountTCCServiceImpl
 * date: 2022/11/7 10:03
 *
 * @author DingJiaxiong
 */

@Slf4j
@Service
public class AccountTCCServiceImpl implements AccountTCCService {

    //接口注入
    @Autowired
    private AccountMapper accountMapper;

    @Autowired
    private AccountFreezeMapper freezeMapper;

    //try方法【资源检测】
    @Override
    @Transactional
    public void deduct(String userId, int money) {

        //0. 获取事务id
        String xid = RootContext.getXID();

        //1. 判断freeze 中是否有冻结记录，如果有，则一定是cancel 执行过，需要拒绝业务
        AccountFreeze oldFreeze = freezeMapper.selectById(xid);
        if (oldFreeze != null){

            //cancel 执行过，需要拒绝业务
            return;
        }

        //1. 扣减可用余额
        accountMapper.deduct(userId,money);
        //2. 记录冻结金额、事务状态
        AccountFreeze freeze = new AccountFreeze();
        freeze.setUserId(userId);
        freeze.setFreezeMoney(money);
        freeze.setState(AccountFreeze.State.TRY);
        freeze.setXid(xid);

        freezeMapper.insert(freeze);
    }

    @Override
    public boolean confirm(BusinessActionContext ctx) {

        //1. 获取事务id
        String xid = ctx.getXid();

        //2. 根据id删除冻结记录
        int count = freezeMapper.deleteById(xid);
        return count == 1;
    }

    @Override
    public boolean cancel(BusinessActionContext ctx) {

        //0. 查询冻结记录
        String xid = ctx.getXid();
        String userId = ctx.getActionContext("userId").toString();
        AccountFreeze freeze = freezeMapper.selectById(xid);

        //1. 空回滚的判断，判断freeze 是否为null，为null证明try 没执行，需要空回滚
        if (freeze == null) {
            //证明try 没执行，需要空回滚
            freeze = new AccountFreeze();
            freeze.setUserId(userId);
            freeze.setFreezeMoney(0);
            freeze.setState(AccountFreeze.State.CANCEL);
            freeze.setXid(xid);

            freezeMapper.insert(freeze);
            return true;
        }

        //2. 幂等判断
        if (freeze.getState() == AccountFreeze.State.CANCEL){
            // 已经处理过一次cancel 了，无需重复处理
            return true;
        }

        //1. 恢复可用余额
        accountMapper.refund(freeze.getUserId(),freeze.getFreezeMoney());

        //2. 将冻结金额清零、状态改为cancel
        freeze.setFreezeMoney(0);
        freeze.setState(AccountFreeze.State.CANCEL);
        //更新
        int count = freezeMapper.updateById(freeze);
        return count == 1;
    }
}