草庐IT

深入浅出Seata的AT模式

知了一笑 2023-04-16 原文

目录

单个掉队，导致集体被动摆烂；

一、业务背景

在分布式架构中，事务管理是个无法避开的复杂问题，虽然有多种解决方案，但是需要根据业务去选择合适的；

从个人最近几年的实践经验来看，Seata组件的AT模式比较常用，本文从实际的案例出发，来深入分析该模式的原理；

首先创建一个全局事务管理的接口，这里是在Facade服务中开启全局事务；

请求经过三个微服务，并且各个服务都进行数据源的操作，然后模拟链路成功和异常的情况，来分析不同状态的逻辑实现；

二、Seata架构

1、核心组件

三大组件

  • TC：事务协调者

即Transaction Coordinator，维护全局和分支事务的状态，驱动全局事务提交或回滚。

  • TM：事务管理器

即Transaction Manager，定义全局事务的范围，开始事务、提交事务，回滚事务。

  • RM：资源管理器

即Resource Manager，管理分支事务处理的资源，向TC注册分支事务，报告分支事务的状态，驱动分支事务提交或回滚。

基础交互

TC是需要独立部署的服务，TM和RM是集成在服务中，三大组件相互协作，共同完成分布事务的管理；

2、AT模式

事务模型

AT是Seata默认的模式，需要基于支持本地ACID事务的关系型数据库；Java应用，通过JDBC访问数据库；基于案例流程，先分析AT的事务模型；

2.1 TM负责定义全局事务的边界，向TC申请，开启一个全局事务；

2.2 全局事务创建成功后，生成全局唯一的XID；

2.3 XID会在微服务请求链路上下文中传播；

2.4 RM向TC注册分支事务，并归属到XID对应的全局事务进行调度；

2.5 TM向TC发起相应XID的全局事务提交或回滚决议；

2.6 TC完成对XID管理的全部分支事务提交或回滚的调度；

核心机制

执行阶段：每个微服务的请求完成后，基于本地数据库的事务能力，保证业务数据和回滚日志在同一个本地事务中提交，快速释放连接和对资源的锁定；

完成阶段：全局提交时分支事务已经完成提交，会清理回滚日志，快速结束流程；全局回滚基于XID和BranchID查询回滚日志，完成数据回滚；

数据源代理

在AT模式中，应用需要使用Seata组件中的JDBC代理数据源DataSourceProxy，实现对真正目标数据源的代理访问；

三、案例分析

1、流程分析

案例的简单描述

在案例中涉及三个服务，Facade服务开启全局事务，然后分别请求Account和Quartz服务的更新接口，通过Quartz接口是否抛异常来调试AT模式的原理；

从实际的请求执行来说，绝大多数的请求都是可以执行成功的，而AT模式的异步化提交极大限度的顾及全局事务的效率问题，少数失败的情况也可以通过回滚日志进行反向补偿；

2、写隔离

上述流程分析AT模式的原子性，即多个分支事务要么都成功要么都失败，接下来分析多个事务中的全局锁隔离机制，先看写隔离，假设TX1先开始；

TX1逻辑

  • TX1开始本地事务，拿到本地锁，然后执行更新操作；
  • TX1本地事务提交前，需要先获取全局锁，否则无法提交；
  • TX1获取全局锁并提交，释放本地锁，但未释放全局锁；

TX2逻辑

  • TX2此时开始本地事务，拿到本地锁；
  • TX2执行本地事务提交前，尝试获取全局锁；
  • 由于全局锁被TX1持有，TX2会重试等待全局锁；

假设TX1全局提交

  • TX1如果全局事务提交，会释放全局锁；
  • TX2获取全局锁成功，执行本地事务提交；

假设TX1全局回滚

  • TX1如果全局事务回滚，要重新获取数据的本地锁，进行回滚的补偿动作；
  • TX2如果仍在等待全局锁，并且还持有本地锁，TX1事务回滚失败，会不断的重试；
  • 当TX2等待全局锁超时，会放弃全局锁并回滚本地事务，释放本地锁；
  • TX1最终获取数据的本地锁，完成回滚动作；

在该过程中，TX1在结束前一直持有全局锁，TX2获取不到全局锁无法对相同的数据执行更新动作，所以避免了脏写的问题；

3、读隔离

在数据库本地隔离级别为读已提交或以上的基础上，Seata的AT模式默认全局隔离级别是读未提交；如果需要全局的读已提交，可以通过SELECT FOR UPDATE语句的代理；

该语句的执行也需要获取全局锁，如果全局锁被TX1持有，TX2会释放本地锁，查询会被阻塞并进行重试，拿到全局锁读取成功后返回；

四、对比XA模式

XA是一个分布式事务分段提交协议；事务管理器即TM：作为全局事务的调度者，负责整个事务中本地资源的提交和回滚；本地资源管理器即RM：大部分关系型数据库都实现了XA接口；

TM先向所有的参与事务的RM发送确认请求，根据确认的结果，判断是调用RM的commit提交还是rollback回滚；

XA具有强一致性，在2段提交的过程中，会持有资源的锁，如果是在交易下单等复杂链路中，并且并发量很高，会存在长事务风险，XA无法满足该类高并发的场景；

