分布式事务解决方案

快来打我* 2023-01-01 01:46 160阅读 0赞

### 文章目录 ###

*   *  1 CAP 定理
     *   *   *  1.1 概念
             *  1.2 中间件实例
     *  2 BASE 理论
     *  3 XA方案
     *   *   *  3.1 程序理解
             *  3.3 适用场景
     *  4 TCC方案
     *   *   *  4.1 三阶段
             *  4.2 跨行转账案例
             *  4.3 适用场景
             *  4.4 方案示意图
     *  5 本地消息表
     *   *   *  5.1 简介
             *  5.2 优点
             *  5.3 缺陷
     *  6 可靠消息最终一致性方案
     *   *   *  6.1 简介
     *  7 最大努力通知方案
     *   *   *  7.1 简介
     *  8 总结

## 1 CAP 定理 ##

#### 1.1 概念 ####

CAP 理论在分布式系统中

*  **一致性**：分布式环境下多个节点的数据是否强一致
 *  **可用性**：分布式服务能一直保证可用状态。当用户发出一个请求后，服务能在有限时间内返回结果
 *  **分区容忍性**：特指对网络分区的容忍性

对于共享数据系统，最多只能同时拥有CAP其中的两个，没法三者兼顾。

*  任两者的组合都有其适用场景
 *  真实系统应当是ACID与BASE的混合体
 *  不同类型的业务可以也应当区别对待
 *  `其中，分区容忍性又是不可或缺的。`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70]  
结论：分布式系统中，最重要的是满足业务需求，而不是追求抽象、绝对的系统特性。

#### 1.2 中间件实例 ####

默认优先选择AP，弱化C  
Cassandra、Dynamo 等

默认优先选择CP，弱化A  
HBase、MongoDB 等

## 2 BASE 理论 ##

**核心思想**

*  **基本可用（BasicallyAvailable）**:分布式系统在出现故障时，允许损失部分的可用性来保证核心可用。
 *  **软状态（SoftState**）:允许分布式系统存在中间状态，该中间状态不会影响到系统的整体可用性。
 *  **最终一致性（EventualConsistency）**:分布式系统中的所有副本数据经过一定时间后，最终能够达到一致的状态

一致性模型数据的一致性模型可以分成以下 3 类：

*  强一致性：数据更新成功后，任意时刻所有副本中的数据都是一致的，一般采用同步方式实现
 *  弱一致性：数据更新成功后，系统不承诺立即可以读到最新写入的值，也不承诺具体多久后可读到
 *  最终一致性：弱一致性的一种形式，数据更新成功后，系统不承诺立即可以返回最新写入的值，但是保证最终会返回上一次更新操作的值。

分布式系统数据的强一致性、弱一致性和最终一致性可以通过Quorum NRW算法分析。

只要聊到做了分布式系统，必问分布式事务，若你对分布式事务一无所知的话，确实很坑，起码得知道有哪些方案，一般怎么来做，每个方案的优缺点是什么。

现在面试，分布式系统成了标配，而分布式系统带来的分布式事务也成了标配.  
你做系统肯定要用事务，那你用事务的话，分布式系统之后肯定要用分布式事务.  
先不说你搞过没有，起码你得明白有哪几种方案，每种方案可能有啥坑？比如TCC方案的网络问题、XA方案的一致性问题

*  单块系统里的事务

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 1]

*  分布式系统里的事务

在这里插入图片描述

**分布式事务的几种解决方案**

● 异步校对数据的方式  
支付宝、微信支付主动查询支付状态、对账单的形式;

● 基于可靠消息(MQ)的解决方案  
异步场景;通用性较强;拓展性较高

● TCC编程式解决方案  
严选、阿里、蚂蚁金服自己封装的DTX

## 3 XA方案 ##

即`两阶段提交事务方案`。  
需要数据库厂商支持; JAVA组件有`atomikos`等。

#### 3.1 程序理解 ####

有一个事务管理器，负责协调多个数据库（资源管理器）的事务

