分布式事务了解吗?你们是如何解决分布式事务问题的?(文末有福利)

目录

一、面试官心理分析

二、面试题剖析

1.XA 方案(两阶段提交方案)

2.TCC 方案

3.Saga方案

4.本地消息表

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

6.最大努力通知方案

7.你们公司是如何处理分布式事务的?

福利放送:


一、面试官心理分析

        只要聊到你做了分布式系统,必问分布式事务,你对分布式事务一无所知的话,确实会很坑,你起码得知道有哪些方案,一般怎么来做,每个方案的优缺点是什么。
        现在面试,分布式系统成了标配,而分布式系统带来的分布式事务也成了标配了。因为你做系统肯定要用事务吧,如果是分布式系统,肯定要用分布式事务吧。先不说你搞过没有,起码你得明白有哪几种方案,每种方案可能有啥坑?比如 TCC方案的网络问题、XA方案的一致性问题。

二、面试题剖析

分布式事务的实现主要有以下6种方案:
        · XA 方案
        · TCC 方案
        · SAGA 方案
        · 本地消息表
        · 可靠消息最终一致性方案
        · 最大努力通知方案

1.XA 方案(两阶段提交方案)

        所谓的 XA方案,即:两阶段提交,有一个事务管理器的概念,负责协调多个数据库(资源管理器)的事务,事务管理器先问问各个数据库你准备好了吗?如果每个数据库都回复 ok,那么就正式提交事务,在各个数据库上执行操作;如果任何其中一个数据库回答不ok,那么就回滚事务。
        这种分布式事务方案,比较适合单块应用里,跨多个库的分布式事务,而且因为严重依赖于数据库层面来搞定复杂的事务,效率很低,绝对不适合高并发的场景。如果要玩儿,那么基于Spring + JTA  就可以搞定,自己随便搜个 demo 看看就知道了。
        这个方案我们很少用,一般来说某个系统内部如果出现跨多个库的这么一个操作,是不合规的。我可以给大家介绍一下,现在微服务,一个大的系统分成几十个甚至几百个服务。一般来说,我们的规定和规范,是要求每个服务只能操作自己对应的一个数据库。
        如果你要操作别的服务对应的库,不允许直连别的服务的库,违反微服务架构的规范,你随便交叉胡乱访问,几百个服务的话,全体乱套,这样的一套服务是没法管理的和治理的,可能会出现数据被别人改错,自己的库被别人写挂等情况。因此,如果你要操作别人的服务的库,必须是通过调用别的服务的接口来实现,绝对不允许交叉访问别人的数据库。

2.TCC 方案

        TCC的全称是: Try、Confirm、Cancel
         · Try 阶段:这个阶段说的是对各个服务的资源做检测以及对资源进行锁定或者预留。
         · Confirm 阶段:这个阶段说的是在各个服务中执行实际的操作。
         · Cancel阶段:如果任何一个服务的业务方法执行出错,那么这里就需要进行补偿,就是执行已经执行成功的业务逻辑的回滚操作。(把那些执行成功的回滚)
        这种方案说实话几乎很少人使用,我们用的也比较少,但是也有使用的场景。因为这个事务回滚实际上是严重依赖于你自己写代码来回滚和补偿了,会造成补偿代码巨大,非常之恶心。
        比如说我们,一般来说跟钱相关的,跟钱打交道的,支付、交易相关的场景会用 TCC,严格保证分布式事务要么全部成功,要么全部自动回滚,严格保证资金的正确性,保证在资金上不会出现问题。而且最好是你的各个业务执行的时间都比较短。但是说实话,一般尽量别这么搞,自己手写回滚逻辑,或者是补偿逻辑,实在太恶心了,那个业务代码是很难维护的。 

3.Saga方案

        金融核心等业务可能会选择 TCC方案,以追求强一致性和更高的并发量,而对于更多的金融核心以上的业务系统,往往会选择补偿事务,补偿事务处理在 30 多年前就提出了 Saga 理论,随着微服务的发展,近些年才逐步受到大家的关注。目前业界比较公认的是采用Saga作为长事务的解决方案。
(1)基本原理
        业务流程中每个参与者都提交本地事务,若某一个参与者失败,则补偿前面已经成功的参与者。下图左侧是正常的事务流程,当执行到 T3 时发生了错误,则开始执行右边的事务补偿流程,反向执行 T3、T2、T1的补偿服务 C3、C2、C1,将 T3、T2、T1 已经修改的数据补偿掉。 

