一文搞懂分布式事务-Saga

2024-06-01 00:36
文章标签 分布式 事务 一文 搞懂 saga

本文主要是介绍一文搞懂分布式事务-Saga，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Saga定义

Saga模式是一种分布式事务处理模式，用于保证分布式系统中的一系列操作要么全部成功执行，要么全部回滚，以实现一致性的目标。它采用了长事务的概念，将原子操作拆分为多个子事务，并通过补偿机制保证整个事务的一致性。

Saga是一种比较传统的解决方案，传统的业务系统中通常会提供冲正服务，当正向服务执行失败时，业务会自动调用冲正服务，将已经发生变化的数据再修改回去，这种解决思想与Saga相同。

Saga组成

Saga由一个个独立的本地事务组成（T1，T2，T3...），并且每个独立的本地事务提供反向逻辑（C1，C2，C3...），反向逻辑是指正向节点发生的变化会滚回去，如T1将数据ID=1 变更为ID=2，则反向逻辑是将ID变更为ID=1

T3节点执行失败，则开始执行冲正服务C2->C1。

Saga隔离性问题

事务隔离性

事务隔离性（Isolation）指的是一个事务的执行过程不会被其他事务干扰，即一个事务内部的操作及使用的数据对并发的其他事务是隔离的。这意味着并发执行的各个事务之间不能互相干扰，每个事务都独立地在自己的工作空间内完成，并且其结果在事务未提交之前对其他事务是不可见的。

事务隔离级别

事务隔离级别存在以下四种

  1. 读已提交

    • 事务内读取的是别的事务已经提交的数据，能够防止脏读，但是无法限制不可重复读和幻读。

  2. 读未提交

    • 能够读取到没有被提交的数据，这个级别的隔离机制无法解决脏读、不可重复读、幻读中的任何一种。

  3. 可重复读

    • Mysql数据库默认隔离级别，一个事务内支持多次读取相同的数据，即第一次读取和第二次读取相同。

  4. 串行化

    • 最严格的隔离级别，操作相同的数据全部加锁以串行的方式执行，数据安全性最高，但是性能上有严重的不足。

Saga隔离性

Saga这种模式对隔离性没有处理，每个本地事务提交，影响的数据对其他事务可见，如下场景

当Saga1流程中的T1执行成功后，本地事务提交，此时执行Saga2流程对ID=1的数据进行了更新ID=2，当Saga1流程执行T2失败后，调用C1进行冲正，此时如何处理？如果直接将ID更新为1，则丢失其他事务修改后的数据。

Saga隔离性问题处理

  1. 第一种解决思路

    • 如果开发过程中分析业务场景可能存在这种问题，流程执行过程中记录为特殊节点，特殊节点执行过后不允许执行冲正执行，重试正向服务中的节点，这样即使数据被其他事务修改，也无影响。

  1. 第二种解决思路

    • 通过分布式锁解决，事务执行前对操作的数据进行加锁，节点T执行成功后不释放锁，需要等待Saga流程全部执行结束后释放锁，这种方案存在明显的问题的是降低了并发能力，因为锁的持有时间是与整个Saga流程时间相同。

这篇关于一文搞懂分布式事务-Saga的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1019494。

相关文章

【数据结构】——原来排序算法搞懂这些就行，轻松拿捏

【数据结构】——原来排序算法搞懂这些就行，轻松拿捏

前言：快速排序的实现最重要的是找基准值，下面让我们来了解如何实现找基准值 基准值的注释：在快排的过程中，每一次我们要取一个元素作为枢纽值，以这个数字来将序列划分为两部分。 在此我们采用三数取中法，也就是取左端、中间、右端三个数，然后进行排序，将中间数作为枢纽值。 快速排序实现主框架： //快速排序 void QuickSort(int* arr, int left, int rig
阅读更多...
集中式版本控制与分布式版本控制——Git 学习笔记01

集中式版本控制与分布式版本控制——Git 学习笔记01

什么是版本控制 如果你用 Microsoft Word 写过东西，那你八成会有这样的经历： 想删除一段文字，又怕将来这段文字有用，怎么办呢？有一个办法，先把当前文件“另存为”一个文件，然后继续改，改到某个程度，再“另存为”一个文件。就这样改着、存着……最后你的 Word 文档变成了这样： 过了几天，你想找回被删除的文字，但是已经记不清保存在哪个文件了，只能挨个去找。真麻烦，眼睛都花了。看
阅读更多...
MySql 事务练习