事务管理器先问各个数据库预提交 ok 吗？  
如果每个数据库都回复ok，即预提交成功，就正式提交事务，在各个数据库开始执行操作，这里失败会有失败异常重试，日志分析，人工重试。

#### 3.3 适用场景 ####

较适合单块应用中，跨多库的分布式事务，而且因为严重依赖于数据库层面来搞定复杂的事务，效率很低，不适合高并发场景。

如果要玩，那么基于`Spring + JTA`就可以搞定。

互联网公司基本都不用，因为某个系统内部如果出现跨多库的操作，是不合规的!现在的微服务，一个大的系统分成几十甚至上百个服务。一般规约每个服务只能操作自己对应的一个数据库。

如果你要操作别的服务对应的库，不允许直连别的服务的库。  
要操作别人的服务的库，必须通过调用别的服务的接口

## 4 TCC方案 ##

#### 4.1 三阶段 ####

Try  
对各个服务的资源做检测,对资源进行提前锁定或者预留  
Confirm  
在各个服务中执行实际的操作  
Cancel  
如果任何一个服务的业务方法执行出错，那么这里就需要进行补偿，即执行已操作成功的业务逻辑的回滚操作

#### 4.2 跨行转账案例 ####

涉及到两个银行的分布式事务，如果用TCC方案来实现，思路是这样的：

*  **Try阶段**：先把两个银行账户中的资金给它冻结住,不让操作了
 *  **Confirm阶段**：执行实际的转账操作，A银行账户的资金扣减，B银行账户的资金增加
 *  **Cancel阶段**：如果任何一个银行的操作执行失败，那么就需要回滚进行补偿

比如A银行账户如果已经扣减了，但是B银行账户资金增加失败了，那么就得把A银行账户资金给加回去  
该方案说实话几乎很少使用，但也有使用场景.  
因为这个事务的回滚实际上严重依赖于你自己写代码来回滚和补偿了，会造成补偿代码巨大，非常恶心!

比如说我们，一般来说和钱相关的支付、交易等相关的场景，我们会用TCC，严格严格保证分布式事务要么全部成功，要么全部自动回滚，严格保证资金的正确性!

#### 4.3 适用场景 ####

除非你是真的一致性要求太高，是系统中核心之核心的场景!  
常见的就是资金类的场景，那可以用TCC方案，自己编写大量的业务逻辑，自己判断一个事务中的各个环节是否ok，不ok就执行补偿/回滚代码

而且最好是你的各个业务执行的时间都比较短

但是说实话，一般尽量别这么搞，自己手写回滚逻辑，或者是补偿逻辑，实在太恶心了，业务代码也很难维护

#### 4.4 方案示意图 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 2]

## 5 本地消息表 ##

ebay搞出来的这么一套思想

#### 5.1 简介 ####

*  A系统在本地一个事务里操作的同时，插入一条数据到消息表
 *  接着A系统将这个消息发送到MQ
 *  B系统接收到消息后，在一个事务里，往自己本地消息表里插入一条数据，同时执行其他的业务操作，如果这个消息已经被处理过了，那么此时这个事务会回滚，这样保证不会重复处理消息
 *  B系统执行成功后，就会更新自己本地消息表的状态以及A系统消息表的状态
 *  如果B系统处理失败，那么就不会更新消息表状态，那么此时A系统会定时扫描自己的消息表，如果有未处理的消息，会再次发送到MQ中去，让B再处理

#### 5.2 优点 ####

这个方案保证了最终一致性  
哪怕B事务失败了，但是A会不断重发消息，直到B那边成功为止

#### 5.3 缺陷 ####

最大的问题就在于严重依赖于数据库的消息表来管理事务,这个会导致高并发场景无力,难以扩展呢,一般确实很少用

*  本地消息表方案

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 3]

## 6 可靠消息最终一致性方案 ##

干脆不用本地的消息表了，直接基于MQ来实现事务。比如阿里的RocketMQ就支持消息事务!

#### 6.1 简介 ####

