异构系统的事务统一处理模型Saga

news2024/12/28 9:49:34

承接上文分布式事务Seata-TCC事务模式

Saga事务模式相对来说是最复杂的,用的不多,只需要把概念理解透就可以了。

Saga是Seata提供的长事务解决方案,在业务流程中每个参与者都提供本地事务,当出现某个参与者失败的情况则补偿前面已经成功的参与者。

Saga也是二阶段的提交,一阶段是正向服务,二阶段是补偿服务,补偿机制就是执行的时候出错了,给它一个改正的机会。

一阶段正向执行,比如T1和T2正常,T2到T3也正常,T3位置出现问题了, 就需要整体的回滚,这个时候就会进行反向补偿,把之前的已成功的状态都补偿回去。

Saga模式下的分布式事务通常是由事件驱动完成的,各个参与者之间是异步执行的。

XA和AT都是数据源代理,业务侵入型少;TCC是自己实现业务逻辑(实现Try、Confirm、Cancel接口),业务侵入性强;而Saga应用场景:封闭式老系统无法修改同时也没有引入任何分布式事务,

比如这3个项目之间的分布式事务问题需要引入Seata的Saga模式,对于不能修改业务代码的场景,只能通过外部的方式来实现分布式事务。

Saga提供了异构系统的事务统一处理模型,保障了整个系统的分布式事务。

所有的子业务系统都不能参与整体的事务处理,比如java项目只负责自身的本地事务处理。

本地事务完成之后,全部交由调用端来进行处理。

在进行总业务处理时,如果某一个子业务出现了问题,则自动补偿前面已经执行成功的其他参与者。

一阶段的正向服务调用和二阶段的事务补偿处理全部由总业务开发实现。

在Saga模式下,子系统业务有对应的业务处理接口和业务补偿接口。

Saga业务模型用json文件来进行管理,调用子业务处理的时候,一阶段的情况下远程调用子业务系统提供的接口。

调用子业务系统的时候,调用对应的接口进行本地的事务处理,如果没有问题,则调用第二个,都没有问题的话,整体提交。

如果第二个出现了问题,则调用二阶段业务补偿接口,即数据回滚接口。

一阶段没有问题,则继续执行,如果有一个子业务系统有问题,就会调用二阶段的业务补偿接口来进行数据的回滚处理,这是对应Saga处理的事务模型。

通过Saga的状态机来完成总业务的处理,需要开发者进行手工的业务流程的绘制并将其转换成json的配置文件,在程序运行时,将依据配置文件实现业务处理以及服务补偿处理 。

要进行Saga的状态绘制,一般通过Saga状态机实现,通过状态图来定义服务间调用流程。

比如图1中这3个完全没有关系的服务,在总业务逻辑处理的时候,使用Saga的状态机来定义,调用服务1,再调用服务2,再调用服务3。状态图中的每一节点可以调用一个服务,也可以配置它的补偿节点。

状态图的json是由状态机的引擎驱动执行,当出现异常时,状态反向执行已成功的节点对应的补偿节点将事务回滚。

每一个子服务里面都会配置一个业务接口和一个业务补偿接口,当出现问题了,就会调用业务补偿接口向上补偿。

Saga状态机可以完成整个服务的编排需求、支持单项选择、并发、子流程、参数转换、参数映射、服务执行状态判断、异常捕获等。

Seata中的Saga事务模式是由外部的Saga提供的状态机来进行完成的,需要定义总流程,状态机里可以定义当前节点的调用服务,而且每个节点上可以配置当前这个调用服务的反向补偿节点。

当某一节点出现问题的时候,就会调用向上的反向补偿。

最开始的时候由业务负责本地的事务处理,当本地的事务处理出现问题的时候,会调用当前的反向补偿接口,然后再向上补偿。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/453730.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

如何设计一个牛逼的API接口

在日常开发中,总会接触到各种接口。前后端数据传输接口,第三方业务平台接口。一个平台的前后端数据传输接口一般都会在内网环境下通信,而且会使用安全框架,所以安全性可以得到很好的保护。这篇文章重点讨论一下提供给第三方平台的…

[自注意力神经网络]Mask Transfiner网络-论文解读

本文为CVPR2022的论文。国际惯例,先贴出原文和源码: 原论文地址https://arxiv.org/pdf/2111.13673.pdf源码地址https://github.com/SysCV/transfiner 一、概述 传统的Two-Stage网络,如Mask R-CNN虽然在实例分割上取得了较好的效果&#xff…

OSCP-Twiggy(ZeroMQ、SaltStack)

目录 扫描 ​编辑WEB 扫描 WEB 80端口 运行着一个名为Mezzanine的东西。快速的谷歌搜索显示这是一个内容管理系统,所以让我们看看它是否对任何可以在我们的目标机器上获得shell的东西都是脆弱的: mezzanine版本是4.3.1,并且此漏洞已在4.2.1中修补。 searchsploit没有返回…

说说MySQL中MVCC机制的原理

一、概述: 了解了MySql的底层架构后,我们今天要深入了解下什么是MVCC。 MVCC,全称Multi-Version Concurrency Control,即多版本并发控制。MVCC是一种多并发控制的方法,一般在数据库管理系统中,实现对数据…

NAS私有云存储 - 搭建Nextcloud私有云盘并公网远程访问

