写点什么

Apache ShardingSphere 整合 Seata AT 分布式事务

  • 2019-07-01
  • 本文字数:1695 字

    阅读完需:约 6 分钟

Apache ShardingSphere整合Seata AT分布式事务

Seata是阿里集团和蚂蚁金服联合打造的分布式事务框架,目前版本包含了 AT 事务和 TCC 事务。其中 AT 事务的目标是在微服务架构下,提供增量的事务 ACID 语意,让用户像使用本地事务一样,使用分布式事务,核心理念同 ShardingSphere 一脉相承。

Seata AT 模型

Seata AT 事务模型包含 TM(事务管理器),RM(资源管理器),TC(事务协调器)。


其中 TC 是一个独立的服务需要单独部署,TM 和 RM 以 jar 包的方式同业务应用部署在一起,它们同 TC 建立长连接,在整个事务生命周期内,保持 RPC 通信。


其中全局事务的发起方作为 TM,全局事务的参与者作为 RM ; TM 负责全局事务的 begin 和 commit/rollback,RM 负责分支事务的执行和 commit/rollback。


ShardingSphere 分布式事务 SPI

ShardingSphere 提供了一套接入分布式事务的 SPI,设计的目标是保证数据分片后,事务的 ACID 语意。分布式事务的实现目前主要包含两阶段的 XA 和 BASE 柔性事务。Seata AT 事务作为 BASE 柔性事务的一种实现,可以无缝接入到 ShardingSphere 生态中。



两阶段 XA 事务方面,我们已经整合了 Atomikos,Narayana,Bitronix 事务管理器,XA 事务底层依赖具体的数据库厂商对 XA 两阶段提交协议的支持,通常 XA 协议通过在 Prepare 和 Commit 阶段进行 2PL(2 阶段锁),保证了分布式事务的 ACID,通常适用于短事务及非云化环境(云化环境下一次 IO 操作大概需要 20ms,两阶段锁会锁住资源长达 40ms,因此事务的 TPS 会降到 25/s 左右,非云化环境通常一次 IO 只需几毫秒,因此锁热点数据的时间相对较低)[1]。


BASE 柔性事务方面,目前我们已经完成了对 ServiceComb Saga 的整合,Saga 通过一阶段提交+补偿的方式提高了整体事务的性能,其中补偿的方式同 Seata 大致相同,即对分片后的物理 SQL 进行 revert 来生成补偿的 SQL,但 Saga 模型在理论上不支持隔离级别,适用于对性能要求较高,对一致性要求比较低的业务。Seata AT 事务在一阶段提交+补偿的基础上,通过 TC 的全局锁实现了 RC 隔离级别的支持,是介于 XA 和 Saga 之间的另一种实现。消息柔性事务方面,也欢迎大家参考我们的 SPI 提供整合的方案。

整合方案

整合 Seata AT 事务时,需要把 TM,RM,TC 的模型融入到 ShardingSphere 分布式事务的 SPI 的生态中。在数据库资源上,Seata 通过对接 DataSource 接口,让 JDBC 操作可以同 TC 进行 RPC 通信。同样,ShardingSphere 也是面向 DataSource 接口对用户配置的物理 DataSource 进行了聚合,因此把物理 DataSource 二次包装为 Seata 的 DataSource 后,就可以把 Seata AT 事务融入到 ShardingSphere 的分片中。


在 Seata 模型中,全局事务的上下文存放在线程变量中,通过扩展服务间的 transport,可以完成线程变量的传递,分支事务通过线程变量判断是否加入到整个 Seata 全局事务中。而 ShardingSphere 的分片执行引擎通常是按多线程执行,因此整合 Seata AT 事务时,需要扩展主线程和子线程的事务上下文传递,这同服务间的上下文传递思路完全相同。


Quick Start

我们已经实现了 base-seata-raw-jdbc-example,大家可以自行进行尝试。


https://github.com/apache/incubator-shardingsphere-example/tree/dev/sharding-jdbc-example/transaction-example/transaction-base-seata-example/transaction-base-seata-raw-jdbc-example


