文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

对比 5 种分布式事务方案,还是宠幸了阿里的 Seata(原理 + 实战)

2024-12-03 17:05

关注

本文转载自微信公众号「 程序员内点事」,作者 程序员内点事。转载本文请联系 程序员内点事公众号。

好长时间没发文了,最近着实是有点忙,当爹的第 43 天,身心疲惫。这又赶上年底,公司冲KPI 强制技术部加班到十点,晚上孩子隔两三个小时一醒,基本没睡囫囵觉的机会,天天处于迷糊的状态,孩子还时不时起一些奇奇怪怪的疹子,总让人担惊受怕的。

本就不多的写文章时间又被无限分割,哎~ 打工人真是太难了。

小眼神几个意思

 

本来不知道写点啥,正好手头有个新项目试着用阿里的 Seata 中间件做分布式事务,那就做一个实践分享吧!

介绍 Seata 之前在简单回顾一下分布式事务的基本概念。

分布式事务的产生

我们先看看百度上对于分布式事务的定义:分布式事务是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。

 

额~ 有点抽象,简单的画个图好理解一下,拿下单减库存、扣余额来说举例:

当系统的体量很小时,单体架构完全可以满足现有业务需求,所有的业务共用一个数据库,整个下单流程或许只用在一个方法里同一个事务下操作数据库即可。此时做到所有操作要么全部提交 或 要么全部回滚很容易。

 

分库分表、SOA

可随着业务量的不断增长,单体架构渐渐扛不住巨大的流量,此时就需要对数据库、表做 分库分表处理,将应用 SOA 服务化拆分。也就产生了订单中心、用户中心、库存中心等,由此带来的问题就是业务间相互隔离,每个业务都维护着自己的数据库,数据的交换只能进行RPC 调用。

当用户再次下单时,需同时对订单库 order、库存库 storage、用户库 account 进行操作,可此时我们只能保证自己本地的数据一致性,无法保证调用其他服务的操作是否成功,所以为了保证整个下单流程的数据一致性,就需要分布式事务介入。

 

Seata 优势

实现分布式事务的方案比较多,常见的比如基于 XA 协议的 2PC、3PC,基于业务层的TCC,还有应用消息队列 + 消息表实现的最终一致性方案,还有今天要说的 Seata 中间件,下边看看各个方案的优缺点。

2PC

基于 XA 协议实现的分布式事务,XA 协议中分为两部分:事务管理器和本地资源管理器。其中本地资源管理器往往由数据库实现,比如 Oracle、MYSQL 这些数据库都实现了 XA 接口,而事务管理器则作为一个全局的调度者。

两阶段提交(2PC),对业务侵⼊很小,它最⼤的优势就是对使⽤⽅透明,用户可以像使⽤本地事务⼀样使⽤基于 XA 协议的分布式事务,能够严格保障事务 ACID 特性。

 

可 2PC的缺点也是显而易见,它是一个强一致性的同步阻塞协议,事务执⾏过程中需要将所需资源全部锁定,也就是俗称的 刚性事务。所以它比较适⽤于执⾏时间确定的短事务,整体性能比较差。

一旦事务协调者宕机或者发生网络抖动,会让参与者一直处于锁定资源的状态或者只有一部分参与者提交成功,导致数据的不一致。因此,在⾼并发性能⾄上的场景中,基于 XA 协议的分布式事务并不是最佳选择。

 

3PC

三段提交(3PC)是二阶段提交(2PC)的一种改进版本 ,为解决两阶段提交协议的阻塞问题,上边提到两段提交,当协调者崩溃时,参与者不能做出最后的选择,就会一直保持阻塞锁定资源。

2PC 中只有协调者有超时机制,3PC 在协调者和参与者中都引入了超时机制,协调者出现故障后,参与者就不会一直阻塞。而且在第一阶段和第二阶段中又插入了一个准备阶段(如下图,看着有点啰嗦),保证了在最后提交阶段之前各参与节点的状态是一致的。

 

