一、分布式事务

分布式事务就是指事务的参与者、支持事务的服务器、资源服务器以及事务管理器分别位于不同的分布式系统的不同节点之上。以上是百度百科的解释,简单的说,就是一次大的操作由不同的小操作组成,这些小的操作分布在不同的服务器上,且属于不同的应用,分布式事务需要保证这些小操作要么全部成功,要么全部失败。本质上来说,分布式事务就是为了保证不同数据库的数据一致性。

以商品流水账单为例,我们拆分为商品购买系统,订单系统,支付系统。

用户看中一件商品,点击购买。

商品购买系统响应用户的点击,向订单系统插入一条订单信息。

跳转到支付系统完成支付。

在用户整个购买商品的过程中,我们需要保证事件1,2,3在没有异常的情况下全部执行成功,一旦某个系统抛出异常,都需要回滚。

那么,如何保证各个子系统的操作具有一致性呢?这就是我们下面提到的分布式事务的解决方案。

在这里,文章中没有提到分布式一致性协议,下面简单列举一下,有兴趣的读者可以参考其他详细资料:

  • 两阶段提交协议
  • 三阶段提交协议
  • Paxos协议
  • Raft协议

二、分布式事务的解决方案

1.两阶段提交方案/XA方案

该方案基于两阶段提交协议,因此也叫做两阶段提交方案。在该分布式系统中,其中 需要一个系统担任协调器的角色,其他系统担任参与者的角色。主要分为Commit-request阶段和Commit阶段

请求阶段:首先协调器会向所有的参与者发送准备提交或者取消提交的请求,然后会收集参与者的决策。

提交阶段:协调者会收集所有参与者的决策信息,当且仅当所有的参与者向协调器发送确认消息时协调器才会提交请求,否则执行回滚或者取消请求。

该方案的缺陷:

  • 同步阻塞:所有的参与者都是事务同步阻塞型的。当参与者占有公共资源时,其他第三方节点访问公共资源不得不处于阻塞状态。
  • 单点故障:一旦协调器发生故障,系统不可用。
  • 数据不一致:当协调器发送commit之后,有的参与者收到commit消息,事务执行成功,有的没有收到,处于阻塞状态,这段时间会产生数据不一致性。
  • 不确定性:当协调器发送commit之后,并且此时只有一个参与者收到了commit,那么当该参与者与协调器同时宕机之后,重新选举的协调器无法确定该条消息是否提交成功。

XA方案的实现方式可以使用Spring+JTA来实现,可以参考文章:Springboot+atomikos+jta实现分布式事务统一管理

2.TCC方案

TCC方案分为Try Confirm Cancel三个阶段,属于补偿性分布式事务。

Try:尝试待执行的业务

这个过程并未执行业务,只是完成所有业务的一致性检查,并预留好执行所需的全部资源

Confirm:执行业务

这个过程真正开始执行业务,由于Try阶段已经完成了一致性检查,因此本过程直接执行,而不做任何检查。并且在执行的过程中,会使用到Try阶段预留的业务资源。

Cancel:取消执行的业务

若业务执行失败,则进入Cancel阶段,它会释放所有占用的业务资源,并回滚Confirm阶段执行的操作。

以一个电商系统用户购买商品的流水线为例。

Try阶段:

在Try阶段成功之后进入Confirm阶段,如有任何异常,进入Cancel阶段。

Confirm阶段

Cancel阶段

假设库存扣减失败,此时需要回滚取消事务。

TCC方案适用于一致性要求极高的系统中,比如金钱交易相关的系统中,不过可以看出,其基于补偿的原理,因此,需要编写大量的补偿事务的代码,比较冗余。不过现有开源的TCC框架,比如TCC-transaction。

3. 本地消息表

本地消息表分布式事务解决方案是国外的eBay提出的一套方案。

需要注意的是,该方案中,在A系统中,我们首先写入业务表,然后写入消息表,然后将消息发送到MQ中,在B系统中需要先写入消息表,这是为了保证消息重复消费,为了保证消息消费的幂等性,我们可以使用数据的唯一键来约束。

当B系统执行成功之后,需要通知A系统执行成功,此时可以使用一个监听器,如Zookeeper,ZK监听到执行成功更新A系统成功。然后开始发送下一条消息。

A系统中需要有一个后台线程,不断的去判断A系统的状态为待确认的消息,设置超时机制,如果超时,重新发送到MQ中。直到执行成功。

可以看出,本地消息表方案需要写入消息表中,如果在高并发的场景下会进行大量的磁盘IO,因此该方案不适用于高并发场景。

4.可靠消息最终一致性方案

该方案基于本地消息表进行优化,不使用本地消息表,而是基于MQ,比如阿里的RocketMQ就支持消息事务。

在该方案中,首先A系统需要向MQ中发送prepare消息,然后执行A系统的业务,写入数据库成功之后向MQ发送confirm消息,当消息为confirm状态时,B系统就可以消费到消息,消费成功之后返回ACK确认消息给MQ。

需要注意的是。需要保证B系统消费消息的幂等性,可以借助第三方系统。比如在redis中设置标识,标明已经消费过该消息,或者借助ZK基于分布式锁的原理,创建节点,重复消费消息,创建失败。

5.最大努力通知方案

最大努力通知型( Best-effort delivery)是最简单的一种柔性事务,适用于一些最终一致性时间敏感度低的业务,且被动方处理结果 不影响主动方的处理结果。典型的使用场景:如银行通知、商户通知等。