MySql 事务练习

事务（transaction） -- 事务 transaction-- 事务是一组操作的集合，是一个不可分割的工作单位，事务会将所有的操作作为一个整体一起向系统提交或撤销请求-- 事务的操作要么同时成功，要么同时失败-- MySql的事务默认是自动提交的，当执行一个DML语句，MySql会立即自动隐式提交事务-- 常见案例：银行转账-- 逻辑：A给B转账1000：1.查询
阅读更多...
开源分布式数据库中间件

开源分布式数据库中间件

转自：https://www.csdn.net/article/2015-07-16/2825228 MyCat：开源分布式数据库中间件 为什么需要MyCat？ 虽然云计算时代，传统数据库存在着先天性的弊端，但是NoSQL数据库又无法将其替代。如果传统数据易于扩展，可切分，就可以避免单机（单库）的性能缺陷。 MyCat的目标就是：低成本地将现有的单机数据库和应用平滑迁移到“云”端
阅读更多...
Lua 脚本在 Redis 中执行时的原子性以及与redis的事务的区别

Lua 脚本在 Redis 中执行时的原子性以及与redis的事务的区别

在 Redis 中，Lua 脚本具有原子性是因为 Redis 保证在执行脚本时，脚本中的所有操作都会被当作一个不可分割的整体。具体来说，Redis 使用单线程的执行模型来处理命令，因此当 Lua 脚本在 Redis 中执行时，不会有其他命令打断脚本的执行过程。脚本中的所有操作都将连续执行，直到脚本执行完成后，Redis 才会继续处理其他客户端的请求。 Lua 脚本在 Redis 中原子性的原因
阅读更多...
laravel框架实现redis分布式集群原理

laravel框架实现redis分布式集群原理

在app/config/database.php中配置如下： 'redis' => array('cluster' => true,'default' => array('host' => '172.21.107.247','port' => 6379,),'redis1' => array('host' => '172.21.107.248','port' => 6379,),) 其中cl
阅读更多...
基于MySQL实现的分布式锁

基于MySQL实现的分布式锁

概述 在单机时代，虽然不需要分布式锁，但也面临过类似的问题，只不过在单机的情况下，如果有多个线程要同时访问某个共享资源的时候，我们可以采用线程间加锁的机制，即当某个线程获取到这个资源后，就立即对这个资源进行加锁，当使用完资源之后，再解锁，其它线程就可以接着使用了。例如，在JAVA中，甚至专门提供了一些处理锁机制的一些API（synchronize/Lock等）。 但是到了分布式系统的时代，这种
阅读更多...
CSP-J基础之数学基础 初等数论 一篇搞懂(一)

CSP-J基础之数学基础 初等数论 一篇搞懂(一)

文章目录 前言声明初等数论是什么初等数论历史1. **古代时期**2. **中世纪时期**3. **文艺复兴与近代**4. **现代时期** 整数的整除性约数什么样的整数除什么样的整数才能得到整数？条件：举例说明：一般化： 判断两个数能否被整除 因数与倍数质数与复合数使用开根号法判定质数哥德巴赫猜想最大公因数与辗转相除法计算最大公因数的常用方法：举几个例子：例子 1: 计算 12 和 18
阅读更多...
CSP-J基础之数学基础 初等数论 一篇搞懂(二)

CSP-J基础之数学基础 初等数论 一篇搞懂(二)

文章目录 前言算术基本定理简介什么是质数？举个简单例子：重要的结论：算术基本定理公式解释：举例： 算术基本定理的求法如何找出质因数：举个简单的例子： 重要的步骤：C++实现 同余举个例子：同余的性质简介1. 同余的自反性2. 同余的对称性3. 同余的传递性4. 同余的加法性质5. 同余的乘法性质 推论 总结 前言 在计算机科学和数学中，初等数论是一个重要的基础领域，涉及到整数
阅读更多...
Kafka 分布式消息系统详细介绍

Kafka 分布式消息系统详细介绍

Kafka 分布式消息系统 一、Kafka 概述1.1 Kafka 定义1.2 Kafka 设计目标1.3 Kafka 特点 二、Kafka 架构设计2.1 基本架构2.2 Topic 和 Partition2.3 消费者和消费者组2.4 Replica 副本 三、Kafka 分布式集群搭建3.1 下载解压3.1.1 上传解压 3.2 修改 Kafka 配置文件3.2.1 修改zookeep
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2