(2)使用场景
        对于一致性要求高、短流程、并发高的场景,如:金融核心系统,会优先考虑 TCC 方案。而在另外一些场景下,我们并不需要这么强的一致性,只需要保证最终一致性即可。比如很多金融核心以上的业务(渠道层、产品层、系统集成层),这些系统的特点是最终一致即可、流程多、流程长、还可能要调用其它公司的服务。这种情况如果选择 TCC 方案开发的话,一来成本高,二来无法要求其它公司的服务也遵循 TCC 模式。同时流程长,事务边界太长,加锁时间长,也会影响并发性能。
        所以 Saga 模式的适用场景是:
        · 业务流程长、业务流程多;
        · 参与者包含其它公司或遗留系统服务,无法提供 TCC 模式要求的三个接口。
(3)优势
       ·  一阶段提交本地事务,无锁,高性能;
       · 参与者可异步执行,高吞吐;
       · 补偿服务易于实现,因为一个更新操作的反向操作是比较容易理解的。
(4)缺点
        不保证事务的隔离性。 

4.本地消息表

        本地消息表其实是国外的 ebay 搞出来的一套思想,大概意思是这样的:
        1.A系统在自己本地一个事务里操作同时,插入一条数据到消息表;

        2.接着A系统将这个消息发送到 MQ 中去;
        3.B系统接收到消息之后,在一个事务里,往自己本地消息表里插入一条数据,同时执行其他的业务操作,如果这个消息已经被处理过了,那么此时这个事务会回滚,这样保证不会重复处理;
        4.B系统执行成功之后,就会更新自己本地消息表的状态以及A系统消息表的状态;

        5.如果 B系统处理失败了,那么就不会更新消息表状态,那么此时A系统会定时扫描自己的消息表,如果有未处理的消息,会再次发送到 MQ中去,让B再次处理;

        6.这个方案保证了最终一致性,哪怕B事务失败了,但是A会不断重发消息,直到 B那边成功为止。
        这个方案说实话最大的问题就在于严重依赖于数据库的消息表来管理事务啥的,如果是高并发场景咋办呢?咋扩展呢?所以一般确实很少用。

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

        这个的意思就是干脆不要用本地的消息表了,直接基于MQ来实现事务。比如阿里的RocketMQ 就支持消息事务。
        大概的意思是:

        1.A系统先发送一个 prepared 消息到 mq,如果这个 prepared 消息发送失败,那么就直接取消操作别执行了。
        2.如果这个消息发送成功了,那么接着执行本地事务,如果成功就告诉 mq 发送确认消息,如果失败就告诉 mq 发送回滚消息。
        3.如果发送了确认消息,那么此时B系统会接收到确认消息,然后执行本地的事务。

        4.mq 会自动定时轮询所有 prepared 消息回调你的接口,问你这个消息是不是本地事务处理失败了,所有没发送确认的消息,是继续重试还是回滚?一般来说这里你就可以查下数据库看之前本地事务是否执行,如果回滚了,那么这里也回滚吧。这个就是避免可能本地事务执行成功了,而确认消息却发送失败了。

        5.这个方案里,要是系统B的事务失败了咋办?重试咯,自动不断重试直到成功,如果实在是不行,要么就是针对重要的资金类业务进行回滚,比如B系统本地回滚后,想办法通知系统A也回滚;或者是发送报警由人工来手动回滚和补偿。

        6.这个还是比较合适的,目前国内互联网公司大都是这么玩儿的,要不你就用 RocketMQ 支持的,要不你就自己基于类似 ActiveMQ、RabbitMQ自己封装一套类似的逻辑出来,总之思路就是这样子的。

6.最大努力通知方案

        这个方案的大致意思就是:
        1.系统A本地事务执行完之后,发送个消息到 MQ;
        2.这里会有个专门消费 MQ 的最大努力通知服务,这个服务会消费 MQ 然后写入数据库中记录下来,或者是放入个内存队列也可以,接着调用系统B的接口;

        3.要是系统 B 执行成功就 ok 了;要是系统B执行失败了,那么最大努力通知服务就定时尝试重新调用系统 B,反复N次,最后还是不行就放弃。 

7.你们公司是如何处理分布式事务的?

        如果你真的被问到,可以这么说,我们某某特别严格的场景,用的是 TCC 来保证强一致性;然后其他的一些场景基于阿里的 RocketMoQ 来实现分布式事务。
        你找一个严格资金要求绝对不能错的场景,你可以说你是用的 TCC 方案。如果是一般的分布式事务场景,订单插入之后要调用库存服务更新库存,库存数据没有资金那么的敏感,可以用可靠消息最终一致性方案。
        友情提示一下,RocketMQ 3.2.6之前的版本,是可以按照上面的思路来的,但是之后接口做了一些改变,我这里不再赘述了。当然如果你愿意,你可以参考可靠消息最终一致性方案来自己实现一套分布式事务,比如基于 RocketMQ 来玩儿。