文章目录 摘要视频教程1. 环境搭建2. 测试局域网访问3. 内网穿透3.1 ubuntu本地安装cpolar3.2 创建隧道3.3 测试公网访问 4 配置固定http公网地址4.1 保留一个二级子域名4.1 配置固定二级子域名4.3 测试访问公网固定二级子域名 转载自内网穿透工具的文章:使用Nextcl…

LVS负载均衡集群

引言 如今,在各种互联网应用中,随着站点对硬件性能、响应速度、服务稳定性、数据可靠性等要求也越来越高,单台服务器也将难以无法承担所有的访问需求。 一、群集的含义 集群、群集 由多台主机构成,但对外,只表现为一…

ubuntu-18.0.04 鸿蒙HarmonyOS系统源码(HOSP)下载

最近小编在研究鸿蒙开发,想要研究下鸿蒙源码,这里记录下源码下载中遇到的问题及解决,也为HarmonyOS的生态的建设提供下帮助,希望能帮到需要的人。 前置步骤:如果你之前下载过AOSP源码,那这里下载鸿蒙源码应…

第五章-数字水印-2-原理及实现

数字水印原理 根据之前图像获取位平面的操作可知,最低位位平面对整体图像的影响最小,因此数字水印的原理为在图像的最低有效位上嵌入隐藏信息,即在图像的最低位替换为数字水印位平面,完成数字的嵌入操作,对已嵌入数字…

Jenkins+Python自动化测试持续集成详细教程(全网独家)

目录 一、前言 二、环境准备 三、创建Jenkins Job 四、编写Python自动化测试脚本 五、测试报告生成与展示 六、持续集成流程优化 七、实战演练 八、常见问题及解决方案 九、结论 一、前言 Jenkins是目前最为流行的CI/CD工具之一,它可以支持多种语言和技术…

如何使用ffmpeg给视频减震去抖

之前自己发过一些记录仪拍下来的画面,你们可能已经看过了,例如: 最适合骑行的罐装饮料 然而,自己这个骑行记录仪,仅仅是很低端的一款,防抖功能很差,远远比不了GoPro那些高端的户外运动记录仪&am…

使用PCL滤波器实现点云裁剪

主要目的就是根据已知的ROI区域,对点云进行裁剪。要么留下点云ROI区域,要么去除。 ROI区域一般都是一个矩形,即(x,y,width,height)。 那么封装的函数形式一般如下: pcl:…

《死锁》与《CAS ABA》问题

文章目录 什么是死锁常见死锁情况❗️死锁的必要条件❗️如何避免死锁呢?CASCAS中ABA问题解决ABA问题 什么是死锁 死锁是指两个或两个以上的进程在执行过程中,由于竞争资源或者由于彼此通信而造成的一种阻塞的现象 。 常见死锁情况❗️ 1.一个线程一把…

Java-static那些事儿

static作为java中基础常用的关键字,通常用于修饰内部类,方法和变量和代码段,且具有以下特性: static修饰内部类时,该类属于静态内部类,其只能访问外部的静态变量和方法static修饰方法时,该方法…

ROS学习第三十七节——机器人运动控制以及里程计信息显示

https://download.csdn.net/download/qq_45685327/87719766 https://download.csdn.net/download/qq_45685327/87719873 gazebo 中已经可以正常显示机器人模型了,那么如何像在 rviz 中一样控制机器人运动呢?在此,需要涉及到ros中的组件: ros…

【mapbox+turf.js】WebGIS空间分析系列(1)

最近在想,自己一直使用webgis做的都是可视化的内容,缺少空间分析的功能。 所以吧,最近理一下使用mapbox turf来做一些基础的空间分析功能。 大概的思路是,获取目标图层(多个图层),然后选择空…

servlet(2)—javaEE

1.获取请求数据 1.1开发前端发请求 ajax封装代码 // 参数 args 是一个 JS 对象, 里面包含了以下属性 // method: 请求方法 // url: 请求路径 // body: 请求的正文数据 // contentType: 请求正文的格式 // callback: 处理响应的回调函数, 有两个参数, 响应正文和响应的状态码…

qt中使用 ui 文件进行界面设计

目录 1、创建 Qt 应用 ​2、项目创建成功 3、直接点击打开 mainwindow.ui 文件 4、随便从左边侧边栏拖拽一个空间到 界面设计区域 5、在右侧边栏右键点击 pushButton 控件,点击转到槽 6、根据实际需要选择对应的信号,我这里方便演示选择 clicked&a…

linux 信号量semget/semop/semctl

专栏内容:linux下并发编程个人主页:我的主页座右铭:天行健,君子以自强不息;地势坤,君子以厚德载物. 目录 前言 概述 原理机制 接口说明 代码演示 结尾 前言 本专栏主要分享linux下并发编…

基于 多态 的职工管理系统(Staff Management System)

目录 一、管理系统需求 作用:管理公司内所有员工的信息 分类:要显示每位员工的编号、姓名、岗位与职责 具体实现的功能: 二、创建管理 类 三、各个接口函数 1、菜单展示功能 2、 选择功能 3、创建员工功能 ①普通员工employee ②经理…

【Web3.0大势所趋】我看到了互联网未来的模样

前言 Web3.0 是一个越来越受到关注的话题,它被认为将会带来天翻地覆的变化。本文我们一起来谈谈 Web3.0 的概念、特点和优势,并探讨它为什么如此重要和具有革命性的。 文章目录 前言Web3.0是什么Web3.0的技术Web3.0的优势总结 Web3.0是什么 Web3.0: 是下…