How to integrate SEATA AT mode with Spring Cloud

原文地址:https://alphahinex.github.io/2020/01/22/how-to-integrate-seata-at-mode-with-spring-cloud/

cover

本文基于一个 Spring Cloud 业务实例,说明如何集成 SEATA AT 模式,进行分布式事务控制。

背景介绍

SEATA 是什么?

Seata: Simple Extensible Autonomous Transaction Architecture

Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式,为用户打造一站式的分布式解决方案。 —— 引用自 SEATA 官方文档

AT 模式是什么?

TXC分布式事务简介 中提到,AT 模式意为 Automatic Taobao Transaction Constructor,但在 SEATA 的官方文档中,并没有关于 AT 名称具体的解释。个人认为 AT 模式可以归类为柔性事务中的二阶段提交方式实现,一阶段先将本地事务进行提交,二阶段如果需要回滚,会根据一阶段生成的 undo log 自动进行回滚,所以可以认为 AT 模式是自动完成回滚的二阶段提交分布式事务处理模型,这也应该是 AT 模式名称的由来。

为什么要使用 SEATA AT 模式?

由上述内容可以看到,AT 模式的优缺点非常明显:

  • 优点:侵入性小,可以用较小代价获得基本的分布式事务控制
  • 缺点:一阶段会直接提交,不保证读隔离性

如果应用在特定场景下,必需要求全局的 读已提交 ,目前 Seata 的方式是通过 SELECT FOR UPDATE 语句的代理。

为了付出二成努力获得八成效果,AT 模式的优点具有很强吸引力。

基础环境

假设当前有这样一个基础微服务环境:

包含以下服务:

  1. 库存服务(storage)
  2. 用户账户服务(account)
  3. 订单服务(order)
  4. 业务服务(business)

业务服务作为直接被调用的接口,组织关联其他三个服务。下订单时,服务的调用顺序如下:

1. 减库存(storage)
2. 创建订单
2.1. 扣减用户账户(account)
2.2. 生成订单(order)

实例

这里 构建了一个包含上述环境的可运行实例,可导入 IDEA 中或使用提供的 docker-compose 查看效果。

注意:该实例运行需要用到发布到 GitHub Packages Registry 的 jar 包,可参考 GitHub Packages in Action 进行配置。

可以在发送第二个 POST 请求得到异常之后查看数据库的数据变化情况,也可以通过集成测试来验证在没有分布式事务控制的情况下,发生异常时三个服务的数据状态出现了不一致。

集成 SEATA AT 模式

集成所需所有改动可见 https://github.com/AlphaHinex/seata-at-demo/compare/master...seata-at

添加 SEATA 依赖

implementation 'com.alibaba.cloud:spring-cloud-starter-alibaba-seata:2.1.1.RELEASE'
implementation 'io.seata:seata-all:1.0.0'
implementation 'io.seata:seata-spring-boot-starter:1.0.0'

为什么需要三个 SEATA 的依赖?每个依赖的作用是什么?

  1. spring-cloud-starter-alibaba-seata

    对 Feign Client 和全局事务 XID 进行了自动配置。

    需要注意的是 Spring Cloud Alibaba 的毕业版本的 GroupId 是 com.alibaba.cloudspring-cloud-starter-alibaba-seata 这个依赖中只依赖了 spring-cloud-alibaba-seata,所以在项目中添加 spring-cloud-starter-alibaba-seataspring-cloud-alibaba-seata 是一样的。

  2. seata-all

    spring-cloud-starter-alibaba-seata 装配的 SEATA 版本为 0.9.0,若需使用其他版本,需额外进行依赖。本例中使用的 SEATA 版本为 1.0.0,故需单独配置 io.seata:seata-all:1.0.0 依赖。

  3. seata-spring-boot-starter

包括自动代理数据源,及支持 yml 配置。

此处需注意,虽说引入此 jar 包后可以通过 yml 的方式对 registry.conf 及 file.conf 中内容进行配置,但目前仍存在一些问题导致无法全部替代 conf 配置文件。例如:

用 yml 配置与 registry.conf 相同的内容,会报 no available service 'null' found, please make sure registry config correct

服务启动后,持续报如下警告:io.seata.config.FileConfiguration : Could not found property service.disableGlobalTransaction, try to use default value instead.

类似问题在 https://github.com/seata/seata/issues/2114 中也有讨论。目前的解决方案为:还是通过 registry.conf 和 file.conf 来存放 yml 中配置无效的内容,

另外,在同时引入 spring-cloud-starter-alibaba-seataseata-spring-boot-starter 依赖时,需要排除掉 spring-cloud-alibaba-seata 里的 GlobalTransactionAutoConfiguration,否则会报错,详见 https://github.com/seata/seata/issues/2076

在各服务数据库中增加 undo_log 表

建表语句可从 SEATA 发布版中获得,如 https://github.com/seata/seata/blob/v1.0.0/script/client/at/db/mysql.sql

示例中为简化过程,所有服务共用一个数据库,并通过 mysql 启动初始化过程,在库中创建了 undo_log 表。

各服务中配置 SEATA 服务端地址

因引入了 seata-spring-boot-starter,可使用 yml 进行配置,如:

seata:
  service:
    grouplist: seata-server:8091

添加全局事务注解

终于把准备工作都完成了,使用 SEATA AT 模式最核心的一步:在 controller 或者 service 上,标记 @GlobalTransactional 注解。That's all。

没错,这就结束了。

验证

可通过集成测试对分布式事务的效果进行验证。如 seata-at-demo 中 README 所示,使用 seata-at 分支代码,在所有服务均正常启动完毕之后,可通过提供的 curl 或编写好的集成测试对效果进行验证。

集成测试结果通过,即表示分布式事务生效,在调用过程中出现异常时,之前执行过的服务对数据进行的变更会自动回滚。

使用 curl 进行验证时,需自己检查数据库中数据变化情况。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,524评论 5 460
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,869评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,813评论 0 320
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,210评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 61,085评论 4 355
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,117评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,533评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,219评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,487评论 1 290
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,582评论 2 309
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,362评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,218评论 3 312
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,589评论 3 299
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,899评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,176评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,503评论 2 341
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,707评论 2 335

推荐阅读更多精彩内容