用TCC来解决多个第三方系统数据一致性问题

2024-09-01 22:04

本文主要是介绍用TCC来解决多个第三方系统数据一致性问题,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

对于做集成的公司来说,会集成各种第三方系统,要么是通过第三方系统的api,要么直接集成第三方系统的设备。如果是通过api集成,单次请求只调用一个三方系统没问题,同步调用就行,但如果同时要调用多个三方系统,并且需要三方系统都成功的时候才算该次请求成功调用,这种情况只要后面调用的系统发生报错,前面系统如果不删除产生的数据,就会遗留在三方系统中,产生脏数据。这种集成的三方系统,不是我方能够控制的,我们不能修改他们的代码。

下图是产生该问题的一个场景:
在这里插入图片描述

这里我尝试使用了TCC来处理多个三方系统的数据一致问题,以添加人脸为例来说明:
在这里插入图片描述

  • try阶段依次调用每个三方系统的新增人脸接口,每个三方系统调用成功后,把我方功能主键ID(比如人脸id)、三方返回数据(三方系统人脸id)、操作类型(比如新增),三方系统唯一标识(比如third1)存储到临时记录表里
  • confirm阶段暂时没用
  • cancel阶段,如果try阶段,某一个三方系统报错了,TCC就会执行到该阶段。该阶段要把try阶段已经执行成功的记录查询出来,调用三方系统的删除接口

经过以上步骤以此来完成脏数据的删除。

TCC我们要考虑以下的几种情况:

  1. 新增出错-删除回调:
    try阶段:每个三方系统调用成功后,将我方功能主键ID、三方系统主键、操作类型(ADD)、三方唯一标识(third1、third2)记下里
    在这里插入图片描述
    cancel阶段:根据我方功能主键ID,操作类型(ADD)查询出所有记录,再循环调用三方删除接口

  2. 修改出错-修改回调:
    try阶段:先从我方系统的映射表中查询出对应的三方系统主键,随后根据三方系统主键调用三方系统查询详情接口,存储到记录表,操作类型(UPDATE)
    cancel阶段:根据我方功能主键ID,操作类型(UPDATE),以THIRD字段分组,查询出最新记录,封装参数,循环调用三方更新接口,更新回原来的数据

  3. 删除出错-新增回调:
    try阶段:先从我方系统的映射表中查询出对应的三方系统主键,随后根据三方系统主键调用三方系统查询详情接口,存储到记录表,操作类型(DELETE)
    cancel阶段:根据我方功能主键ID,操作类型(DELETE),查询出最新记录,封装参数,循环调用三方新增接口,把删除的数据加回来,随后再更新我方系统映射表中三方主键id

这是使用TCC来解决的多个三方数据一致性问题,这种方案数据查询,参数封装都需要手动写代码处理,比较繁琐,我之前还提供过另外一种方案,通过注解进行声明,由框架解析注解来自动处理,代码量少很多,不过我的代码还有很多要优化完善的地方,但我想这种思想是好的,可以看看https://itsaysay.blog.csdn.net/article/details/126072080

贴出TCC部分的代码看一下,源码可以查看 https://github.com/jujunchen/tcc-third-transaction:

