微服务13-Seata的四种分布式事务模式

文章目录

  • XA模式
    • 实现XA模式
  • AT模式
    • AT模式的脏写问题（对同数据并发写的问题）
    • 其他事务不获取全局锁的一个情况（AT模式写隔离的实现）
    • 实现AT模式
  • TCC模式
    • TCC实现
    • 我们怎么样去判断是否空回滚和业务悬挂？
    • 业务分析
  • Saga模式
    • 总结

XA模式

XA模式分为两种情况：
提交成功：
在这里插入图片描述

提交失败：

在这里插入图片描述

具有强一致性seata相当于是在RM上做了一层封装；

在这里插入图片描述

XA模式
优点：
1.事务的强一致性，只要有失败的，TC事务协调者就会发送信息让RM回滚——>满足ACID原则
2.没有代码侵入，常用数据库都支持
缺点：
1.第一阶段就要锁定数据库资源，但是却不提交，从而导致数据库所占用的资源不能释放（占数据库锁），性能较差
2.依赖关系型数据库实现事务

实现XA模式

步骤：

1.在yaml文件中开启XA代理模式

2.添加@GlobalTransactional注解开启全局事务

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

AT模式

在这里插入图片描述
利用快照来保证事务的一致性，来进行数据回滚；

在这里插入图片描述

AT模式是一种最终一致的模式：因为RM资源管理器执行sql后会直接提交，那么此时如果是数据不一致的情况下，那么说明肯定是软一致，但是在阶段二时，AT模式RM资源管理器会利用快照进行数据回滚，从而保证最终一致；
AT模式直接提交，有利于提高效率

在这里插入图片描述

AT模式的脏写问题（对同数据并发写的问题）

脏写问题：造成数据空转现象

什么是脏写：

简而言之，就是两个事务并发执行，修改同一条数据，我第一个事务修改并且提交之后，释放DB锁资源，第二个事务想要进行回滚，那么就会导致脏写——>前一个事务修改无效

在这里插入图片描述
解决：对事务2造成数据空转现象进行处理

1.事务1先获取DB锁，并且保存快照
——>2.然后执行业务sql，我们在提交事务前获取全局锁（防止一提交事务，释放DB锁后，其他事务立马插入获取DB锁更改sql）
——>3.此时全局锁会记录操作当前数据的事务，让该事务持有全局锁，然后提交事务释放DB锁
——>4.此时其他事务可以争夺DB锁，执行业务sql
——>5.然后和之前一样，它也要获取全局锁，但是全局锁此时已经被事务1拿了，所以它会进行自旋（300ms）
——>6.然后事务1如果此时要根据快照恢复数据，那么就需要DB锁，但是DB锁此时被其他事务拿了
——>7.死锁现象发生
——>8.还好其他事务重试失败后会释放锁资源，因为获取全局锁失败，那么后面的事务提交也进行不了
——>9.事务1再次拿到DB锁，可以进行快照恢复数据了；

在这里插入图片描述

其他事务不获取全局锁的一个情况（AT模式写隔离的实现）

利用了CAS的思想 ：

实际上是有两份快照的：before-image、after-image

跟cas一样，before是我们要回滚目标的状态，而after是相当于验证的一个状态，如果满足after的内容，就可以设置为before；

如果不一样不满足的话，就会判断不能恢复回滚，那么我们可以记录异常发送警告；

在这里插入图片描述

总结：

AT：在第一阶段RM直接提交事务，释放数据库资源，不需要像XA模式那样，还需要将状态返回给TC事务协调者，还利用了全局锁实现读写分离：将表执行的事务储存起来，相当于一个标识；
并且**没有代码侵入，seata自动完成回滚和提交——>seata相当于RM资源管理器的一个代理**

在这里插入图片描述

实现AT模式

数据库表中：lock_table:全局锁，undo_log：放的是快照信息

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

可以再下单途中在业务代码中加上断点的方式查看数据库表中记录的快照信息和AT模式的全局锁信息 他们会在业务结束时自动销毁清理干净

TCC模式

在这里插入图片描述
在这里插入图片描述
那我们TCC模式是怎么保证一致性？

首先我们想想AT模式，在第一阶段，通过对数据库锁的获取完成事务，事务都是隔离的，所以有人成功有人失败，只有在二阶段完成回滚才能够保证数据的最终一致性，中间还是出现了软状态；

而TCC模式，为什么就不需要锁了呢？我们AT模式是利用全局锁来保证一致性的——>执行sql后提交前上一道全局锁，那么其他事务的sql就执行不了进行自旋，超时就释放DB锁，而TCC解决：利用了每个事务都是预留资源进行处理——> 第一个事务冻结的金额和第二个事务冻结的金额是不一样的，跟其他事务是没有关系的，那么回滚事务也是跟其他事务不影响的，不需要加锁（类似Semaphore）

