程序员修神之路--那些分布式事务解决方案

亲爱的,关注我吧

为了保证分布式环境下数据强一致性,需要引入分布式事务,而分布式事务由于网络环境的不确定性,天生就很难实现。具体可以见上一篇。

[分布式下,我想要强一致性]

为了保证分布式事务的正确性,目前互联网领域有几种流行的解决方案,但是大部分都没有像XA事务一样形成标准的工业规范。但是这些方案在某些特定的行业或者业务场景下却得到了越来越多的开发者的认可。

避免分布式事务

此方案提倡尽量避免分布式事务,不仅仅是因为分布式事务的难度,更是因为实现分布式事务需要更多的高级人才。如果一个操作设计到事务操作,而这些事务操作可以利用单机事务来解决,推荐首选单机事务。

当然,是否可以避免分布式事务还要看具体业务,在微服务盛行的当下,更多的还要看领域的划分标准,如果两个微服务可以合并成一个微服务,一定程度上在领域划分标准接受范围之内,可以考虑利用合并的方式来避免分布式服务。

举一个很简单的栗子:一个用户基本信息服务和用户资产服务(比如:用户经验值),当用户修改资料的时候给用户加贡献值这个业务场景下,因为涉及到用户资料修改和加贡献值两个不同服务的操作,这个时候就可以考虑将两个服务合并为一个服务,用单机的数据库事务来代替分布式事务。

在可以避免分布式事务的情况下,首选避免分布式事务

二阶段提交

二阶段(2PC)提交方案是基于X/OpenDTP标准规范的,最大的缺点在于它在第一阶段需要锁定资源,会大大降低系统的性能,大型的互联网应用并不推荐这种方案,那种对性能不敏感的企业级应用可以尝试使用。

在asp.net中,微软已经提供了分布式事务的管理类型:TransactionScope,它依赖DTC(Distributed Transaction Coordinator)服务完成事务一致性。当它包裹的代码中如果设计到多个不同物理位置的数据库的时候,它会自动升级为分布式事务,使用起来非常方便。

using (TransactionScope ts = new TransactionScope()){数据库A操作();数据库B操作();数据库C操作();ts.Complete();}

TCC

TCC本质上是一种编程模型,它提倡的是补偿操作,所以一般情况下它会有重试机制,它约定参与事务的每个业务方都需要提供三个接口,具体情况请查看上一篇文章。由于TCC的接口重试特性,所以提供的提交和取消接口必须实现幂等性。

2PC主要是针对数据库操作,而TCC主要是针对业务层面来进行操作,这在性能上比2PC要高很多,例如一个提交订单的场景,商品服务需要扣除库存,而订单系统需要创建订单,代码类似以下,请不要纠结命名和参数:

using (TransactionScope ts = new TransactionScope()){数据库A操作();//订单服务
public interface IOrderService
{//创建一个不可见的订单,返回订单号Task<string> CreateOrder();//根据订单号提交订单,使订单可见Task<int> SubmitOrder(string orderNo);//根据订单号取消订单Task<int> CancleOrder(string orderNo);
} 
//商品服务
public interface IProductService
{//根据商品id,锁定库存,返回锁定的idTask<int> LockProductStock(int productId);//根据锁定的库存id,提交事务,扣除商品库存Task<int> SubmitLockStock(int lockId);//根据锁定的库存id,取消事务,商品库存回滚Task<int> CancleLockStock(int lockId);
}//订单服务
public interface IOrderService
{//创建一个不可见的订单,返回订单号Task<string> CreateOrder();//根据订单号提交订单,使订单可见Task<int> SubmitOrder(string orderNo);//根据订单号取消订单Task<int> CancleOrder(string orderNo);
} 
//商品服务
public interface IProductService
{//根据商品id,锁定库存,返回锁定的idTask<int> LockProductStock(int productId);//根据锁定的库存id,提交事务,扣除商品库存Task<int> SubmitLockStock(int lockId);//根据锁定的库存id,取消事务,商品库存回滚Task<int> CancleLockStock(int lockId);
}   数据库B操作();数据库C操作();ts.Complete();}

