专栏首页路人甲Java玩转分布式事务系列 - 可靠消息解决跨库转账问题

玩转分布式事务系列 - 可靠消息解决跨库转账问题

本文内容

  1. 什么是分布式事务
  2. 分布式事务中的难点
  3. 常见的解决方案
  4. 讲解通过可靠消息来解决分布式事务
  5. 若本文对您有一点点帮助,请帮忙转发一下,在此谢谢大家

什么是分布式事务?

有这样一个需求:

小明有两个账户,分别位于A、B两个数据库中,小明需要将A中的资金转到B中。

我们如何实现?

按照下面的方式实现看看有没有问题。

  1. 连接数据库A,获取connA连接
  2. connA打开事务
  3. A库资金减少100
  4. 连接库B,获取connB连接
  5. connB打开事务
  6. B库资金增加100
  7. connA.commit()
  8. connB.commit()

上面操作,正常情况是没有问题。

考虑如下情况:

第7步执行成功之后,网络出问题了,第8步会提交失败,此时的结果是:A库资金减少了100,B库资金却没有增加;这是一个网络问题导致了我们业务失败了,网络因素是程序不可控的一些因素,还有其他的比如运行到7之后,系统突然断电了,也会出现同样的结果。造成了数据错误,对业务影响也是比较大的。

分布式事务可以这么理解:一个业务操作中,会包含很多子业务的,每个子业务都是独立的事务,我们需要考虑的是如何保证这些子业务都成功,或者都失败。

分布式事务中的难点

  1. 分布式事务中,分支可能是各种各样的,可能存在各种异常情况导致有些成功有些却失败了,这些情况需要我们程序能够处理,保证所有的分支要么都成功、要么都失败,不能出现部分成功而部分失败的情况。
  2. 分布式事务中,很难保证多个分支同时成功。每个分支可能都是提供远程接口进行调用,之间存在网络故障的问题,前面的分支调用成功了,但是其他分支由于网络等不可控的因素而调用不成功,此时数据是很难做到同时一致性的。
  3. 实时一致性难以保证。那么我们可以做到最终一致性也是可以的。

什么是最终一致性?

就拿上面的转账来说,A库的资金减少了,由于网络问题,操作B库的connB连接断开了,导致B库资金没有增加;网络问题是可以恢复了,如果网络恢复了,系统能够给B中资金加上,这样最终数据也是正确的;这中间有段时间AB库的资金是不一致的(A库减少了100,B库应该增加100却没有增加,数据是不一致的),但是最终某个时间点数据变为一致了。能够将不一致的时间降到最低是系统需要考虑的问题。

分布式事务中,我们可以接受数据在某个时间段之内不一致,但是数据最终在某个时间点是一致的。

常见解决方案

  1. 可靠消息模式
  2. TCC模式实现

分布式事务系列中主要讲这2种方案,这两种方案基本上可以解决大多数常见的分布式事务的问题,所以咱们必须把这两种方式拿下。

下面我们介绍一下使用可靠消息如何实现?

可靠消息模式实现转账操作

两个微服务 服务A:用于操作A库中的账户 服务B:用于操作B库中的账户

两个服务都是链接独立的数据库,依靠数据库提供的功能,能够保证各自的事务。

对于用户来说过程如下:

  1. 调用服务A,扣款100
  2. 发送扣款成功的消息到消息服务
  3. 返回用户转账已受理

接着

  1. 服务B,拉取到转账消息
  2. B库中给账户+100
  3. 调用消息服务将消息删除
  4. 服务B消费的过程中,比如出现网络、机器重启等原因,导致消费失败,等机器恢复之后,可以再次消费这条消息,重试多次最终会成功