操作手册:


  1. 按照 seata-work-shop 中的步骤,下载并启动 seata server。


https://github.com/seata/seata-workshop


参考 Step6 和 Step7 即可


  1. 在每一个分片数据库实例中执行 resources/sql/undo_log.sql 脚本,创建 undo_log 表

  2. Run YamlConfigurationTransactionExample.java

待优化项

Seata AT 事务在 Revert SQL 时,需要对 ShardingSphere 分片后的物理 SQL 进行二次的解析,这里我们需要设计一个 SPI,避免 SQL 二次解析的性能损耗。


参考论文


[1]: Transactions for Distributed Actors in the Cloud


https://www.microsoft.com/en-us/research/wp-content/uploads/2016/10/EldeebBernstein-TransactionalActors-MSR-TR-1.pdf


本文转载自公众号 ShardingSphere 官微(ID:Sharding-Sphere)


原文链接


https://mp.weixin.qq.com/s/xfUGep5XMcIqRTGY3WFpgA


2019-07-01 08:0021936

评论

发布
暂无评论
发现更多内容

Casper Network (CSPR)2024 年愿景:通过投资促进增长

股市老人

Mac软件:使用【Path Finder】来管理你的文件

Rose

最近很火的一款的低代码开发平台

互联网工科生

软件开发 低代码 JNPF 引迈信息

Casper Labs 与 IBM Consulting 合作,透明度、审计能力的新方案

股市老人

文心一言 VS 讯飞星火 VS chatgpt (177)-- 算法导论13.3 6题

福大大架构师每日一题

福大大架构师每日一题

SiteSucker Pro嵌入式视频下载工具 Mac破解软件 兼容M1/M2

Rose

Internet Status for Mac(网络连接状态查看工具)v5.7激活版 兼容M1/M2

Rose

专业的字体设计软件 FontLab

Rose

Substance 3D Designer最新图文安装教程 附Ds激活补丁

Rose

学习如何使用 Python 连接 MongoDB: PyMongo 安装和基础操作教程

小万哥

Python 数据库 程序人生 软件工程 后端开发

浅谈6种流行的API架构风格

EquatorCoco

架构 开发 API

十分钟教你在 k8s 中部署一个前后端应用

不在线第一只蜗牛

Kubernetes 容器 云原生 k8s

tb商品评论数据接口Python

tbapi

淘宝API接口 淘宝商品评论接口 天猫商品评论接口 天猫评论接口 淘宝评论接口

indesign2024打开后进不了页面

Rose

活动 | Mint Blockchain 将于 2024 年 1 月 17 号启动 MintID 限量发行活动

NFT Research

blockchain NFT\

苹果软件推荐:fork for mac破解版 GIT客户端

Rose

Mac财务管理软件Money Pro - 可同步账单、预算和账户

Rose

【SpringBoot实战专题】「开发实战系列」全方位攻克你的技术盲区之Spring定义Jackson转换Null的方法和实现案例

洛神灬殇

Java spring springboot 后端技术、 2024年第八篇文章

500mA High Voltage Linear Charger with OVP/OCP

芯动大师

左耳听风 - 有竞争力的程序员「读书打卡 day 05」

Java 工程师蔡姬

读书笔记 程序员 个人成长 读书 竞争力

Mac系统维护工具TinkerTool System v8.89最新下载

Rose

AWS改革6万人的销售团队以解决客户投诉问题

B Impact

语音聊天室APP运营第一天:打造交互式社交体验

山东布谷科技胡月

语音直播 语音聊天室开发 语聊平台 语音派对房

为什么思科愿意高价收购一家云网络创业公司

B Impact

Mac音乐制作软件 Live 11 详细图文安装教程 附Ableton Live激活工具

Rose

必看:详解淘宝店铺订单数据API文档

tbapi

淘宝API接口 淘宝店铺订单接口 天猫店铺订单接口 淘宝店铺订单详情接口

授权的艺术

俞凡

管理

Apache ShardingSphere整合Seata AT分布式事务_架构_分片生态圈_InfoQ精选文章