虽然 3PC 用超时机制,解决了协调者故障后参与者的阻塞问题,但与此同时却多了一次网络通信,性能上反而变得更差,也不太推荐。

TCC

所谓的 TCC 编程模式,也是两阶段提交的一个变种,不同的是 TCC 为在业务层编写代码实现的两阶段提交。TCC 分别指 Try、Confirm、Cancel ,一个业务操作要对应的写这三个方法。

以下单扣库存为例,Try 阶段去占库存,Confirm 阶段则实际扣库存,如果库存扣减失败 Cancel 阶段进行回滚,释放库存。

TCC 不存在资源阻塞的问题,因为每个方法都直接进行事务的提交,一旦出现异常通过则 Cancel 来进行回滚补偿,这也就是常说的补偿性事务。

原本一个方法,现在却需要三个方法来支持,可以看到 TCC 对业务的侵入性很强,而且这种模式并不能很好地被复用,会导致开发量激增。还要考虑到网络波动等原因,为保证请求一定送达都会有重试机制,所以考虑到接口的幂等性。

消息事务(最终一致性)

消息事务其实就是基于消息中间件的两阶段提交,将本地事务和发消息放在同一个事务里,保证本地操作和发送消息同时成功。下单扣库存原理图:

 

基于消息中间件的两阶段提交方案,通常用在高并发场景下使用,牺牲数据的强一致性换取性能的大幅提升,不过实现这种方式的成本和复杂度是比较高的,还要看实际业务情况。

Seata

Seata 也是从两段提交演变而来的一种分布式事务解决方案,提供了 AT、TCC、SAGA 和XA 等事务模式,这里重点介绍 AT模式。

既然 Seata 是两段提交,那我们看看它在每个阶段都做了点啥?下边我们还以下单扣库存、扣余额举例。

 

先介绍 Seata 分布式事务的几种角色:

Seata 实现分布式事务,设计了一个关键角色 UNDO_LOG (回滚日志记录表),我们在每个应用分布式事务的业务库中创建这张表,这个表的核心作用就是,将业务数据在更新前后的数据镜像组织成回滚日志,备份在 UNDO_LOG 表中,以便业务异常能随时回滚。

第一个阶段

比如:下边我们更新 user 表的 name 字段。

  1. update user set name = '小富最帅' where name = '程序员内点事' 

首先 Seata 的 JDBC 数据源代理通过对业务 SQL 解析,提取 SQL 的元数据,也就是得到 SQL 的类型(UPDATE),表(user),条件(where name = '程序员内点事')等相关的信息。

第一个阶段的流程图

 

先查询数据前镜像,根据解析得到的条件信息,生成查询语句,定位一条数据。

  1. select  name from user where name = '程序员内点事' 

数据前镜像

 

紧接着执行业务 SQL,根据前镜像数据主键查询出后镜像数据

  1. select name from user where id = 1 

 


 

数据后镜像

 

把业务数据在更新前后的数据镜像组织成回滚日志,将业务数据的更新和回滚日志在同一个本地事务中提交,分别插入到业务表和 UNDO_LOG 表中。

回滚记录数据格式如下:包括 afterImage 前镜像、beforeImage 后镜像、 branchId 分支事务ID、xid 全局事务ID

  1.     "branchId":641789253, 
  2.     "xid":"xid:xxx"
  3.     "undoItems":[ 
  4.         { 
  5.             "afterImage":{ 
  6.                 "rows":[ 
  7.                     { 
  8.                         "fields":[ 
  9.                             { 
  10.                                 "name":"id"
  11.                                 "type":4, 
  12.                                 "value":1 
  13.                             } 
  14.                         ] 
  15.                     } 
  16.                 ], 
  17.                 "tableName":"product" 
  18.             }, 
  19.             "beforeImage":{ 
  20.                 "rows":[ 
  21.                     { 
  22.                         "fields":[ 
  23.                             { 
  24.                                 "name":"id"
  25.                                 "type":4, 
  26.                                 "value":1 
  27.                             } 
  28.                         ] 
  29.                     } 
  30.                 ], 
  31.                 "tableName":"product" 
  32.             }, 
  33.             "sqlType":"UPDATE" 
  34.         } 
  35.     ] 

