当前位置: 首页 > news >正文

阿里中间件(Aliware)双十一专题——“分布式事务中间件GTS(TXC)”

一、 前言

什么是事务?大家最熟悉的莫过于数据库事务,一大堆SQL操作一个DB,要么同时成功、要么同时失败。(GTS支持ACID,特此公告,不再解释)
什么是分布式事务?一大堆SQL操作N个DB,或者一大堆服务操作1个或多个DB,要么同时成功、要么同时失败。
怎么保证事务?有一个解决办法是“两阶段提交”,一阶段大家先把该做的做了但是不提交,二阶段再一起提交或都不提交。
单机事务到分布式事务的变化?在分布式环境下,所有的状态同步都需要走网络,成本变得非常高。因此做好分布式事务容易,难点在于怎样做的又快又好。
现状?分布式事务是性能杀手,千万不要使用,可以异步做最终一致,既保证性能又保证功能,完美!我们是程序员,不怕实现幂等、不怕实现补偿、不怕逻辑复杂、不怕工作量、不怕人肉、不怕加班。。。
楼主想说:niubility!然而事实的真相是,过度使用事务造成的性能下降的恶果,应该由应用的开发者承担;应用开发者在使用事务的时候,必须考虑到性能问题。然而,作为中间件,必须提供事务机制,而不是因为性能问题,就干脆不提供事务。我们有义务把通用的问题从复杂业务中抽丝剥茧,做成稳定的工具,避免重复造轮子。更何况,我们只是牺牲了那么一丢丢性能,换来的是不用加班、不用承担故障风险、可以更好的关注业务本身。

二、 GTS来了

进入正题,什么是GTS?GTS是一款高性能、高可靠、接入简单的分布式事务中间件,用于解决分布式环境下的事务一致性问题。该产品支持 DRDS(TDDL)、RDS、Oracle、MySQL、PostgreSQL、H2 等多种数据源,并可以配合使用 EDAS(HSF)、Dubbo 及多种私有 RPC 框架,同时还兼容 MetaQ(MQ) 消息队列等中间件产品,能够轻松实现分布式数据库事务、多库事务、消息事务、服务链路级事务及其各种组合,策略丰富,易用性和性能兼顾。
我们专注于提供易使用、高性能、稳定、可靠的完整的分布式事务解决方案体系。

三、 双11解决了哪些问题

作为双11战场的新兵,我们承担了阿里影业、村淘、菜鸟结算等业务线,以及公有云波司登、慧银等外部用户的双11大促。
GTS承担了保证业务数据一致的责任,并且一般在业务出现异常的时候才发挥作用,把不完整的业务数据回滚到操作之前的状态。这种异常,在业务压力不大的情况下,是低概率事件,而到了双11大促这种业务流量突发的情况下,变成了频发事件。从11.11零点到10分这段时间里,后端通用服务系统均存在不同程度限流的状况,前端业务出现了大量的不完整事务。我相信,使用GTS的产品线都可以爽歪歪、早早洗洗碎了,完全不用担心那些不完整的事务怎么处理。
事实说明,菜鸟结算、阿里影业、村淘的三个业务场景,在双11的前30分钟内,业务回滚超过5%,全天平均回滚超过2%。其他业务线普遍回滚事务超过总量的1%。无一数据不一致!!!

四、 更多的应用场景

(1)解决TDDL分库分表产生的跨数据库事务

54b00f52c432827f48929a2d635950acfa705cbf

@TxcTransaction(timeout = 60 * 1000)
void funcUseDrds(DataSource tddlDataSource) throws SQLException {
Connection connection = tddlDataSource.getConnection();
Statement statement = connection.createStatement();
try {
statement.execute("insert");
statement.execute("update");
statement.execute("delete");
} catch (Exception e) {
throw new TxcExecption(e);
} finally {
// clear env ...
}
}

(2)解决服务化产生的操作多个服务的分布式事务

b28c09f9af434173b6daa7eb3d4f1132c7aae0a6

@TxcTransaction(timeout = 60 * 1000)
void funcUseEdas(HsfService hsf) {
// 调用远端服务
boolean ret = hsf.runBusiness();
if(ret == false)
throw new TxcExecption;
}