在该系统中,A系统执行完本地事务,向MQ发送消息,最大努力通知服务消费消息,比如消息服务,然后调用B系统的接口,执行B系统的本地事务,如果B系统执行成功则OK,否则不断重试,重复多次之后还是失败的话就放弃执行。

这六种目前最常见分布式事务解决方案!请拿走不谢相关推荐

  1. 分布式基础-常见分布式事务解决方案

    文章目录 一.分布式事务问题及2PC/3PC协议 1.单机ACID事务 2.分布式事务产生 3.两阶段提交协议 4.三阶段提交协议 二.业务侵入的解决方案 1.消息队列 1.1.执行过程 1.2.优缺 ...

  2. 这6种最常见分布式事务解决方案!请拿走不谢!

    作者:不清不慎,目前在杭州蘑菇街公司任职,Java大数据开发工程师一枚,热爱研究开源技术! 架构师社区合伙人! 一.分布式事务 分布式事务就是指事务的参与者.支持事务的服务器.资源服务器以及事务管理器 ...

  3. 常见分布式事务解决方案

    一.分布式事务开源框架方案 市面上有很多开源的分布式事务框架,下面列举几个!!! seata,seata基本实现了最常用的各个场景的分布式事务解决方案,主要分为以下四种模式 XA模式 参考:Seata ...

  4. 分布式事务解决方案 - SpringCloud Alibaba Seata

    目录 github代码:GitHub - 18409489244/seata: 基于springcloud alibaba seata 的分布式事务demo 一.常见分布式事务解决方案 二.分布式事务 ...

  5. 分布式事务解决方案分布式事务原理

    分布式事务解决方案&分布式事务原理 0. 前言 1. 单数据源事务 & 多数据源事务 2. 常见分布式事务解决方案 2.0.什么是分布式事务 2.1. 分布式事务模型 2.2. 二将军 ...

  6. 如何选择分布式事务解决方案?

    简介: 分布式事务中涉及的参与者分布在异步网络中,参与者通过网络通信来达到分布式一致性,网络通信不可避免出现失败.超时的情况,因此分布式事务的实现比本地事务面临更多的困难.本文归纳总结五种分布式事务解 ...

  7. 一行代码,保障分布式事务一致性—GTS:微服务架构下分布式事务解决方案

    摘要: 虽然微服务现在如火如荼,但对其实践其实仍处于初级阶段.即使互联网巨头的实践也大多是试验层面,鲜有核心业务系统微服务化的案例.GTS是目前业界第一款,也是唯一的一款通用的解决微服务分布式事务问题 ...

  8. 程序员修神之路--那些分布式事务解决方案

    亲爱的,关注我吧 为了保证分布式环境下数据强一致性,需要引入分布式事务,而分布式事务由于网络环境的不确定性,天生就很难实现.具体可以见上一篇. [分布式下,我想要强一致性] 为了保证分布式事务的正确性 ...

  9. Spring Boot之基于Dubbo和Seata的分布式事务解决方案

    转载自 Spring Boot之基于Dubbo和Seata的分布式事务解决方案 1. 分布式事务初探 一般来说,目前市面上的数据库都支持本地事务,也就是在你的应用程序中,在一个数据库连接下的操作,可以 ...

最新文章

  1. SpringBoot (七) :SpringBoot 整合dubbo
  2. Laravel 底层是如何处理 HTTP 请求的?
  3. ★教师工资为什么这么低?/整理
  4. CCNP第四天(2) 配置、校验OSPF特殊区域类型-完全Stub区域
  5. OpenCV | 基于OpenCV的双目图像采集源代码(相机标定)
  6. vuejs之【router-link】大全(二)
  7. 我心目中未来的计算机200字,我心目中未来的计算机.doc
  8. Python 按坐标进行文字剪裁
  9. RN开发关闭所有黄色警告弹出(console.warn())
  10. 从VC6到VC9移植代码问题总结
  11. U盘插入电脑有提示声,不识别(不显示大容量存储设备)
  12. rfid破解 BLE Hacking
  13. TTS交易所的STO(证券化通证)、资产证券化(ABS)与ICO之间的区别
  14. Java-设计模式学习笔记-总结
  15. SpringCloud学习系列之三-----配置中心(Config)文件修改后,客户端动态刷新(Refresh)
  16. 词根词缀|ori/orn/ortho/pact/pan及词源O的故事
  17. 初学Flutter 环境搭建
  18. Debian11.5 最小化安装后更改主机名、安装桌面、设置默认语言、时区、静态IP、局域网DNS等
  19. (按位取反)运算的理解
  20. Java项目:考试在线报名管理系统(java+SSM+HTML+JS+jsp+mysql)

热门文章

  1. window xp 序列号|可用|有效的
  2. (全国)废旧石膏基墙板技术与设备开发中心揭牌
  3. android实现runnable接口,Android中实现Runnable接口简单例子
  4. 网站服务器数据能不能互通,原神服务器数据是否互通
  5. leetcode374375. 猜数字大小总结
  6. 天翼云Web应用防火墙(边缘云版)通过首批可信认证
  7. 只言片语 - 唯美图片与优美文字的完美结合
  8. SQL中的coalesce函数
  9. HTML小游戏24 —— h5魂斗罗之突围游戏(附完整源码)
  10. python使用redis缓存数据库