其实TCC实现过程中,还有很多细节。比如:当提交事务阶段,有一个节点由于网络原因或者down机提交失败,该怎么办呢?这个时候我们要在本地引入本地消息机制,或者叫做业务活动管理器,把每个业务参与分布式事务的每个操作都记录下来,当某个过程的某个节点操作失败,无论是自动发起重试,还是手动重试都可以达到最终数据的一致性。

基于消息的事务

基于消息的分布式事务实现的是最终一致性,它是基于BASE理论的一个解决方案,最早由eBay提出并实施,它采用了消息队列来辅助实现事务控制流程,核心思想是将需要分布式处理的任务通过MQ分发给每个业务去异步执行,如果任务失败,则可以发起系统自动重试或者人工重试的纠正流程。

还是以上边的创建订单和扣减库存为栗子:

1. 首先调用订单服务的创建订单接口创建订单,如果创建成功,则发送需要扣减库存的消息(也可以看做创建订单成功的消息)到MQ。

2. 商品服务监听扣减库存消息队列,如果收到扣减库存消息,则执行扣减库存操作,如果操作成功,则回复MQ删除该消息。如果没有操作成功,则准备接收同样消息的下次投递。

这个流程看似很完美,其实有很多漏洞。

- 创建订单是第一步操作,可以看做是单纯的单机操作,这个并没有问题,但是接着发送MQ消息这一步需要和创建订单保证事务性,因为会发生创建订单成功,发送mq消息失败的情况。如果不能用技术手段来保证这两步的事务,也可以采用引入本地消息的方案,在创建订单的时候,用订单数据库来保证订单创建成功和创建订单消息表的一致性。然后发送mq成功之后,修改订单消息表的状态为发送成功,如果发送mq消息失败,则启用另外一个线程或者进程进行重试。

- 商品服务扣减库存类似,扣减库存这个操作和回复mq消息这两个操作也可以利用本地消息表的方式来解决一致性问题。当收到扣减库存消息的时候,扣减库存和添加消息成功处理记录可以利用数据库的事务来保证一致性,如果回复消息队列ack失败,就算是有重复消息,也可以根据本地的消费消息表来过滤重复消息

基于消息的分布式解决方案还有一个劣势,如果一个事务的业务参与方非常多,消息的发送可能会非常复杂,需要非常谨慎的设计。比如以上订单的栗子,现在引入了优惠券服务,在订单创建成功,需要同时扣减库存和优惠券,如果优惠券扣减失败,需要同时回滚库存和取消订单,这也只是三个业务参与方,如果是四个,五个呢?当然这在业务中也许并不常见。

基于消息的分布式事务解决方案,由于引入了重试机制,也需要接口在实现的时候支持幂等性。但从开发的角度,这种方案要比tcc以及2pc都要有优势,把每个系统之间的耦合度降到了最低,而且每个业务方的实现技术可以非常灵活,无论是采用java还是c#活着是golang都无所谓。

当然市面上基于消息的分布式解决方案各式各样,但总体来说都属于最终一致性方案。如果引入消息通道MQ的不稳定性,那还需要在各个业务方引入查询机制来确保消息的ack机制。举个栗子:如果商品服务已经正常扣减库存,由于mq问题,始终不能正常ack。这个时候订单服务是否会主动查询商品服务是否已经正常扣库存?这个时候整个架构可能就非现在这个样子了,这个要是扯起来又是一篇文章了

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

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

相关文章

7-36 社交网络图中结点的“重要性”计算 (30 分)(思路加详解)兄弟们PTA乙级题目冲起来

一&#xff1a;题目 在社交网络中&#xff0c;个人或单位&#xff08;结点&#xff09;之间通过某些关系&#xff08;边&#xff09;联系起来。他们受到这些关系的影响&#xff0c;这种影响可以理解为网络中相互连接的结点之间蔓延的一种相互作用&#xff0c;可以增强也可以减…

分享几个亲测有效的高效工作技巧

这里是Z哥的个人公众号每周五11&#xff1a;45 按时送达当然了&#xff0c;也会时不时加个餐&#xff5e;我的第「154」篇原创敬上大家好&#xff0c;我是Z哥。在工作中&#xff0c;你会发现有的小伙伴每天看上去很忙&#xff0c;但是好像产出的成果比旁边看上去工作轻松甚至有…