package csdn.itsaysay.we.service.handler;import java.util.List;
import java.util.Objects;import javax.annotation.Resource;import org.mengyun.tcctransaction.api.Compensable;
import org.mengyun.tcctransaction.api.UniqueIdentity;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import com.baomidou.mybatisplus.core.toolkit.Wrappers;import csdn.itsaysay.we.bean.Third;
import csdn.itsaysay.we.bean.model.FaceDO;
import csdn.itsaysay.we.bean.model.ThirdHistoryDO;
import csdn.itsaysay.we.mapper.ThirdHistoryMapper;
import csdn.itsaysay.we.third.feign.ThirdFeignClient;
import csdn.itsaysay.we.third.third1.T1FaceService;
import csdn.itsaysay.we.third.third2.T2FaceService;
import lombok.extern.slf4j.Slf4j;@Slf4j
@Service
public class FaceAdd {@Resourceprivate T1FaceService third1FaceService;@Resourceprivate T2FaceService third2FaceService;@Resourceprivate ThirdHistoryMapper thirdHistoryMapper;@Resourceprivate ThirdFeignClient thirdFeignClient;@Compensable(confirmMethod = "confirmFaceAdd", cancelMethod = "cancelFaceAdd")@Transactionalpublic void tryFaceAdd(@UniqueIdentity FaceDO face) {log.info("------->we try");//把第三方接口独立成服务,通过feign去调用
//		FaceAddReq req = BeanUtil.copyProperties(face, FaceAddReq.class);
//		thirdFeignClient.faceAdd(req);//直接写在当前服务里面String id1 = third1FaceService.faceAdd(face);thirdHistoryMapper.insert(buildModel(face.getId(), id1, Third.ADD, Third.THIRD1));String id2 = third2FaceService.faceAdd(face);thirdHistoryMapper.insert(buildModel(face.getId(), id2, Third.ADD, Third.THIRD2));}public void confirmFaceAdd(FaceDO face) {log.info("------->we confirm");}public void cancelFaceAdd(FaceDO face) {log.info("------->we cancel");List<ThirdHistoryDO> faceThirdDOs = thirdHistoryMapper.selectList(Wrappers.<ThirdHistoryDO>lambdaQuery().eq(ThirdHistoryDO::getWeData, face.getId()).eq(ThirdHistoryDO::getRtype, Third.ADD));for (ThirdHistoryDO thirdHistoryDO : faceThirdDOs) {//如果只有几个的话,可以单独指定,如果是不确定有几个的话,还要根据third字段唯一标识来获取应该调用哪个第三方if (Objects.equals(thirdHistoryDO.getThird(), Third.THIRD1)) {third1FaceService.faceDelete(thirdHistoryDO.getThirdData());}if (Objects.equals(thirdHistoryDO.getThird(), Third.THIRD2)) {third1FaceService.faceDelete(thirdHistoryDO.getThirdData());}}}private ThirdHistoryDO buildModel(Integer id, String thirdId, String rtype, String third) {ThirdHistoryDO thirdHistoryDO = new ThirdHistoryDO();thirdHistoryDO.setWeData(String.valueOf(id));thirdHistoryDO.setThirdData(thirdId);thirdHistoryDO.setRtype(rtype);thirdHistoryDO.setThird(third);return thirdHistoryDO;}}

这篇关于用TCC来解决多个第三方系统数据一致性问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1128171

相关文章

Java利用JSONPath操作JSON数据的技术指南

《Java利用JSONPath操作JSON数据的技术指南》JSONPath是一种强大的工具,用于查询和操作JSON数据,类似于SQL的语法,它为处理复杂的JSON数据结构提供了简单且高效... 目录1、简述2、什么是 jsONPath?3、Java 示例3.1 基本查询3.2 过滤查询3.3 递归搜索3.4

Python实现无痛修改第三方库源码的方法详解

《Python实现无痛修改第三方库源码的方法详解》很多时候,我们下载的第三方库是不会有需求不满足的情况,但也有极少的情况,第三方库没有兼顾到需求,本文将介绍几个修改源码的操作,大家可以根据需求进行选择... 目录需求不符合模拟示例 1. 修改源文件2. 继承修改3. 猴子补丁4. 追踪局部变量需求不符合很

Spring事务中@Transactional注解不生效的原因分析与解决

《Spring事务中@Transactional注解不生效的原因分析与解决》在Spring框架中,@Transactional注解是管理数据库事务的核心方式,本文将深入分析事务自调用的底层原理,解释为... 目录1. 引言2. 事务自调用问题重现2.1 示例代码2.2 问题现象3. 为什么事务自调用会失效3

mysql出现ERROR 2003 (HY000): Can‘t connect to MySQL server on ‘localhost‘ (10061)的解决方法

《mysql出现ERROR2003(HY000):Can‘tconnecttoMySQLserveron‘localhost‘(10061)的解决方法》本文主要介绍了mysql出现... 目录前言:第一步:第二步:第三步:总结:前言:当你想通过命令窗口想打开mysql时候发现提http://www.cpp

MySQL大表数据的分区与分库分表的实现

《MySQL大表数据的分区与分库分表的实现》数据库的分区和分库分表是两种常用的技术方案,本文主要介绍了MySQL大表数据的分区与分库分表的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有... 目录1. mysql大表数据的分区1.1 什么是分区?1.2 分区的类型1.3 分区的优点1.4 分

Mysql删除几亿条数据表中的部分数据的方法实现

《Mysql删除几亿条数据表中的部分数据的方法实现》在MySQL中删除一个大表中的数据时,需要特别注意操作的性能和对系统的影响,本文主要介绍了Mysql删除几亿条数据表中的部分数据的方法实现,具有一定... 目录1、需求2、方案1. 使用 DELETE 语句分批删除2. 使用 INPLACE ALTER T

SpringBoot启动报错的11个高频问题排查与解决终极指南

《SpringBoot启动报错的11个高频问题排查与解决终极指南》这篇文章主要为大家详细介绍了SpringBoot启动报错的11个高频问题的排查与解决,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一... 目录1. 依赖冲突:NoSuchMethodError 的终极解法2. Bean注入失败:No qu

Python Dash框架在数据可视化仪表板中的应用与实践记录

《PythonDash框架在数据可视化仪表板中的应用与实践记录》Python的PlotlyDash库提供了一种简便且强大的方式来构建和展示互动式数据仪表板,本篇文章将深入探讨如何使用Dash设计一... 目录python Dash框架在数据可视化仪表板中的应用与实践1. 什么是Plotly Dash?1.1

springboot报错Invalid bound statement (not found)的解决

《springboot报错Invalidboundstatement(notfound)的解决》本文主要介绍了springboot报错Invalidboundstatement(not... 目录一. 问题描述二.解决问题三. 添加配置项 四.其他的解决方案4.1 Mapper 接口与 XML 文件不匹配

基于Flask框架添加多个AI模型的API并进行交互

《基于Flask框架添加多个AI模型的API并进行交互》:本文主要介绍如何基于Flask框架开发AI模型API管理系统,允许用户添加、删除不同AI模型的API密钥,感兴趣的可以了解下... 目录1. 概述2. 后端代码说明2.1 依赖库导入2.2 应用初始化2.3 API 存储字典2.4 路由函数2.5 应