这样就可以保证,任何提交的业务数据的更新一定有相应的回滚日志。

在本地事务提交前,各分支事务需向 全局事务协调者 TC 注册分支 ( Branch Id) ,为要修改的记录申请 全局锁 ,要为这条数据加锁,利用 SELECT FOR UPDATE 语句。而如果一直拿不到锁那就需要回滚本地事务。TM 开启事务后会生成全局唯一的 XID,会在各个调用的服务间进行传递。

有了这样的机制,本地事务分支(Branch Transaction)便可以在全局事务的第一阶段提交,并马上释放本地事务锁定的资源。相比于传统的 XA 事务在第二阶段释放资源,Seata降低了锁范围提高效率,即使第二阶段发生异常需要回滚,也可以快速 从UNDO_LOG 表中找到对应回滚数据并反解析成 SQL 来达到回滚补偿。

最后本地事务提交,业务数据的更新和前面生成的 UNDO LOG 数据一并提交,并将本地事务提交的结果上报给全局事务协调者 TC。

第二个阶段

第二阶段是根据各分支的决议做提交或回滚:

如果决议是全局提交,此时各分支事务已提交并成功,这时 全局事务协调者(TC) 会向分支发送第二阶段的请求。收到 TC 的分支提交请求,该请求会被放入一个异步任务队列中,并马上返回提交成功结果给 TC。异步队列中会异步和批量地根据 Branch ID 查找并删除相应 UNDO LOG 回滚记录。

 

如果决议是全局回滚,过程比全局提交麻烦一点,RM 服务方收到 TC 全局协调者发来的回滚请求,通过 XID 和 Branch ID 找到相应的回滚日志记录,通过回滚记录生成反向的更新 SQL 并执行,以完成分支的回滚。

注意:这里删除回滚日志记录操作,一定是在本地业务事务执行之后

 

上边说了几种分布式事务各自的优缺点,下边实践一下分布式事务中间 Seata 感受一下。

Seata 实践

Seata 是一个需独立部署的中间件,所以先搭 Seata Server,这里以最新的 seata-server-1.4.0 版本为例,下载地址:https://seata.io/en-us/blog/download.html

解压后的文件我们只需要关心 \seata\conf 目录下的 file.conf 和 registry.conf 文件。

Seata Server

file.conf

file.conf 文件用于配置持久化事务日志的模式,目前提供 file、db、redis 三种方式。


 

file.conf 文件配置

 

