一 单机事务

image.png

二 分布式事务

image.png

三 分布式事务两阶段方案

第一阶段，询问。第二阶段，执行
image.png

  1. 所谓的XA事务，两阶段提交，有一个事务管理器的概念，负责协调多个数据库（资源管理器）的事务，事务管理器先问问各个数据库你准备好了吗？如果每个数据库都回复ok，那么就正式提交事务，在各个数据库上执行操作；如果任何一个数据库回答不ok，那么就回滚事务。
  2. 这种分布式事务方案，比较适合单块应用里，跨多个库的分布式事务，而且因为严重依赖于数据库层面来搞定复杂的事务，效率很低，绝对不适合高并发的场景。
  3. 这个方案，我们很少用，一般来说某个系统内部如果出现跨多个库的这么一个操作，是不合规的。我可以给大家介绍一下，现在微服务，一个大的系统分成几百个服务，几十个服务。一般来说，我们的规定和规范，是要求说每个服务只能操作自己对应的一个数据库。

  4. 如果你要操作别的服务对应的库，不允许直连别的服务的库，违反微服务架构的规范，你随便交叉胡乱访问，几百个服务的话，全体乱套，这样的一套服务是没法管理的，没法治理的，经常数据被别人改错，自己的库被别人写挂。如果你要操作别人的服务的库，你必须是通过调用别的服务的接口来实现，绝对不允许你交叉访问别人的数据库！

    四 分布式事务三阶段方案

    TCC的全程是：Try、Confirm、Cancel。

  5. Try阶段：这个阶段说的是对各个服务的资源做检测以及对资源进行锁定或者预留

  6. Confirm阶段：这个阶段说的是在各个服务中执行实际的操作
  7. Cancel阶段：如果任何一个服务的业务方法执行出错，那么这里就需要进行补偿，就是执行已经执行成功的业务逻辑的回滚操作

image.png
例如：跨银行转账

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

缺点：

  1. 这种方案说实话几乎很少用人使用，我们用的也比较少，但是也有使用的场景。因为这个事务回滚实际上是严重依赖于你自己写代码来回滚和补偿了，会造成补偿代码巨大，非常之恶心。一般来说跟钱相关的，跟钱打交道的，支付、交易相关的场景，我们会用TCC，严格严格保证分布式事务要么全部成功，要么全部自动回滚，严格保证资金的正确性，在资金上出现问题。
  2. 比较适合的场景：这个就是除非你是真的一致性要求太高，是你系统中核心之核心的场景，比如常见的就是资金类的场景，那你可以用TCC方案了，自己编写大量的业务逻辑，自己判断一个事务中的各个环节是否ok，不ok就执行补偿/回滚代码。而且最好是你的各个业务执行的时间都比较短。

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

    五 本地消息表方案

    image.png
    PS：我们公司没有用zookeeper ，直接回调接口即可
    国外的ebay提出的一套思想：

  4. A在本地事务里插入业务数据同时插入一条数据到消息表

  5. 接着A将这个消息发送到MQ中去
  6. B接收消息之后，在本地事务里，先插入消息表，再插入业务表，如果消息已被处理则事务会回滚，保证不会重复处理消息
  7. B执行成功之后，就会更新自己本地消息表的状态以及A系统消息表的状态
  8. 如果B处理失败，那么就不更新消息表状态，那么此时A会定时扫描自己的消息表，如果有没处理的消息，会再次发送到MQ中去，让B再次处理
  9. 这个方案保证了最终一致性，哪怕B事务失败了，但是A会不断重发消息，直到B那边成功为止

缺点：
这个方案说实话最大的问题就在于严重依赖于数据库的消息表来管理事务，不适用高并发的场景，没发扩展

六 可靠消息最终一致性方案

也可以不用zookeeper ，调用回调接口
image.png

  1. A系统先发送一个prepared消息到mq，如果这个prepared消息发送失败那么就直接取消操作别执行了。
  2. 如果消息发送成功，那么接着执行本地事务，如果成功就告诉mq发送确认消息，如果失败就告诉mq回滚prepared消息。
  3. 如果发送了确认消息，那么此时B系统会接收到确认消息，然后执行本地的事务
  4. mq会自动定时轮询所有prepared消息回调你的接口，问你，这个消息是不是本地事务处理失败了，所有没发送确认消息？那是继续重试还是回滚？一般来说这里你就可以查下数据库看之前本地事务是否执行，如果回滚了，那么这里也回滚吧。这个就是避免可能本地事务执行成功了，别确认消息发送失败了。

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

    七 最大努力通知服务

    image.png

  6. A本地事务执行完之后，发送个消息到MQ

  7. 这里会有个专门消费MQ的最大努力通知服务，这个服务会消费MQ然后写入数据库中记录下来，或者是放入个内存队列也可以，接着调用系统B的接口
  8. 要是系统B执行成功就ok了；要是系统B执行失败了，那么最大努力通知服务就定时尝试重新调用系统B，反复N次，最后还是不行就放弃。

    八 尽量避免分布式事务

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