7-37 模拟EXCEL排序 (25 分)(思路+详解+超时解决 兄弟们冲呀呀呀呀呀呀)

一&#xff1a;题目 Excel可以对一组纪录按任意指定列排序。现请编写程序实现类似功能。 输入格式: 输入的第一行包含两个正整数N(≤10 5 ) 和C&#xff0c;其中N是纪录的条数&#xff0c;C是指定排序的列号。之后有 N行&#xff0c;每行包含一条学生纪录。每条学生纪录由学号…

Azure DevOps+Docker+Asp.NET Core 实现CI/CD(三.实现CD持续部署管道)

前言本文主要是讲解如何使用Azure DevOpsDocker 来实现持续集成Asp.NET Core项目(当然 也可以是任意项目).上一篇:Azure DevOpsDockerAsp.NET Core 实现CI/CD(一 .简介与创建自己的代理池)Azure DevOpsDockerAsp.NET Core 实现CI/CD(二.创建CI持续集成管道)觉得有帮助的朋友~可…

7-1 寻找大富翁 (25 分)(思路加详解+两种做法(一种优先队列,一种vector容器))

一&#xff1a;题目 胡润研究院的调查显示&#xff0c;截至2017年底&#xff0c;中国个人资产超过1亿元的高净值人群达15万人。假设给出N个人的个人资产值&#xff0c;请快速找出资产排前M位的大富翁。 输入格式: 输入首先给出两个正整数N&#xff08;≤10 6 &#xff09;和M…

7-39 魔法优惠券 (25 分)(思路加解释 用容器做的)加油兄弟们

一&#xff1a;题目 在火星上有个魔法商店&#xff0c;提供魔法优惠券。每个优惠劵上印有一个整数面值K&#xff0c;表示若你在购买某商品时使用这张优惠劵&#xff0c;可以得到K倍该商品价值的回报&#xff01;该商店还免费赠送一些有价值的商品&#xff0c;但是如果你在领取…

.NET Core Web APi大文件分片上传研究

【导读】前两天发表利用FormData进行文件上传.NET和.NET Core Web APi FormData多文件上传&#xff0c;然后有人问要是大文件几个G上传怎么搞&#xff0c;常见的不就是分片再搞下断点续传&#xff0c;动动手差不多也能搞出来&#xff0c;只不过要深入的话&#xff0c;考虑的东西…

ciclop读音,购机必备,15种 3D扫描 设备 优缺点汇总

原标题&#xff1a;购机必备&#xff0c;15种 3D扫描 设备 优缺点汇总小编总结了市场上常见的15种&#xff0c;可用于3D扫描的软件和设备&#xff0c;并详细列出有关它们的价格、优缺点等特征&#xff0c;以供大家在购机时有比较实用性参考&#xff1a;一、软件选择根据研究表明…

7-40 奥运排行榜 (25 分)(详解+思路+map+vector做法)兄弟们冲压呀呀呀呀呀呀呀

一&#xff1a;题目 每年奥运会各大媒体都会公布一个排行榜&#xff0c;但是细心的读者发现&#xff0c;不同国家的排行榜略有不同。比如中国金牌总数列第一的时候&#xff0c;中国媒体就公布“金牌榜”&#xff1b;而美国的奖牌总数第一&#xff0c;于是美国媒体就公布“奖牌…

常哥带你认识NoSQL和Redis的强大

各位朋友&#xff0c;这篇文章是针对Redis快速了解的内容&#xff0c;为了学好Redis在这里首先跟大家聊聊NoSQL相关内容&#xff0c;有了概念和方向后&#xff0c;我们再学习Redis大家会感觉得心应手。一NoSQL你必知的那些事儿1什么是NoSQL?NoSQL是Not Only SQL的缩写&#xf…

java当中用UDP实现相互交流

一&#xff1a;引言 实现一方 到另一方可以发送信息&#xff0c;而另一方也能回复信息。这里用到了多线程&#xff0c;开辟两条不同的执行路径&#xff0c;一个执行接收信息&#xff0c;一个执行发送信息&#xff0c;但其端口号 要对应 &#xff0c;即一个发送端口&#xff0c…

