Java微服务分布式事务框架seata的TCC模式

╰半橙微兮° 2024-04-23 21:08 90阅读 0赞

?作者主页：青花锁 ?简介：Java领域优质创作者?、Java微服务架构公号作者?

?简历模板、学习资料、面试题库、技术互助

?文末获取联系方式 ?

![在这里插入图片描述][8e79f79251004be596a5f46b79e5197a.png]

--------------------

## 往期热门专栏回顾 ##

<table> 
 <thead> 
  <tr> 
   <th align="left">专栏</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">Java项目实战</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12345409.html" rel="nofollow">介绍Java组件安装、使用；手写框架等</a></td> 
  </tr> 
  <tr> 
   <td align="left">Aws服务器实战</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12492968.html" rel="nofollow">Aws Linux服务器上操作nginx、git、JDK、Vue</a></td> 
  </tr> 
  <tr> 
   <td align="left">Java微服务实战</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12439818.html" rel="nofollow">Java 微服务实战，Spring Cloud Netflix套件、Spring Cloud Alibaba套件、Seata、gateway、shadingjdbc等实战操作 </a></td> 
  </tr> 
  <tr> 
   <td align="left">Java基础篇</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12369312.html" rel="nofollow">Java基础闲聊，已出HashMap、String、StringBuffer等源码分析，JVM分析，持续更新中 </a></td> 
  </tr> 
  <tr> 
   <td align="left">Springboot篇</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12273537.html" rel="nofollow">从创建Springboot项目，到加载数据库、静态资源、输出RestFul接口、跨越问题解决到统一返回、全局异常处理、Swagger文档 </a></td> 
  </tr> 
  <tr> 
   <td align="left">Spring MVC篇</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12295009.html" rel="nofollow">从创建Spring MVC项目，到加载数据库、静态资源、输出RestFul接口、跨越问题解决到统一返回 </a></td> 
  </tr> 
  <tr> 
   <td align="left">华为云服务器实战</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12426609.html" rel="nofollow">华为云Linux服务器上操作nginx、git、JDK、Vue等，以及使用宝塔运维操作添加Html网页、部署Springboot项目/Vue项目等 </a></td> 
  </tr> 
  <tr> 
   <td align="left">Java爬虫</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_8863085.html" rel="nofollow">通过Java+Selenium+GoogleWebDriver 模拟真人网页操作爬取花瓣网图片、bing搜索图片等 </a></td> 
  </tr> 
  <tr> 
   <td align="left">Vue实战</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12278346.html" rel="nofollow">讲解Vue3的安装、环境配置，基本语法、循环语句、生命周期、路由设置、组件、axios交互、Element-ui的使用等 </a></td> 
  </tr> 
  <tr> 
   <td align="left">Spring</td> 
   <td align="left"><a href="https://blog.csdn.net/s445320/category_12283629.html" rel="nofollow">讲解Spring(Bean)概念、IOC、AOP、集成jdbcTemplate/redis/事务等 </a></td> 
  </tr> 
 </tbody> 
</table>

--------------------

## 系列文章目录 ##

[第一章 Java线程池技术应用][Java]  
[第二章 CountDownLatch和Semaphone的应用][CountDownLatch_Semaphone]  
[第三章 Spring Cloud 简介][Spring Cloud]  
[第四章 Spring Cloud Netflix 之 Eureka][Spring Cloud Netflix _ Eureka]  
[第五章 Spring Cloud Netflix 之 Ribbon][Spring Cloud Netflix _ Ribbon]  
[第六章 Spring Cloud 之 OpenFeign][Spring Cloud _ OpenFeign]  
[第七章 Spring Cloud 之 GateWay][Spring Cloud _ GateWay]  
[第八章 Spring Cloud Netflix 之 Hystrix][Spring Cloud Netflix _ Hystrix]  
[第九章 代码管理gitlab 使用][_gitlab]  
[第十章 SpringCloud Alibaba 之 Nacos discovery][SpringCloud Alibaba _ Nacos discovery]  
[第十一章 SpringCloud Alibaba 之 Nacos Config][SpringCloud Alibaba _ Nacos discovery]  
[第十二章 Spring Cloud Alibaba 之 Sentinel][Spring Cloud Alibaba _ Sentinel]  
[第十三章 JWT][JWT]  
[第十四章 RabbitMQ应用][RabbitMQ]  
[第十五章 RabbitMQ 延迟队列][RabbitMQ 1]  
[第十六章 spring-cloud-stream][spring-cloud-stream]  
[第十七章 Windows系统安装Redis、配置环境变量][Windows_Redis]  
[第十八章 查看、修改Redis配置，介绍Redis类型][_Redis_Redis]  
[第十九章 Redis RDB AOF][Redis RDB AOF]  
[第二十章 Spring boot 操作 Redis][Spring boot _ Redis]  
[第二十一章 Java多线程安全与锁][Java 1]  
[第二十二章 Java微服务分布式事务框架seata][Java_seata]  
[第二十三章 Java微服务分布式事务框架seata的TCC模式][Java_seata_TCC]