注意:在选择 db 方式后,需要在对应数据库创建 globalTable(持久化全局事务)、branchTable(持久化各提交分支的事务)、 lockTable(持久化各分支锁定资源事务)三张表。

  1. -- the table to store GlobalSession data 
  2. -- 持久化全局事务 
  3. CREATE TABLE IF NOT EXISTS `global_table` 
  4.     `xid`                       VARCHAR(128) NOT NULL
  5.     `transaction_id`            BIGINT
  6.     `status`                    TINYINT      NOT NULL
  7.     `application_id`            VARCHAR(32), 
  8.     `transaction_service_group` VARCHAR(32), 
  9.     `transaction_name`          VARCHAR(128), 
  10.     `timeout`                   INT
  11.     `begin_time`                BIGINT
  12.     `application_data`          VARCHAR(2000), 
  13.     `gmt_create`                DATETIME, 
  14.     `gmt_modified`              DATETIME, 
  15.     PRIMARY KEY (`xid`), 
  16.     KEY `idx_gmt_modified_status` (`gmt_modified`, `status`), 
  17.     KEY `idx_transaction_id` (`transaction_id`) 
  18. ) ENGINE = InnoDB 
  19.   DEFAULT CHARSET = utf8; 
  20.  
  21. -- the table to store BranchSession data 
  22. -- 持久化各提交分支的事务 
  23. CREATE TABLE IF NOT EXISTS `branch_table` 
  24.     `branch_id`         BIGINT       NOT NULL
  25.     `xid`               VARCHAR(128) NOT NULL
  26.     `transaction_id`    BIGINT
  27.     `resource_group_id` VARCHAR(32), 
  28.     `resource_id`       VARCHAR(256), 
  29.     `branch_type`       VARCHAR(8), 
  30.     `status`            TINYINT, 
  31.     `client_id`         VARCHAR(64), 
  32.     `application_data`  VARCHAR(2000), 
  33.     `gmt_create`        DATETIME(6), 
  34.     `gmt_modified`      DATETIME(6), 
  35.     PRIMARY KEY (`branch_id`), 
  36.     KEY `idx_xid` (`xid`) 
  37. ) ENGINE = InnoDB 
  38.   DEFAULT CHARSET = utf8; 
  39.  
  40. -- the table to store lock data 
  41. -- 持久化每个分支锁表事务 
  42. CREATE TABLE IF NOT EXISTS `lock_table` 
  43.     `row_key`        VARCHAR(128) NOT NULL
  44.     `xid`            VARCHAR(96), 
  45.     `transaction_id` BIGINT
  46.     `branch_id`      BIGINT       NOT NULL
  47.     `resource_id`    VARCHAR(256), 
  48.     `table_name`     VARCHAR(32), 
  49.     `pk`             VARCHAR(36), 
  50.     `gmt_create`     DATETIME, 
  51.     `gmt_modified`   DATETIME, 
  52.     PRIMARY KEY (`row_key`), 
  53.     KEY `idx_branch_id` (`branch_id`) 
  54. ) ENGINE = InnoDB 
  55.   DEFAULT CHARSET = utf8; 

registry.conf

registry.conf 文件设置 注册中心 和 配置中心:

目前注册中心支持 nacos 、eureka、redis、zk、consul、etcd3、sofa 七种,这里我使用的 eureka作为注册中心 ;配置中心支持 nacos 、apollo、zk、consul、etcd3五种方式。

registry.conf 文件配置

 

配置完以后在 \seata\bin 目录下启动 seata-server 即可,到这 Seata 的服务端就搭建好了。

Seata Client

Seata Server 环境搭建完,接下来我们新建三个服务 order-server(下单服务)、storage-server(扣减库存服务)、account-server(账户金额服务),分别服务注册到eureka。

每个服务的大体核心配置如下:

  1. spring: 
  2.     application: 
  3.         name: storage-server 
  4.     cloud: 
  5.         alibaba: 
  6.             seata: 
  7.                 tx-service-group: my_test_tx_group 
  8.     datasource: 
  9.         driver-class-name: com.mysql.jdbc.Driver 
  10.         url: jdbc:mysql://47.93.6.1:3306/seat-storage 
  11.         username: root 
  12.         password: root 
  13.  
  14. # eureka 注册中心 
  15. eureka: 
  16.     client: 
  17.         serviceUrl: 
  18.             defaultZone: http://${eureka.instance.hostname}:8761/eureka/ 
  19.     instance: 
  20.         hostname: 47.93.6.5 
  21.         prefer-ip-address: true 

业务大致流程:用户发起下单请求,本地 order 订单服务创建订单记录,并通过 RPC 远程调用 storage 扣减库存服务和 account 扣账户余额服务,只有三个服务同时执行成功,才是一个完整的下单流程。如果某个服执行失败,则其他服务全部回滚。