上面整个转账过程中有几点我们需要考虑一下:

  1. 如何确保A服务中扣款成功之后,消息一定能够发送成功;如果消息发送失败而丢失了,后面的业务将没法进行。这块设计如何发送可靠消息,之前消息系列的文章有介绍,大家可以看一下:聊聊业务系统中投递消息到mq的几种方式
  2. 我们的服务一般都是集群的方式,消息消费的时候,可能会出现一条消息并发消费的情况,并发情况发生的时候,如何确保消费只能够被消费成功一次。如果一条转账消息被成功消费两次,最终B账户中将增加200,导致业务出错。这块可以参考如何保证消息消费的幂等性,这块之前也有讲过,大家也可以看一下:探讨确保消息消费幂等性的几种方式

依靠消息模式实现分布式事物,比较适合消费者最终一定会处理成功的场景。比如用户注册发送邮件、发送短信、送积分等。

总结

  1. 本文主要介绍了什么是分布式事务、其中的一些难点
  2. 常见的使用最多的解决方案:异步消息处理分布式事物、tcc模式
  3. tcc模式我们在后面的文章中介绍,目前在我们自己的系统中实现了通用的tcc,已经上线运行,运行也比较稳定
  4. 对分布式事务有兴趣、或有疑问的,可以加我微信itsoku交流

本文分享自微信公众号 - 路人甲Java(javacode2018),作者:路人甲Java

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-05-16

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 从0到1,撸一个IDEA插件,So Easy!

    前段时间看到公众号一篇关于IDEA插件开发的文章,感觉写的太过于简单,所以想自己写一个IDEA插件开发的系列,从实战的角度讲解IDEA插件开发的流程。

    路人甲Java
  • java并发系列 - 第29天:高并发中常见的限流方式

    以秒杀业务为例,10个iphone,100万人抢购,100万人同时发起请求,最终能够抢到的人也就是前面几个人,后面的基本上都没有希望了,那么我们可以通过控制并发...

    路人甲Java
  • 确定能搞懂幻读?

    今天刚好在看某个公众号中提到了这个知识点,发现对这块的解释不是很到位,尤其是对幻读这块的解释,很多文章都是相互复制粘贴,所以我们看到的大部分解释都是类似的,很多...

    路人甲Java
  • Java基于redis实现分布式锁(SpringBoot)

    分布式锁,其实原理是就是多台机器,去争抢一个资源,谁争抢成功,那么谁就持有了这把锁,然后去执行后续的业务逻辑,执行完毕后,把锁释放掉。

    Happyjava
  • C语言中把数字转换为字符串 【转】

    在将各种类型的数据构造成字符串时,sprintf 的强大功能很少会让你失望。由于sprintf 跟printf 在用法上几乎一样,只是打印的目的地不同而已,前者...

    用户2038589
  • InnoDB行锁,如何锁住一条不存在的记录?

    《InnoDB,5项最佳实践,知其所以然?》发布后,不少同学留言希望讲讲MySQL的InnoDB行锁机制。要细聊MySQL的行锁,难以避免的要从事务的四种隔离级...

    架构师之路
  • LintCode 寻找丢失的数 II代码

    给一个由 1 - n 的整数随机组成的一个字符串序列,其中丢失了一个整数,请找到它。

    desperate633
  • 骰子点数之和问题

    从独立概率入手可能可以更好地解决问题,因为不需要单独考虑每个点数和的概率。6个骰子,每个骰子出现1、2、3、4、5、6的概率相等且独立随机的,所以总的情况有6^...

    冰之角
  • ASP.NET Core 3.0 原生DI拓展实现IocManager

    昨天.NET Core 3.0正式发布,创建一个项目运行后发现:原来使用的Autofac在ConfigureServices返回IServiceProvider...

    梁规晓
  • 使用了继承、多态还有工厂模式和反射,但是还是没有OO的感觉。[已经增加了实现的代码]

    最近项目里遇到了一个问题,为了解决这个问题“动用了”继承、多态还有工厂模式和反射,但是还是没有OO的感觉。呵呵。 先说一下具体情况: 1、使用短信猫来接收短...

    用户1174620

扫码关注云+社区

领取腾讯云代金券