简而言之就是把事务所用到的资源预留起来 等后面的结果再来判断是扣除还是释放，预留起来后数据库原表中的数据已经扣除了，所以其他的业务请求也不会有影响

在这里插入图片描述

TCC模式的关键在于有代码侵入：需要考虑Comfirm成功提交和Cancel数据回滚的编写

优点：1.TCC第一阶段直接提交事务，提交完直接释放数据库资源，AT的话也是直接执行，但是使用了全局锁来保存事务操作的一个状态，保证其他事务争夺不了，XA的话第一阶段就垃圾了，不会提交sql业务，需要把状态给到TC事务协调者进行判断是否回滚还是提交（是一提交或者回滚就是全局那种）；
2.无需生成快照与全局锁，依赖的是一个补偿操作，因为事务直接提交的原则，所以其他事务是操作不到自己的，可用于非关系型数据库

在这里插入图片描述

TCC实现

具体模式还得根据场景来，比如TCC，就很像Semaphore，一般来说是对一个共享资源进行操作，比如停车场的停车位，库存…，像下单服务就不适合了，因为你每次调用都是一个新的订单；

一个事务是可以有多个模式实现的

在这里插入图片描述

在这里插入图片描述

我们怎么样去判断是否空回滚和业务悬挂？

利用两者相互判断 根据冻结金额的那张表来判断 在进行try业务前 先查询一下冻结金额的表中的数据是否为空 如果不为空则证明已经执行了CANCEL操作 则需要直接拒绝try的操作，反之在进行cancel业务前，需要根据事务id查询一下冻结金额的表中的数据是否为空 如果为空的话则证明try业务还没做，需要进行空回滚，同时也需要记录数据，new一个新的对象将冻结金额设为0，以及其他数据set进去

业务分析

在这里插入图片描述
在这里插入图片描述

我们可以在BusinessActionContext中获取里面的参数

事务表：表示事务冻结金额，冻结金额状态发生改变——>表示那部分被锁定

事务id，用户id，冻结金额和状态

在这里插入图片描述

业务方便代码的实现:

@Slf4j
@Service
public class AccountTCCServiceImpl implements AccountTCCService {@Autowiredprivate AccountMapper accountMapper;@Autowiredprivate AccountFreezeMapper accountFreezeMapper;@Override@Transactionalpublic void deduct(String userId, int money) {//0.获取事务idString xid = RootContext.getXID();// 判断是否有冻结记录 有的话直接拒绝执行try业务AccountFreeze Freeze = accountFreezeMapper.selectById(xid);if (Freeze!=null) {//拒绝return;}//1.扣减可用余额accountMapper.deduct(userId, money);//2.记录冻结金额，记录事务状态AccountFreeze accountFreeze = new AccountFreeze();accountFreeze.setUserId(userId);accountFreeze.setFreezeMoney(money);accountFreeze.setState(AccountFreeze.State.TRY);accountFreeze.setXid(xid);accountFreezeMapper.insert(accountFreeze);}@Overridepublic boolean confirm(BusinessActionContext ctx) {//0.获取事务idString xid = ctx.getXid();//1.删除数据int count = accountFreezeMapper.deleteById(xid);return count == 1;}@Overridepublic boolean cancel(BusinessActionContext ctx) {//0.查询冻结记录AccountFreeze accountFreeze = accountFreezeMapper.selectById(ctx.getXid());String userId = (String) ctx.getActionContext("userId");//0.2.判断是否空回滚if (accountFreeze == null){accountFreeze = new AccountFreeze();accountFreeze.setUserId(userId);accountFreeze.setFreezeMoney(0);accountFreeze.setState(AccountFreeze.State.CANCEL);accountFreeze.setXid(ctx.getXid());accountFreezeMapper.insert(accountFreeze);return true;}//0.3 幂等判断if (accountFreeze.getState()==AccountFreeze.State.CANCEL){//已经处理过cancel了 无需重复业务return true;}//1.恢复可用余额accountMapper.refund(accountFreeze.getUserId(),accountFreeze.getFreezeMoney());//2.将冻结金额清零 改状态为cancelaccountFreeze.setFreezeMoney(0);accountFreeze.setState(AccountFreeze.State.CANCEL);int count = accountFreezeMapper.updateById(accountFreeze);return count == 1;}
}

在这里插入图片描述

Saga模式

与TCC模式类似，但是TCC第一阶段只是将资源进行冻结，真正的去除还是在第二阶段的，而Saga模式是直接提交本地事务，第二阶段直接操作事务本身：成功则什么都不做，失败则通过编写补偿业务来进行回滚；

与AT相比没有用锁，与TCC比没有冻结资源，性能较好；

失败用自定义的补偿来写；

缺点：

没有保证隔离性，既没有隔离预留资源又没有上锁，容易出现脏写

在这里插入图片描述

总结

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【学习笔记】项目进行过程中遇到有关composer的问题

【学习笔记】项目进行过程中遇到有关composer的问题

composer.json内容详解 以项目中的composer.json为例，参考文档。 name：composer包名type：包的类型，project和library两种keywords：关键词，方便别人在安装时通过关键词检索（没试过，好…
阅读更多...
Java 中 Volatile 关键字

Java 中 Volatile 关键字

基本概念 补充一下 java 内存模型中的 可见性、原子性和有序性 可见性： 指的是线程之间的可见性，一个线程修改的状态对另一个线程是可见的。也就是一个线程修改的结果，另一个线程马上可以看到。比如 ：用 volatile 修饰的变量&am…
阅读更多...
froeach迭代删除和List迭代删除问题

froeach迭代删除和List迭代删除问题

场景:我有一个 List<ISSLogMessage> records 数据,需要从里面删除指定内容数据 第一次写成 foreach(var item in records) {if (item.logMessage.Contains("上传通行记录"))records.Remove(item); } 直接报错,因为foreach 是个迭代器 直接移除它的对象会报…
阅读更多...
Redis实现简易消息队列的三种方式

Redis实现简易消息队列的三种方式

Redis实现简易消息队列的三种方式 消息队列简介 消息队列是一种用于在计算机系统中传递和处理数据的重要工具。如果你完全不了解消息队列&#xff0c;不用担心&#xff0c;我将尽力以简单明了的方式来解释它。 首先&#xff0c;想象一下你正在玩一个游戏&#xff0c;而游戏中…
阅读更多...
Web应用防火墙的性能优化技术

Web应用防火墙的性能优化技术

Web应用防火墙&#xff08;WAF&#xff09;是企业网络安全的重要屏障&#xff0c;其性能直接影响到网络服务的质量和安全。本文详细探讨了WAF性能优化的几种技术&#xff0c;旨在为网络安全专业人员提供实用的参考。 规则优化 1.1 精简规则集 规则评估&#xff1a;定期评估规…
阅读更多...
JQuery、JSON、AJAX、XML、IO流、多线程、反射核心知识点详解

JQuery、JSON、AJAX、XML、IO流、多线程、反射核心知识点详解

JQuery 一、什么是JQuery JQuery是JavaScript的一个框架&#xff0c;对js的封装&#xff0c;使得js简单易学 优点&#xff1a; 1、不用考虑浏览器兼容性问题 2、jquery拥有强大的选择器&#xff0c;简化了js代码 3、jquery提供了很多系统函数&#xff0c;直接调用 二、版本 1.x…
阅读更多...
面试题补充

面试题补充

1.公司有几套环境&#xff1a;测试环境&#xff08;测试人员使用&#xff09;&#xff0c;开发环境&#xff08;开发人员使用&#xff09;&#xff0c;预生产环境&#xff08;测试人员使用&#xff09;&#xff0c;生产环境&#xff08;用户使用&#xff09; 2.作为一名测试&a…
阅读更多...
C语言第一节--从c语言源码到可执行文件

C语言第一节--从c语言源码到可执行文件

C语言第一节–从c语言源码到可执行文件 编译 C 语言代码生成可执行文件的流程一般可以分为四个步骤&#xff1a;预处理、编译、汇编和链接。 假设有一个名为 “hello.c” 的 C 语言源文件&#xff0c;内容如下&#xff1a; #include <stdio.h>int main() {printf("…
阅读更多...
Kubernetes 常用命令 持续更新

Kubernetes 常用命令 持续更新

1、进入指定namespace pod kubectl exec -it --namespacekube-system g-lsb-proxy-nginx-r7zfl-2522744936-11rld /bin/sh kubectl exec -it g-lsb-proxy-nginx-r7zfl-2522744936-9tz5k -n kube-system /bin/bash2、查看k8s pod详情 kubectl describe pods -n jiankunking …
阅读更多...
【计算机网络】网络编程接口 Socket API 解读（11）

【计算机网络】网络编程接口 Socket API 解读（11）

Socket 是网络协议栈暴露给编程人员的 API&#xff0c;相比复杂的计算机网络协议&#xff0c;API 对关键操作和配置数据进行了抽象&#xff0c;简化了程序编程。 本文讲述的 socket 内容源自 Linux man。本文主要对各 API 进行详细介绍&#xff0c;从而更好的理解 socket 编程。…
阅读更多...
opencv跨平台arm交叉编译之ubuntu

opencv跨平台arm交叉编译之ubuntu

目录 1. 安装交叉编译工具链2. 安装依赖3. 配置工具链3.1 新建build目录3.2 安装cmake-gui3.3 工具链配置界面进行配置3.3.1 终端输入以下命令3.3.2 点击Configure&#xff0c;弹出编译方式选择对话框&#xff1a;3.3.3 点击Next3.3.4 点击Finish3.3.5 点击Configure。3.3.6 Ge…
阅读更多...
RISC-V 特权级架构

RISC-V 特权级架构

特权级别 级别的数值越大&#xff0c;特权级越高&#xff0c;掌控硬件的能力越强&#xff0c;在CPU硬件层面&#xff0c;M模式必须存在&#xff0c;其它模式可以不存在 执行环境调用 ecall &#xff0c;这是一种很特殊的陷入类的指令&#xff0c; 相邻两特权级软件之间的接口正…
阅读更多...
2023年9月Web3行业月度发展报告区块链篇 | 陀螺科技会员专享

2023年9月Web3行业月度发展报告区块链篇 | 陀螺科技会员专享

9月是加密市场的活动月&#xff0c;斯坦福区块链周、Token2049等大型活动相继举办&#xff0c;后者更是创下超过1万人的历史最高纪录&#xff0c;成为了全球最大的Web3活动。在本次Token2049上&#xff0c;RWA、支付以及出入金成为了讨论度最多的活动。尽管活动如火如荼&#x…
阅读更多...
docker入门加实战—docker数据卷

docker入门加实战—docker数据卷

docker入门加实战—docker数据卷 容器是隔离环境&#xff0c;容器内程序的文件、配置等都在容器的内部&#xff0c;要读写容器内的文件非常不方便。 因此&#xff0c;容器提供程序的运行环境&#xff0c;但是程序运行产生的数据、程序运行依赖的配置都应该与容器进行解耦。 …
阅读更多...
JUC第二十八讲：JUC工具类: Semaphore详解

JUC第二十八讲：JUC工具类: Semaphore详解

JUC工具类: Semaphore详解 本文是JUC第二十八讲&#xff0c;JUC工具类: Semaphore详解。Semaphore底层是基于AbstractQueuedSynchronizer来实现的。Semaphore称为计数信号量&#xff0c;它允许n个任务同时访问某个资源&#xff0c;可以将信号量看做是在向外分发使用资源的许可证…
阅读更多...
亳州市的自然风光与旅游资源：欣赏安徽省中部的壮丽景色

亳州市的自然风光与旅游资源：欣赏安徽省中部的壮丽景色

亳州市是中国安徽省的一个地级市&#xff0c;位于该省的中部。 亳州市辖区包括谯城区、涡阳县、蒙城县和利辛县等地。亳州市拥有悠久的历史和丰富的文化遗产&#xff0c;同时也以其独特的自然风光而闻名。 首先&#xff0c;让我们来了解一下亳州的历史和景点。亳州的历史可以…
阅读更多...
软件‘小程序‘前台开发软件定制的知识|app网站搭建

软件‘小程序‘前台开发软件定制的知识|app网站搭建

软件&#xff0c;小程序&#xff0c;前台开发软件定制的知识 随着互联网的快速发展&#xff0c;软件&#xff0c;小程序&#xff0c;前台开发软件定制已经成为了企业必备的工具。它可以帮助企业更好地管理业务&#xff0c;提高效率&#xff0c;增强用户体验。那么&#xff0c;什…
阅读更多...
vue3学习（五）--- 父子组件传值

vue3学习（五）--- 父子组件传值

文章目录 defineProps普通写法TS写法 defineEmits普通写法TS写法 defineExpose defineProps 和 defineEmits 都是只能在 <script setup> 中使用的编译器宏。他们不需要导入&#xff0c;且会随着 <script setup> 的处理过程一同被编译掉。 defineProps 接收父组件传…
阅读更多...
MySQL中使用函数会使索引失效？

MySQL中使用函数会使索引失效？

文章目录 1、前置准备2、ChatGPT的答案3、实践证明SQL1SQL2SQL3SQL4SQL5 4、总结 1、前置准备 首先创建我们要测试的库表 CREATE TABLE lianhe_index (id int(11) NOT NULL AUTO_INCREMENT COMMENT id,name varchar(255) DEFAULT NULL,age int(11) DEFAULT NULL,number int(1…
阅读更多...
Flink报错could not be loaded due to a linkage failure

Flink报错could not be loaded due to a linkage failure

文章目录 1、报错2、原因3、解决 1、报错 在Flink上提交作业&#xff0c;点Submit没反应&#xff0c;F12看到接口报错信息为&#xff1a; 大概意思是&#xff0c;由于链接失败&#xff0c;无法加载程序的入口点类xx。没啥鸟用的信息&#xff0c;去日志目录继续分析&#xff1a…
阅读更多...
最新文章

Copyright @ 2022~2023