7-41 PAT排名汇总 (25 分)(详解+思路+重写sort函数)兄弟们冲呀呀呀呀呀呀呀

一&#xff1a;题目 计算机程序设计能力考试&#xff08;Programming Ability Test&#xff0c;简称PAT&#xff09;旨在通过统一组织的在线考试及自动评测方法客观地评判考生的算法设计与程序设计实现能力&#xff0c;科学的评价计算机程序设计人才&#xff0c;为企业选拔人才…

使用 Azure Web 应用防火墙拦截黑客攻击

点击上方蓝字关注“汪宇杰博客”导语开发或运维过网站的朋友总免不了遇到不怀好意的访客。互联网上有许多全自动黑客工具及脚本&#xff0c;可以扫描你的网站是否有已知安全漏洞&#xff0c;并全自动发起攻击&#xff0c;企图夺取服务器控制权。尽管我们可以在编写网站程序的时…

libgo 支持mysql,loadrunner通过使用libmysql.dll完成mysql的测试-Go语言中文社区

【1】需要使用到MySQL的libmysql.dll动态链接库&#xff0c;因此需要安装MySQL&#xff1b;注&#xff1a;本地安装的MySQL最好和MySQL数据库服务器上的版本一致&#xff1b;(本次使用的是MYSQL 5.6)【2】LoadRunner选择“CVuser”协议&#xff1b;【3】选择“File”→“Add Fi…

Java使用TCP实现群聊 聊天室(多线程和tcp的使用)

一&#xff1a;引言&#xff1a; 显示结果在控制台显示&#xff0c;未能实现图形界面的结合 二&#xff1a;上码 1.服务端 package com.wyj.talkhome; /** * 实现一个用户可以接发多条消息 * * */ import java.io.DataInputStream; import java.io.DataOutputStream; imp…

Azure WAF 导致网站无法登录 AAD 的解决办法

点击上方蓝字关注“汪宇杰博客”导语昨天写了篇《使用 Azure Web 应用防火墙拦截黑客攻击》然后自爆了&#xff0c;我博客的后台管理被 WAF 干掉了。我996了半小时&#xff0c;终于让 Azure WAF 放过了被误杀的平民。今天把方法分享给大家。误杀平民我的博客后台配置了 Azure A…

Java用TCP手写聊天室 可以 私聊版加群聊版

一&#xff1a;引言 想要私聊必须有规定的格式&#xff1a;名字&#xff1a;要说的话 二&#xff1a;上码 1.服务端 package com.wyj.talkhome; /** * 实现一个用户可以接发多条消息 * * */ import java.io.DataInputStream; import java.io.DataOutputStream; import ja…

macbook oracle 工具,Navicat for Oracle Mac 四种实用工具

Navicat for Oracle Mac 凭借精心设计的用户界面&#xff0c;可以简便快捷地以安全且简单的方法创建、组织、访问和共享信息&#xff0c;优化 Oracle 管理。除了 Oracle 的核心功能外&#xff0c;Navicat for Oracle Mac 也提供了一些丰富的增强功能&#xff0c;包括数据模型工…

7-42 整型关键字的散列映射 (25 分)(思路加详解)兄弟们 来呀 写题呀

一&#xff1a;题目 给定一系列整型关键字和素数P&#xff0c;用除留余数法定义的散列函数H(Key)Key将关键字映射到长度为P的散列表中。用线性探测法解决冲突。 输入格式: 输入第一行首先给出两个正整数N&#xff08;≤1000&#xff09;和P&#xff08;≥N的最小素数&#xf…

TIOBE 8 月榜单:C 力压 Java 夺得第一,Java掉了1.6 个点

喜欢就关注我们吧&#xff01;TIOBE 已公布 2020 年 8 月的编程语言排行榜。本月编程语言界无大事发生。增长指数最高的是排在第八位的 R 语言&#xff0c;TIOBE 猜测它有可能成为 2020 年的年度编程语言。年初的时候 R 语言排名 18&#xff0c;之后一直保持上升趋势&#xff0…