ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

分布式事务篇

2021-08-27 03:00:06  阅读:220  来源: 互联网

标签:回滚 协调者 事务 commit TCC 参与者 分布式


点赞再看,养成习惯,微信搜索「小大白日志」关注这个搬砖人。

文章不定期同步公众号,还有各种一线大厂面试原题、我的学习系列笔记。

分布式事务的四种处理措施

在分布式系统中实现分布式事务,它有多个本地事务组成。事务一般遵守ACID(原子性、一致性、隔离性、持久性),但分布式事务很难ACID都满足。一般实现分布式事务有4种方法:2PC、TCC、本地消息表、RocketMQ消息事务

2PC
  • 定义:顾名思义,这个过程有两步=P+C:做一些准备工作来锁定资源,除了提交事务之外啥事都做了(P)->提交或者回滚事务(C);

一般会有一个事务协调者、多个事务参与者,首先事务协调者会群发“准备命令”给各个事务参与者,各个事务参与者除了“commit”命令之外准备工作都做完了,然后发送“准备成功”给事务协调者 -> 事务协调者群发“commit”命令让每个事务参与者提交各自本地的事务;

  • 特点:
    • 假如在第一阶段就有参与者返回“准备失败”,则协调者群发“回滚”命令让各参与者回滚;
    • 假如第二阶段失败了(1)如果是某个参与者“commit”失败,则不断重试直到成功(2)如果是某个参与者“回滚”失败,也是不断重试
    • 假如协调者很久没收到某个参与者的“准备成功”命令,则等待一定的时间后就认为该参与者准备失败,群发“回滚”命令让其他参与者回滚操作
  • 弊端:各个事务参与者做完准备工作之后必须阻塞等待其他参与者完成才能“commit”;系统对事务协调者依赖过大,一旦协调者发生故障不能用,那么整个系统分布式事务将不可用

image

TCC
  • 定义:T=try=预留资源,C=confirm=预留资源成功则提交事务,C=cancel=预留资源失败则回滚事务;TCC方案有一个事务协调者(和2PC一样)、多个'TCC服务',一个事务协调者协调多个'TCC服务'的事务提交和回滚,所以每个'TCC服务'都要实现try/confirm/cancel方法;首先事务协调者会调用所有'TCC服务'的try方法去预留资源,所有'TCC服务'预留成功则返回成功标识,事务协调者再调用所有'TCC服务'的confirm方法提交事务,若有一个'TCC服务'预留失败则调用cancel回滚事务,如下:

image

  • 特点:
    • 允许空回滚:事务协调者发出的try指令由于网络原因而丢包,进而触发cancel指令,那么各'TCC服务方'就只会收到cancel指令而造成空回滚,所以'TCC服务方'应该支持空回滚,如下
      image
    • 防悬挂控制:事务协调者发出的try指令由于网络原因一直未到达各个'TCC服务方',从而事务协调者一直未收到响应而触发了cancel回滚指令,此时'TCC服务方'先收到cancel指令执行了空回滚,而后收到延迟的try指令,但'TCC服务方'应该拒绝延迟的try指令,如下
      image
本地消息表

假如现在有两个业务操作需要执行,在本地消息表中有一条对应的消息状态代表它们是否都执行成功:第一个业务操作之后,接着执行下一个业务操作,如果下一个业务操作成功,则返回结果给第一个业务去修改它们对应的某条消息状态为'成功';如果第一个或下一个业务操作失败,则它们对应本地消息表中的某条消息状态改为'失败';对于本地消息表中失败状态的消息,会有定时器去定时扫描它们并重新发起对应的业务操作

RocketMQ消息事务

有一个发送方会提前发送一个'半消息'给RocketMQ的broker(负责消息的接收、存储、发送),broker接到后返回成功标识给发送方,然后发送方执行本地事务,执行成功再发送commit给broker,然后订阅方从broker中读到commit命令代表执行完自身的业务后可以提交自身事务,提交完再回头消费这条'commit命令消息';如果发送方执行本地事务失败则发送rollback给broker,'rollback命令'和'半消息'对订阅者都是不可见的,订阅方都收不到这两种消息,也就不需要往下执行订阅方自身的事务;另外发送方需要提供一个反查询事务接口给RocketMQ的broker,以便broker在持续没有收到发送方的commit/rollback命令时,可以反查询出发送方的事务执行结果进而判断是否向订阅者提供'commit命令消息'

OK,如果文章哪里有错误或不足,欢迎各位留言。

创作不易,各位的「三连」是二少创作的最大动力!我们下期见!

标签:回滚,协调者,事务,commit,TCC,参与者,分布式
来源: https://www.cnblogs.com/mofes/p/15192266.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有