--------------------

#### 文章目录 ####

*  往期热门专栏回顾
 *  系列文章目录
 *  前言
 *  1、TCC模式
 *   *  1.1、AT 模式（参考链接 TBD）基于 支持本地 ACID 事务 的 关系型数据库
     *   *  1.1.1、 一阶段 prepare 行为
         *  1.1.2、二阶段 commit 行为
         *  1.1.3、二阶段 rollback 行为
     *  1.2、TCC 模式，不依赖于底层数据资源的事务支持
     *   *  1.2.1、一阶段 prepare 行为
         *  1.2.2、二阶段 commit 行为
         *  1.2.3、二阶段 rollback 行为
 *  2、例子
 *   *  2.1、定义controller
     *  2.2、定义service

--------------------

## 前言 ##

上一章节介绍微服务分布式项目中，使用的事务框架seata，本章节介绍分布式事务框架seata TCC模式，以及集成到Springboot、微服务框架里。

## 1、TCC模式 ##

一个分布式的全局事务，整体是 两阶段提交 的模型。全局事务是由若干分支事务组成的，分支事务要满足 两阶段提交 的模型要求，即需要每个分支事务都具备自己的：

*  一阶段 prepare 行为
 *  二阶段 commit 或 rollback 行为  
    ![在这里插入图片描述][f2d3f09a58af47f78c79e3b98a794961.png]

根据两阶段行为模式的不同，我们将分支事务划分为 Automatic (Branch) Transaction Mode 和 TCC (Branch) Transaction Mode.

### 1.1、AT 模式（参考链接 TBD）基于 支持本地 ACID 事务 的 关系型数据库 ###

#### 1.1.1、 一阶段 prepare 行为 ####

在本地事务中，一并提交业务数据更新和相应回滚日志记录。

#### 1.1.2、二阶段 commit 行为 ####

马上成功结束，自动 异步批量清理回滚日志。

#### 1.1.3、二阶段 rollback 行为 ####

通过回滚日志，自动 生成补偿操作，完成数据回滚。

### 1.2、TCC 模式，不依赖于底层数据资源的事务支持 ###

#### 1.2.1、一阶段 prepare 行为 ####

调用 自定义 的 prepare 逻辑。try

#### 1.2.2、二阶段 commit 行为 ####

调用 自定义 的 commit 逻辑。confirm

#### 1.2.3、二阶段 rollback 行为 ####

调用 自定义 的 rollback 逻辑。cancel

## 2、例子 ##

### 2.1、定义controller ###

/**
     * 采购
     */
    @PostMapping("/purchaseTCC")
    @GlobalTransactional
    public String purchaseTCC(@RequestBody OrderDTO orderDTO){
        
        this.businessTCCService.purchase(orderDTO);
        return "success";
    }

### 2.2、定义service ###

@LocalTCC
    public interface BusinessTCCService {
        
        /**
         * 采购 执行资源检查及预留操作
         */
        @TwoPhaseBusinessAction(name = "purchase",commitMethod = "commit",rollbackMethod = "rollback")
        public void purchase(@BusinessActionContextParameter(paramName = "orderDTO") OrderDTO orderDTO);
    
        /**
         * 全局事务进行提交
         * @param businessActionContext
         * @return
         */
        boolean commit(BusinessActionContext businessActionContext);
    
        /**
         * 全局事务进行不回滚
         * @param businessActionContext
         * @return
         */
        boolean rollback(BusinessActionContext businessActionContext);
    }

package com.xxxx.store.business.service.impl;
    
    import cn.hutool.crypto.SecureUtil;
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.JSONObject;
    import com.xxxx.store.business.service.BusinessService;
    import com.xxxx.store.business.service.BusinessTCCService;
    import com.xxxx.store.business.service.OrderService;
    import com.xxxx.store.business.service.StorageService;
    import com.xxxx.store.common.dto.OrderDTO;
    import com.xxxx.store.common.dto.StorageDTO;
    import io.seata.rm.tcc.api.BusinessActionContext;
    import io.seata.spring.annotation.GlobalTransactional;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Service;
    
    import java.io.File;
    
    @Service
    public class BusinessTCCServiceImpl implements BusinessTCCService {
        
        @Value("${file.path}")
        private String filePath;
        @Autowired
        private OrderService orderService;
        @Autowired
        private StorageService storageService;
    
        @Override
        public void purchase(OrderDTO orderDTO) {
        
            //减库存
            this.storageService.deduct(new StorageDTO(null,orderDTO.getCommodityCode(),orderDTO.getCount()));
            //创建订单
            this.orderService.create(orderDTO);
        }
    
        @Override
        public boolean commit(BusinessActionContext businessActionContext) {
        
            System.out.println("事务ID：" + businessActionContext.getXid());
            return true;
        }
    
        @Override
        public boolean rollback(BusinessActionContext businessActionContext) {
        
            JSONObject jSONObject = (JSONObject)businessActionContext.getActionContext("orderDTO");
    
            OrderDTO orderDTO = jSONObject.toJavaObject(OrderDTO.class);
            StorageDTO storageDTO = new StorageDTO(null, orderDTO.getCommodityCode(), orderDTO.getCount());
    
            String s = JSON.toJSONString(storageDTO);
            String md5 = SecureUtil.md5(s);
            System.out.println("**************触发回滚操作：" + filePath + md5);
            File file = new File(filePath + md5);
            file.delete();
            return true;
        }
    
        /*@Override
        public void purchase(OrderDTO orderDTO) {
            //减库存
            this.storageService.deduct(new StorageDTO(null,orderDTO.getCommodityCode(),orderDTO.getCount()));
            //创建订单
            this.orderService.create(orderDTO);
        }*/
    
    }