*  A系统先发送一个prepared消息到MQ，如果这个prepared消息发送失败,那么就直接取消操作,不执行了
 *  如果这个消息发送成功过了，那么接着执行本地事务，如果成功就告诉MQ发送确认消息，如果失败就告诉MQ回滚消息
 *  如果发送了确认消息，那么此时B系统会接收到确认消息，然后执行本地的事务
 *  MQ会自动定时轮询所有prepared消息回调你的接口，问你这个消息是不是本地事务处理失败了，所有没发送确认的消息,是继续重试还是回滚？  
    这里你就可以查下数据库看之前本地事务是否执行，如果回滚了，那么这里也回滚吧。这个就是避免可能本地事务执行成功了，别确认消息发送失败了。
 *  如果系统B的事务失败了咋办？  
    重试咯，自动不断重试直到成功，如果实在是不行，要么就是针对重要的资金类业务进行回滚，比如B系统本地回滚后，想办法通知系统A也回滚；或者是发送报警由人工来手工回滚和补偿

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

*  可靠消息最终一致性方案![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 4]

## 7 最大努力通知方案 ##

#### 7.1 简介 ####

系统A本地事务执行完后，发送一个消息到MQ

有一专门消费MQ的最大努力通知服务，会消费MQ,然后写入数据库中记录下来，亦可是放入内存队列，接着调用系统B的接口

若系统B执行成功就ok；若系统B执行失败，那么最大努力通知服务就定时尝试重新调用系统B，反复N次，最后还是不行才放弃

*  最大努力通知方案示意图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 5][]

## 8 总结 ##

真的被问到，可以这么说，我们某某特别严格的场景，用的是TCC来保证强一致性；然后其他的一些场景基于了阿里的RocketMQ来实现了分布式事务~

你找一个严格资金要求绝对不能错的场景，你可以说你是用的TCC方案  
如果是一般的分布式事务场景，订单插入之后要调用库存服务更新库存，库存数据没有资金那么的敏感，可以用可靠消息最终一致性方案

> Rocketmq 3.2.6之前的版本，是可以按照上面的思路来的，但是之后接口做了一些改变，不再赘述

你其实用任何一个分布式事务的这么一个方案，都会导致你那块儿代码会复杂10倍。很多情况下，系统A调用系统B、系统C、系统D，我们可能根本就不做分布式事务。如果调用报错会打印异常日志。

每个月也就那么几个bug，很多bug是功能性的，体验性的，真的是涉及到数据层面的一些bug，一个月就几个，两三个？如果你为了确保系统自动保证数据100%不能错，上了几十个分布式事务，代码太复杂；性能太差，系统吞吐量、性能大幅度下跌。

99%的分布式接口调用，不要做分布式事务，直接就是监控（发邮件、发短信）、记录日志（一旦出错，完整的日志）、事后快速的定位、排查和出解决方案、修复数据。  
每个月，每隔几个月，都会对少量的因为代码bug，导致出错的数据，进行人工的修复数据，自己临时动手写个程序，可能要补一些数据，可能要删除一些数据，可能要修改一些字段的值。

比你做50个分布式事务，成本要来的低上百倍，低几十倍

trade off，权衡，要用分布式事务的时候，一定是有成本，代码会很复杂，开发很长时间，性能和吞吐量下跌，系统更加复杂更加脆弱反而更加容易出bug；好处，如果做好了，TCC、可靠消息最终一致性方案，一定可以100%保证你那快数据不会出错。

1%，0.1%，0.01%的业务，资金、交易、订单，我们会用分布式事务方案来保证，会员积分、优惠券、商品信息，其实不要这么搞了

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70]: /images/20221120/334012ef14ff4c5c8bc03134d8f1cdac.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 1]: /images/20221120/b85f805bbfcc41af89cd6ec8d2ecbb83.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 2]: /images/20221120/5fc4170905f54dacb330eb87a4b61259.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 3]: /images/20221120/14ca09e08fb645f385d4733a62c97fbf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 4]: /images/20221120/50397063e97d4fb39e48a7567c8ad1a7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80Mjc0MDUzMA_size_16_color_FFFFFF_t_70 5]: /images/20221120/6f3b4e54ba6a4a00b26857da534d4e21.png