Seata 对业务代码的侵入性非常小,代码中使用只需用 @GlobalTransactional 注解开启一个全局事务即可。

  1. @Override 
  2. @GlobalTransactional(name = "create-order", rollbackFor = Exception.class) 
  3. public void create(Order order) { 
  4.  
  5.     String xid = RootContext.getXID(); 
  6.  
  7.     LOGGER.info("------->交易开始"); 
  8.     //本地方法 
  9.     orderDao.create(order); 
  10.  
  11.     //远程方法 扣减库存 
  12.     storageApi.decrease(order.getProductId(), order.getCount()); 
  13.  
  14.     //远程方法 扣减账户余额 
  15.     LOGGER.info("------->扣减账户开始order中"); 
  16.     accountApi.decrease(order.getUserId(), order.getMoney()); 
  17.     LOGGER.info("------->扣减账户结束order中"); 
  18.  
  19.     LOGGER.info("------->交易结束"); 
  20.     LOGGER.info("全局事务 xid: {}", xid); 

前边说过 Seata AT 模式实现分布式事务,必须在相关的业务库中创建 undo_log 表来存数据回滚日志,表结构如下:

  1. -- for AT mode you must to init this sql for you business database. the seata server not need it. 
  2. CREATE TABLE IF NOT EXISTS `undo_log` 
  3.     `id`            BIGINT(20)   NOT NULL AUTO_INCREMENT COMMENT 'increment id'
  4.     `branch_id`     BIGINT(20)   NOT NULL COMMENT 'branch transaction id'
  5.     `xid`           VARCHAR(100) NOT NULL COMMENT 'global transaction id'
  6.     `context`       VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization'
  7.     `rollback_info` LONGBLOB     NOT NULL COMMENT 'rollback info'
  8.     `log_status`    INT(11)      NOT NULL COMMENT '0:normal status,1:defense status'
  9.     `log_created`   DATETIME     NOT NULL COMMENT 'create datetime'
  10.     `log_modified`  DATETIME     NOT NULL COMMENT 'modify datetime'
  11.     PRIMARY KEY (`id`), 
  12.     UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`) 
  13. ) ENGINE = InnoDB 
  14.   AUTO_INCREMENT = 1 
  15.   DEFAULT CHARSET = utf8 COMMENT ='AT transaction mode undo table'

到这环境搭建的工作就完事了,完整案例会在后边贴出 GitHub 地址,就不在这占用篇幅了。

测试 Seata

项目中的服务调用过程如下图:

服务调用过程

 

启动各个服务后,我们直接请求下单接口看看效果,只要 order 订单表创建记录成功,storage 库存表 used 字段数量递增、account 余额表 used 字段数量递增则表示下单流程成功。

原始数据

 

请求后正向流程是没问题的,数据和预想的一样

下单数据

 

而且发现 TM 事务管理者 order-server 服务的控制台也打印出了两阶段提交的日志

控制台两次提交

 

那么再看看如果其中一个服务异常,会不会正常回滚呢?在 account-server 服务中模拟超时异常,看能否实现全局事务回滚。

全局事务回滚

 

发现数据全没执行成功,说明全局事务回滚也成功了

 

那看一下 undo_log 回滚记录表的变化情况,由于 Seata 删除回滚日志的速度很快,所以要想在表中看见回滚日志,必须要在某一个服务上打断点才看的更明显。

回滚记录

 

总结

上边简单介绍了 2PC、3PC、TCC、MQ、Seata 这五种分布式事务解决方案,还详细的实践了 Seata 中间件。但不管我们选哪一种方案,在项目中应用都要谨慎再谨慎,除特定的数据强一致性场景外,能不用尽量就不要用,因为无论它们性能如何优越,一旦项目套上分布式事务,整体效率会几倍的下降,在高并发情况下弊端尤为明显。

 

本案例 github 地址:https://github.com/chengxy-nds/Springboot-Notebook/tree/master/springboot-seata-transaction

 

来源: 程序员内点事 内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