<table> 
 <thead> 
  <tr> 
   <th align="left">注解</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">@LocalTCC</td> 
   <td align="left">一定需要注解在接口上，否则不生效，此接口可以是寻常的业务接口，只要实现了TCC的两阶段提交对应方法便可，适用于SpringCloud+Feign模式下的TCC。</td> 
  </tr> 
  <tr> 
   <td align="left">@TwoPhaseBusinessAction</td> 
   <td align="left">注解try方法，其中name为当前tcc方法的bean名称，写方法名便可（全局唯一），commitMethod指向提交方法，rollbackMethod指向事务回滚方法。指定好三个方法之后，seata会根据全局事务的成功或失败，自动调用提交方法或者回滚方法。</td> 
  </tr> 
  <tr> 
   <td align="left">@BusinessActionContextParameter</td> 
   <td align="left">使用该注解可以将参数传递到二阶段commit或者rollback的方法中，方便调用。</td> 
  </tr> 
  <tr> 
   <td align="left">BusinessActionContext</td> 
   <td align="left">TCC事务上下文，使用BusinessActionContext.getActionContext(“params”)便可以得到一阶段try中定义的参数，在二阶段参考此参数进行业务回滚操作。</td> 
  </tr> 
 </tbody> 
</table>

建议:可以在try方法中使用@Transational，直接通过spring来控制关系型数据库的事务，进行回滚的操作，而非关系型数据库等中间件的回滚操作可以交给rollbackMethod方法处理。

建议:try接口不可以捕获异常，否则TCC将识别该操作为成功，直接执行二阶段commit方法。

--------------------

资料获取，更多粉丝福利，关注下方公众号获取

![在这里插入图片描述][a74f7d5d03234f7c8a635562034442a0.gif_pic_center]

[8e79f79251004be596a5f46b79e5197a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/23/21fe538a2f634b15902e3032813c82d3.png
[Java]: https://blog.csdn.net/s445320/article/details/132870714
[CountDownLatch_Semaphone]: https://blog.csdn.net/s445320/article/details/132912126
[Spring Cloud]: https://blog.csdn.net/s445320/article/details/132939152
[Spring Cloud Netflix _ Eureka]: https://blog.csdn.net/s445320/article/details/133024912
[Spring Cloud Netflix _ Ribbon]: https://blog.csdn.net/s445320/article/details/133156575
[Spring Cloud _ OpenFeign]: https://blog.csdn.net/s445320/article/details/130624259
[Spring Cloud _ GateWay]: https://blog.csdn.net/s445320/article/details/133612365
[Spring Cloud Netflix _ Hystrix]: https://blog.csdn.net/s445320/article/details/133759729
[_gitlab]: https://blog.csdn.net/s445320/article/details/133842594
[SpringCloud Alibaba _ Nacos discovery]: https://blog.csdn.net/s445320/article/details/133977189
[Spring Cloud Alibaba _ Sentinel]: https://blog.csdn.net/s445320/article/details/134149339
[JWT]: https://blog.csdn.net/s445320/article/details/134197122
[RabbitMQ]: https://blog.csdn.net/s445320/article/details/134228181
[RabbitMQ 1]: https://blog.csdn.net/s445320/article/details/130823776
[spring-cloud-stream]: https://blog.csdn.net/s445320/article/details/134360837
[Windows_Redis]: https://blog.csdn.net/s445320/article/details/134361033
[_Redis_Redis]: https://blog.csdn.net/s445320/article/details/134591045
[Redis RDB AOF]: https://blog.csdn.net/s445320/article/details/136615331
[Spring boot _ Redis]: https://blog.csdn.net/s445320/article/details/136617602
[Java 1]: https://blog.csdn.net/s445320/article/details/136641717
[Java_seata]: https://blog.csdn.net/s445320/article/details/136806573
[Java_seata_TCC]: https://blog.csdn.net/s445320/article/details/136928879
[f2d3f09a58af47f78c79e3b98a794961.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/23/3ea8c13c888545f2a31169cd5c3ad155.png
[a74f7d5d03234f7c8a635562034442a0.gif_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/23/a7b73885e4e74c8098d2f15afd8597e9.gif