福利放送:

        程序员朋友们,换工作不知道简历怎么写?在职跟老板的关系如何解?35岁的危机又让你的心在滴血?
        看看前美团高级技术经理、前新东方技术总监托尼学长的《程序员职场避坑指南》吧,旨在总结可复制的经验,帮助你在职场之路上避坑。
        无论是求职面试、在职发展,还是抉择成长,在职场中会遇到的几十个核心问题,这里统统都有。
        原价399元,现价特惠10元买断,满1500人涨价。不够一杯奶茶钱,你还在犹豫什么?

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/671162.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

cmake进阶:文件操作之读文件

一. 简介 cmake 提供了 file() 命令可对文件进行一系列操作,譬如读写文件、删除文件、文件重命名、拷贝文件、创建目录等等。 接下来 学习这个功能强大的 file() 命令。 前一篇文章学习了 CMakeLists.txt语法中写文件操作。文章如下: cmake进阶&…

[极客大挑战 2019]PHP

1.通过目录扫描找到它的备份文件,这里的备份文件是它的源码。 2.源码当中涉及到的关键点就是魔术函数以及序列化与反序列化。 我们提交的select参数会被进行反序列化,我们要构造符合输出flag条件的序列化数据。 但是,这里要注意的就是我们提…

【数据结构与算法】之五道链表进阶面试题详解!

目录 1、链表的回文结构 2、相交链表 3、随机链表的复制 4、环形链表 5、环形链表(||) 6、完结散花 个人主页:秋风起,再归来~ 数据结构与算法 个人格言:悟已往之不谏,知…

本地运行AI大模型简单示例

一、引言 大模型LLM英文全称是Large Language Model,是指包含超大规模参数(通常在十亿个以上)的神经网络模型。2022年11月底,人工智能对话聊天机器人ChatGPT一经推出,人们利用ChatGPT这样的大模型帮助解决很多事情&am…

ubuntu中的docker记录(3)——如何安装nvidia-docker以更好地支持GPU加速计算应用程序的运行

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 前言一、nvidia-docker2的安装1. 安装docker2. 安装nvidia-docker2(1) 添加密钥(2) 更新软件列表(3) 安装nvidia-docker2(4) 测试nvidia-docker2 二、可能的报错及解…

springboot版本升级,及解决springsecurity漏洞问题

背景: 项目中要解决 Spring Security RegexRequestMatcher 认证绕过漏洞(CVE-2022-22978) 漏洞问题,并且需要将项目的版本整体升级到boot版本2.1.7,升级改造过程非常的痛苦,一方面对整个框架的代码不是很熟…

【云原生】Pod 的生命周期(一)

【云原生】Pod 的生命周期(一)【云原生】Pod 的生命周期(二) Pod 的生命周期(一) 1.Pod 生命期2.Pod 阶段3.容器状态3.1 Waiting (等待)3.2 Running(运行中)3…

《第一行代码》第二版学习笔记(8)——网络技术

文章目录 一、Http1、HttpURLConnection2、OKHttp 二、解析JSON格式数据1、使用JSONObject2、使用GSON解析JSON数据 一、Http 1、HttpURLConnection public void run() {HttpURLConnection connection null;BufferedReader reader null;try {URL url new URL("http://…

LangChain框架学习总结

目录 一、简介 二、概念 三、组件具体介绍 3.1 Models 3.1.1 LLMs 3.1.2 Chat Models 3.1.3 Text Embedding Modesl 3.1.4 总结 3.2 Prompts 3.2.1 LLM Prompt Template 3.2.1.1 自定义PromptTemplate 3.2.1.2 partial PromptTemplate 3.2.1.3 序列化PromptTemplat…

24.5.5(离散化+树状数组,线段树)

星期一: dp题单 背包 第四题 混可乐 cf传送门 思路:条件可演化为每种可乐值为 ai-n,选最少的可乐使总和为0(具体可看官方题解 到这会发现背包并不适合了,其实这是道bfs伪装的背包…

Unity3D DOTween

简单介绍一下 DOTween 插件的使用。 导入插件 先到 Asset Store 获取 DOTween 插件,然后在 Package Manager 的 My Assets 中搜索,下载并导入插件。 导入后,会自动弹出一个窗口,提示需要先对插件进行配置。 点击上图中的按钮&am…

【Osek网络管理测试】[TG3_TC5]等待总线睡眠状态_1

🙋‍♂️ 【Osek网络管理测试】系列💁‍♂️点击跳转 文章目录 1.环境搭建2.测试目的3.测试步骤4.预期结果5.测试结果 1.环境搭建 硬件:VN1630 软件:CANoe 2.测试目的 验证DUT在满足进入等待睡眠状态的条件时是否进入该状态 …