而在Seata的AT模式中，在服务执行完成后，直接进行RM提交和资源释放，提供了对CAP理论相对平衡的解决方案，并且没有侵入业务工程；

五、参考源码

应用仓库：
https://gitee.com/cicadasmile/butte-flyer-parent

组件封装：
https://gitee.com/cicadasmile/butte-frame-parent
深入浅出深入1691717listrongJava

有关深入浅出Seata的AT模式的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri，根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby-on-rails - Rails - 子类化模型的设计模式是什么？ - 2

    我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？ 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co

  3. ruby - 解析 RDFa、微数据等的最佳方式是什么，使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2

    我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i

  4. ruby - 如何在续集中重新加载表模式？ - 2

    鉴于我有以下迁移:Sequel.migrationdoupdoalter_table:usersdoadd_column:is_admin,:default=>falseend#SequelrunsaDESCRIBEtablestatement,whenthemodelisloaded.#Atthispoint,itdoesnotknowthatusershaveais_adminflag.#Soitfails.@user=User.find(:email=>"admin@fancy-startup.example")@user.is_admin=true@user.save!ende

  5. ruby - 是否有用于序列化和反序列化各种格式的对象层次结构的模式？ - 2

    给定一个复杂的对象层次结构，幸运的是它不包含循环引用，我如何实现支持各种格式的序列化？我不是来讨论实际实现的。相反，我正在寻找可能会派上用场的设计模式提示。更准确地说:我正在使用Ruby，我想解析XML和JSON数据以构建复杂的对象层次结构。此外，应该可以将该层次结构序列化为JSON、XML和可能的HTML。我可以为此使用Builder模式吗？在任何提到的情况下，我都有某种结构化数据-无论是在内存中还是文本中-我想用它来构建其他东西。我认为将序列化逻辑与实际业务逻辑分开会很好，这样我以后就可以轻松支持多种XML格式。 最佳答案 我最

  6. ruby - 导轨 4 : column reference "updated_at" is ambiguous with Postgres - 2

    我正在尝试使用“updated_at”字段的日期时间范围查询数据库。前端在JSON数组中发送查询:["2015-09-0100:00:00","2015-10-0223:00:00"]在RailsController中，我使用以下方法将两个字符串解析为DateTime:start_date=DateTime.parse(params[:date_range_arr][0])end_date=DateTime.parse(params[:date_range_arr][1])#...@events=@events.where('updated_atBETWEEN?AND?,start_d

  7. ruby-on-rails - environment.rb 中设置的常量在开发模式中消失 - 2

    了解Rails缓存如何工作的人可以真正帮助我。这是嵌套在Rails::Initializer.runblock中的代码:config.after_initializedoSomeClass.const_set'SOME_CONST','SOME_VAL'end现在，如果我运行script/server并发出请求，一切都很好。然而，在我的Rails应用程序的第二个请求中，一切都因单元化常量错误而变得糟糕。在生产模式下，我可以成功发出第二个请求，这意味着常量仍然存在。我已通过将以上内容更改为以下内容来解决问题:config.after_initializedorequire'some_cl

  8. Ruby:标准递归模式 - 2

    我经常迷上ruby​​的一件事是递归模式。例如，假设我有一个数组，它可能包含无限深度的数组作为元素。所以，例如:my_array=[1,[2,3,[4,5,[6,7]]]]我想创建一个方法，可以将数组展平为[1,2,3,4,5,6,7]。我知道.flatten可以完成这项工作，但这个问题是作为我经常遇到的递归问题的一个例子-因此我试图找到一个更可重用的解决方案。简而言之-我猜这种事情有一个标准模式，但我想不出任何特别优雅的东西。任何想法表示赞赏 最佳答案 递归是一种方法，它不依赖于语言。您在编写算法时要考虑两种情况:再次调用函数的情

  9. ruby - 在 Ruby 中查找多个正则表达式匹配的模式和位置 - 2

    这应该是一个简单的问题，但我找不到任何相关信息。给定一个Ruby中的正则表达式，对于每个匹配项，我需要检索匹配的模式$1、$2，但我还需要匹配位置。我知道=~运算符为我提供了第一个匹配项的位置，而string.scan(/regex/)为我提供了所有匹配模式。如果可能，我需要在同一步骤中获得两个结果。 最佳答案 MatchDatastring.scan(regex)do$1#Patternatfirstposition$2#Patternatsecondposition$~.offset(1)#Startingandendingpo

  10. ruby - sinatra 框架的 MVC 模式 - 2

    我想开始使用“Sinatra”框架进行编码，但我找不到该框架的“MVC”模式。是“MVC-Sinatra”模式或框架吗？ 最佳答案 您可能想查看Padrino这是一个围绕Sinatra构建的框架，可为您的项目提供更“类似Rails”的感觉，但没有那么多隐藏的魔法。这是使用Sinatra可以做什么的一个很好的例子。虽然如果您需要开始使用这很好，但我个人建议您将它用作学习工具，以对您来说最有意义的方式使用Sinatra构建您自己的应用程序。写一些测试/期望，写一些代码，通过测试-重复:)至于ORM，你还应该结帐Sequel其中(imho

随机推荐