registry {
  # tc服务的注册中心类，这里选择nacos，也可以是eureka、zookeeper等
  type = "nacos"
  nacos {
    # seata tc 服务注册到 nacos的服务名称，可以自定义
    application = "seata-tc-server"
    serverAddr = "127.0.0.1:8848"
    group = "DEFAULT_GROUP"
    namespace = ""
    cluster = "SH"
    username = "nacos"
    password = "nacos"
  }
}
config {
  # 读取tc服务端的配置文件的方式，这里是从nacos配置中心读取，这样如果tc是集群，可以共享配置
  type = "nacos"
  # 配置nacos地址等信息
  nacos {
    serverAddr = "127.0.0.1:8848"
    namespace = ""
    group = "SEATA_GROUP"
    username = "nacos"
    password = "nacos"
    dataId = "seataServer.properties"
  }
}

<!--seata-->
<dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
  <exclusions>
    <!--版本较低，1.3.0，因此排除--> 
    <exclusion>
      <artifactId>seata-spring-boot-starter</artifactId>
      <groupId>io.seata</groupId>
    </exclusion>
  </exclusions>
</dependency>
<dependency>
  <groupId>io.seata</groupId>
  <artifactId>seata-spring-boot-starter</artifactId>
  <!--seata starter 采用1.4.2版本-->
  <version>${seata.version}</version>
</dependency>

# 数据存储方式，db代表数据库
store.mode=db
store.db.datasource=druid
store.db.dbType=mysql
store.db.driverClassName=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true&rewriteBatchedStatements=true
store.db.user=root
store.db.password=123
store.db.minConn=5
store.db.maxConn=30
store.db.globalTable=global_table
store.db.branchTable=branch_table
store.db.queryLimit=100
store.db.lockTable=lock_table
store.db.maxWait=5000
# 事务、日志等配置
server.recovery.committingRetryPeriod=1000
server.recovery.asynCommittingRetryPeriod=1000
server.recovery.rollbackingRetryPeriod=1000
server.recovery.timeoutRetryPeriod=1000
server.maxCommitRetryTimeout=-1
server.maxRollbackRetryTimeout=-1
server.rollbackRetryTimeoutUnlockEnable=false
server.undo.logSaveDays=7
server.undo.logDeletePeriod=86400000
# 客户端与服务端传输方式
transport.serialization=seata
transport.compressor=none
# 关闭metrics功能，提高性能
metrics.enabled=false
metrics.registryType=compact
metrics.exporterList=prometheus
metrics.exporterPrometheusPort=9898

seata:
  registry: # TC服务注册中心的配置，微服务根据这些信息去注册中心获取tc服务地址
    type: nacos # 注册中心类型 nacos
    nacos:
      server-addr: 127.0.0.1:8848 # nacos地址
      namespace: "" # namespace，默认为空
      group: DEFAULT_GROUP # 分组，默认是DEFAULT_GROUP
      application: seata-tc-server # seata服务名称
      username: nacos
      password: nacos
  tx-service-group: seata-demo # 事务组名称
  service:
    vgroup-mapping: # 事务组与cluster的映射关系
      seata-demo: SH

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 javax.annotation.Resource;
import java.util.Objects;
import static cn.itcast.account.entity.AccountFreeze.State.CANCEL;
@Slf4j
@Service
public class AccountTCCServiceImpl implements AccountTCCService {
    @Autowired
    private AccountMapper accountMapper;
    @Resource
    private AccountFreezeMapper accountFreezeMapper;
    /**
     * TCC模式第一阶段Try
     *（1）扣减正常的account表的余额
     *（2）冻结资源：freeze——tbl
     * (3) 业务悬挂: try阶段cancel已经做了，
     *      我查找一次本地DB如果有一条状态为cancel的数据，就做业务悬挂
     * @param userId
     * @param money
     */
    @Override
    public void deduct(String userId, int money) {
        //获取事务id
        String xid = RootContext.getXID();
        //处理业务悬挂
        AccountFreeze freeze = accountFreezeMapper.selectById(xid);
        if (Objects.nonNull(freeze)) {
            // 说明并发场景下，别的线程提前执行完了try
            if (freeze.getState() == AccountFreeze.State.TRY ||
                // 真正的业务悬挂：尾巴比头先做
                freeze.getState() == CANCEL) {
                return;
            }
        }
        //1.扣减可用金额
        accountMapper.deduct(userId,money);
        //2.新增冻结资源
        AccountFreeze entity = new AccountFreeze();
        entity.setXid(xid);
        entity.setUserId(userId);
        entity.setFreezeMoney(money);
        entity.setState(AccountFreeze.State.TRY);
        accountFreezeMapper.insert(entity);
    }
    /**
     * 第二阶段confirm函数
     * （1）删除冻结资源-xid
     * (2) 幂等：多次相同操作返回相同的结果
     *  第一次：返回true，数据成功删除，符合预期
     *  第二次：返回false，数据没有删除成功说明已经被人删除了，所以我本身就可以不删除，符合预期
     *  N次：SQL执行异常，应该删除但是没删除所以返回false，刚好需要重试
     * @param context
     * @return
     */
    @Override
    public boolean confirm(BusinessActionContext context) {
        //1.删除冻结资源
        int rows = accountFreezeMapper.deleteById(context.getXid());
        //2.返回结果
        return rows == 1;
    }
    /**
     * 第二阶段cancel函数
     * （1）根据冻结资源恢复account表数据
     * （2）释放冻结资源
     * （3）空回滚: cancel阶段try没做
     * （4）幂等
     * @param context
     * @return
     */
    @Override
    public boolean cancel(BusinessActionContext context) {
        // 1-根据冻结资源恢复account表数据
        // 1.1 查找当前冻结资源信息
        AccountFreeze freeze = accountFreezeMapper.selectById(context.getXid());
        //空回滚
        if (Objects.isNull(freeze)) {
            AccountFreeze entity = new AccountFreeze();
            entity.setXid(context.getXid());
            entity.setUserId(context.getActionContext("userId").toString());
            entity.setFreezeMoney(0);
            entity.setState(CANCEL);
            accountFreezeMapper.insert(entity);
            return true;
        }
        //幂等
        if (freeze.getState() == CANCEL) {
            return true;
        }
        //1.2恢复数据
        String userId = freeze.getUserId();
        Integer money = freeze.getFreezeMoney();
        accountMapper.refund(userId,money);
        //2.释放冻结资源
        AccountFreeze updateEntity = new AccountFreeze();
        updateEntity.setXid(context.getXid());
        updateEntity.setState(CANCEL);
        updateEntity.setFreezeMoney(0);
        int rows = accountFreezeMapper.updateById(updateEntity);
        return rows == 1;
    }
}