(3)解决异构数据源,包括TDDL、MetaQ、以及其他关系型数据库产品的分布式事务问题;

380c149427ab28436cb91e85bf65cf554cc13872

@TxcTransaction(timeout = 60 * 1000)
void distributedTransaction(
Service svc,
DataSource dataSource,
Message msg, TxcMetaQProducer producer)
{

// 调用远端服务
serv.runBusiness();
// 调用DB
dataSource.executeSQL();
// 调用MQ
producer.sendMessage();
}

五、 我们的优势

完整的分布式事务解决方案;
高性能、高可靠;
九项发明专利奠定了技术壁垒;
支撑内外近50个用户,经过实际验证。

六、 未来的挑战及我们的目标

提升SQL兼容性
提升用户体验
丰富可接入资源(含nosql类、消息类、rdbms、更多服务框架)

阿里云帮助文档:https://help.aliyun.com/document_detail/43085.html?spm=5176.product29500.6.225.ePTeeW

阿里沈询:分布式事务原理与实现 2016年12月28日20:00在线直播 绝对干货等你来   立即去报名观看直播

相关文章:

  • apache shiro的工作流程分析
  • margin和padding的区别
  • Linux date 用法
  • mysql引擎更改
  • jquery中DOM节点操作(一)
  • PowerDesigner CDM中取消默认不能存在同名主键的方法
  • linux 下java环境的配置
  • dubbo源码解析(二)
  • 在VMW 虚拟桌面环境下 VC总是提示 计算虚拟磁盘空间
  • RH413-RHEL6.4课程总结
  • 摄像机成像模型
  • mybatis 获取insert返回的主键
  • 15索引器
  • (七)理解angular中的module和injector,即依赖注入
  • zzz
  • 《剑指offer》分解让复杂问题更简单
  • 【跃迁之路】【669天】程序员高效学习方法论探索系列(实验阶段426-2018.12.13)...
  • Akka系列(七):Actor持久化之Akka persistence
  • Android Volley源码解析
  • CSS实用技巧
  • dva中组件的懒加载
  • Invalidate和postInvalidate的区别
  • js数组之filter
  • Laravel5.4 Queues队列学习
  • MaxCompute访问TableStore(OTS) 数据
  • mysql 5.6 原生Online DDL解析
  • Promise面试题2实现异步串行执行
  • python_bomb----数据类型总结
  • sessionStorage和localStorage
  • underscore源码剖析之整体架构
  • 构建工具 - 收藏集 - 掘金
  • 类orAPI - 收藏集 - 掘金
  • 入口文件开始,分析Vue源码实现
  • 携程小程序初体验
  • 3月7日云栖精选夜读 | RSA 2019安全大会:企业资产管理成行业新风向标,云上安全占绝对优势 ...
  • ​软考-高级-系统架构设计师教程(清华第2版)【第15章 面向服务架构设计理论与实践(P527~554)-思维导图】​
  • #图像处理
  • (C语言)球球大作战
  • (Redis使用系列) Springboot 实现Redis 同数据源动态切换db 八
  • (二) Windows 下 Sublime Text 3 安装离线插件 Anaconda
  • (附源码)计算机毕业设计SSM在线影视购票系统
  • (提供数据集下载)基于大语言模型LangChain与ChatGLM3-6B本地知识库调优:数据集优化、参数调整、Prompt提示词优化实战
  • (一)为什么要选择C++
  • .apk 成为历史!
  • .apk文件,IIS不支持下载解决
  • .bat批处理(五):遍历指定目录下资源文件并更新
  • .NET 8.0 中有哪些新的变化?
  • .net core 6 使用注解自动注入实例,无需构造注入 autowrite4net
  • .net wcf memory gates checking failed
  • .net 获取url的方法
  • .net经典笔试题
  • .NET牛人应该知道些什么(2):中级.NET开发人员
  • .net企业级架构实战之7——Spring.net整合Asp.net mvc
  • .NET下的多线程编程—1-线程机制概述
  • .Net组件程序设计之线程、并发管理(一)