04.其他方案

其他方案

1.事务状态表+调⽤⽅重试+接收⽅幂等

介绍

调⽤⽅维护⼀张事务状态表(或者说事务⽇志、⽇志流⽔),在每次调⽤之前,落盘⼀条事务流⽔,⽣成⼀个全局的事务ID

事务开始之前的状态是Begin,全部结束之后的状态是End。如果某个事务⼀直停留在Begin状态,则说明该事务没有执⾏完毕

然后有⼀个后台任务,扫描状态表,在过了某段时间后(假设1次事务执⾏成功通常最多花费30s),状态没有变为最终的状态,说明这条事务没有执⾏成功。于是重新调⽤系统的接口。保证这条流⽔的最终状态是End状态

事务状态表

补充说明

  • 幂等问题:系统调用方和被调用方根据全局的事务ID做幂等操作,所以即使重复调⽤也没有关系
  • 如果后台任务重试多次仍然不能成功,要为状态表加⼀个Error状态,通过⼈⼯介⼊⼲预
  • 对于同步调⽤,调⽤⽅调⽤A或B失败的时候,可以重试三次。如果重试三次还不成功,则放弃操作,再交由后台任务后续处理

2.对账

介绍

所有的“过程”都必然产⽣“结果”,过程是我们所说的“事务”,结果就是业务数据。⼀个过程如果部分执⾏成功、部分执⾏失败,则意味着结果是不完整的。从结果也可以反推出过程出了问题,从⽽对数据进⾏修补,这就是“对账”的思路

分类

  • 全量对账:⽐如每天晚上运作⼀个定时任务,对比两个数据库
  • 增量对账:可以是⼀个定时任务,基于数据库的更新时间;也可以基于消息中间件,每⼀次业务操作都抛出⼀个消息到消息中间件,然后由⼀个消费者消费这条消息,对两个数据库中的数据进⾏⽐对(当然,消息可能丢失,⽆法百分之百地保证,还是需要全量对账来兜底)

例子

案例1

电商⽹站的订单履约系统。⼀张订单从“已⽀付”,到“下发给仓库”,到“出仓完成”。假定从“已⽀付”到“下发给仓库”最多⽤1个⼩时;从“下发给仓库”到“出仓完成”最多⽤8个⼩时。意味着只要发现1个订单的状态过了1个⼩时之后还处于“已⽀付”状态,就认为订单下发没有成功,需要重新下发,也就是“重试”。同样,只要发现订单过了8个⼩时还未出仓,这时可能会发出报警,仓库的作业系统是否出了问题……诸如此类

案例2

微博的关注关系。需要存两张表,⼀张是关注表,⼀张是粉丝表,这两张表各⾃都是分库分表的。假设A关注了B,需要先以A为主键进⾏分库,存⼊关注表;再以B为主键进⾏分库,存⼊粉丝表。也就是说,⼀次业务操作,要向两个数据库中写⼊两条数据,如何保证原⼦性?

案例3

电商的订单系统也是分库分表的。订单通常有两个常⽤的查询维度,⼀个是买家,⼀个是卖家。如果按买家分库,按卖家查询就不好做;如果按卖家分库,按买家查询就不好做。这种通常会把订单数据冗余⼀份,按买家进⾏分库分表存⼀份,按卖家再分库分表存⼀份。和案例2存在同样的问题:⼀个订单要向两个数据库中写⼊两条数据,如何保证原⼦性?

案例2和3的解决思路

如果把案例 2、案例 3 的问题看作为⼀个分布式事务的话,可以⽤对账解决

因为两个库的数据是冗余的,可以先保证⼀个库的数据是准确的,以该库为基准校对另外⼀个库

总结

对账的关键是要找出“数据背后的数学规律”。有些规律⽐较直接,谁都能看出来,⽐如案例2、案例3的冗余数据库;有些规律隐含⼀些,⽐如案例1的订单履约的状态。找到了规律就可以基于规律进⾏数据的⽐对,发现问题,然后补偿

3.弱⼀致性+基于状态的补偿

场景

需求解析

对于该需求,有⼀个关键特性:对于电商的购物来讲,允许少卖,但不能超卖。⽐如有100件东西,卖给99个⼈,有1件没有卖出去,这是可以接受的;但如果卖给了101个⼈,其中1个⼈拿不到货,平台违约,这就不能接受。⽽该处就利⽤了这个特性

流程

  • 提交订单成功,扣库存成功,返回成功
  • 提交订单成功,扣库存失败,返回失败,调⽤⽅重试(此处可能会多扣库存)
  • 提交订单失败,不再扣库存,调⽤⽅重试

解决

只要最终保证库存可以多扣,不能少扣即可

但是,库存多扣了,数据不⼀致,怎么补偿呢?

库存每扣⼀次,都会⽣成⼀条流⽔记录。这条记录的初始状态是“占⽤”,等订单⽀付成功后,会把状态改成“释放”

对于那些过了很长时间⼀直是占⽤,⽽不释放的库存,要么是因为前⾯多扣造成的,要么是因为⽤户下了单但没有⽀付

通过⽐对,得到库存系统的“占⽤又没有释放的库存流⽔”与订单系统的未⽀付的订单,就可以回收这些库存,同时把对应的订单取消。类似12306⽹站,过⼀定时间不⽀付,订单会取消,将库存释放

4.重试+回滚+报警+⼈⼯修复

先扣库存,后创建订单。不做状态补偿,为库存系统提供⼀个回滚接口。创建订单如果失败了,先重试。如果重试还不成功,则回滚库存的扣减。如回滚也失败,则发报警,进⾏⼈⼯⼲预修复

总之,根据业务逻辑,通过三次重试或回滚的⽅法,最⼤限度地保证⼀致。实在不⼀致,就发报警,让⼈⼯⼲预。只要⽇志流⽔记录得完整,⼈⼯肯定可以修复!通常只要业务逻辑本⾝没问题,重试、回滚之后还失败的概率会⽐较低,所以这种办法虽然丑陋,但很实⽤

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

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

相关文章

Go语言进阶篇——文件

文件的打开 文件的常见的两种打开方式是基于os包所提供的两个函数: func Open(name string) (*File,error) func OpenFile(name string flag int perm FileMode) (*File,error)相对于前者,OpenFile可以提供更加细致的操作,而前者就是对后者的一个简单封…

码垛工作站:食品生产企业的转型助推器

在当今高度自动化的工业生产中,码垛工作站的应用正逐渐成为一种趋势。某食品生产企业在面临市场竞争加剧、人工成本上升等多重压力下,决定引入码垛工作站,以期实现生产流程的升级与变革。 一、码垛工作站引入背景 该企业主要从事休闲食品的…

Android 中的 LinearLayout 布局

在 Android 开发中,布局是至关重要的一部分,它决定了应用程序的界面结构和用户体验。LinearLayout 是 Android 中最常用的布局之一,它以线性方式排列子视图,可以垂直或水平布局。在这篇博客中,我们将深入了解 LinearLa…

数据结构实现-栈和队列

顺序栈 #include <iostream> using namespace std; #define MaxSize 50//顺序栈 template<typename ElemType> struct SqStack{ElemType data[MaxSize];int top; };//初始化 template<typename ElemType> void InitStack(SqStack<ElemType>&s){s.…

Postman和Jmeter的区别

1.用例组织方式不同 jmeter组织方式相对比较扁平&#xff0c;没有工作空间的概念&#xff0c;直接就是测试计划 postman组织方式会比较轻量级&#xff0c;只要是针对单个的HTTP请求 2.支持的接口类型与测试类型上 jmeter会更强大&#xff0c;可以支持REST、Soap等等&#xf…

Kotlin 协程遇见 Flow:打造更优雅的数据流处理

Kotlin Flow 是 Kotlin 协程库中的一个组件&#xff0c;它提供了处理异步数据流的能力。Kotlin Flow 类似于 RxJava 中的 Observable&#xff0c;但它完全基于 Kotlin 协程设计&#xff0c;使得异步流的操作变得更加简单和直观。 Flow 是冷流&#xff08;cold stream&#xff…

【贪心算法】Leetcode 455.分发饼干 376. 摆动序列 53. 最大子数组和

【贪心算法】Leetcode 455 分发饼干 376. 摆动序列【规律很多】53. 最大子数组和 455 分发饼干局部最优推全局最优&#xff1a;尽量用大饼干去满足大胃口的小朋友 376. 摆动序列【规律很多】思想&#xff1a;注意考虑一个坡度留首尾两个点、平坡、首尾 53. 最大子数组和【好思想…

15.网络游戏逆向分析与漏洞攻防-网络通信数据包分析工具-发送通信数据包至分析工具

上一个内容&#xff1a;14.数据包分析工具界面与通信设计 码云地址&#xff08;master 分支&#xff09;&#xff1a;https://gitee.com/dye_your_fingers/titan 码云版本号&#xff1a;2d6491e3c51a1a7ab4da0ee6dc4cf566a80fd6e1 代码下载地址&#xff0c;在 titan 目录下&…

模版进阶C++

非类型模版 之前我们写的模版都是在不知道模版&#xff08;类&#xff09;中有的变量的类型是什么的时候&#xff0c;我们先用模版参数定义&#xff0c;当类实例化的时候在传参确认 非类型模版&#xff1a;模版参数定义的时候也可以定义整型类型&#xff08;c20之后才支持其…

奇点云:SAFe框架下,我们对平台软件工程生产线做了4项改造

导读&#xff1a; 客户规模扩大&#xff0c;如何保证大数据软件产品和服务质量始终如一&#xff1f;几乎所有成长中的软件厂商&#xff0c;尤其是需要通过私有化部署交付的厂商&#xff0c;都会面临这个问题。正如《人月神话》中多次表明的&#xff0c;单纯地增加人手、扩大团队…

基于YOLOv8/YOLOv7/YOLOv6/YOLOv5的植物病害检测系统(Python+PySide6界面+训练代码)

摘要&#xff1a;开发高效的植物病害检测系统对于提升农业生产效率和作物健康管理意义重大。本篇博客详细阐述了如何运用深度学习技术构建一个植物病害检测系统&#xff0c;并提供了完整的实现代码。该系统基于先进的YOLOv8算法&#xff0c;对YOLOv7、YOLOv6、YOLOv5进行了性能…

考研数学——高数:微分方程

一、一阶线性微分方程 两种形式&#xff1a; 非齐次&#xff1a; 齐次&#xff1a; 推导过程 推导公式的过程一般由特殊到一般&#xff1a;所以先求解齐次方程的解 &#xff08;然后对等式两边同时积分&#xff09; 再来求非齐次方程的解&#xff0c;由…

【测开求职】2023秋招快手一面面经

已经过了百度测开三面,快手这个一面比百度的要难很多,可能也是遇到了比较严格的面试官,感觉其他面经没有这么难。30分钟实习,20分钟算法题,20分钟八股,没有问项目。 实习 diff遇到了哪些痛点diff是全量还是增量一些字段的增加或者枚举值的增加可以用diff测吗有哪些自动化…

03-grafana的下拉列表选项制作-grafana的变量

一、准备环境 为了实现下拉列表筛选的样例&#xff0c;我们监控两个linux节点&#xff1b; 目前&#xff0c;我们已经有了一个节点了&#xff0c;再添加一个&#xff1b; 二、grafana的仪表盘变量 如果想给仪表盘自定义下拉列表&#xff0c;那么&#xff0c;需要设置变量&#…

线上问题——2021-12-27 父子线程共用线程池导致死锁故障

一、事故现象 从早上6点开始edu-wings-admin的timer-task和mq就开始报警任务堆积&#xff0c;且数量持续上升&#xff0c;到6点50左右mq也开始告警&#xff0c;8点左右发现问题&#xff0c;开始排查&#xff0c;直到11点才找到问题&#xff0c;任务开始正常消费。 二、事故影响…

haproxy集成国密ssl功能[下]

上接[haproxy集成国密ssl功能上 4. 源码修改解析 以下修改基本围绕haproxy的ssl_sock.c进行修改来展开的,为了将整个实现逻辑能够说明清楚,下述内容有部分可能就是直接摘抄haproxy的原有代码没有做任何修改,而大部分增加或者修改的内容则进行了特别的说明。 4.1 为bind指令…

基于springboot+vue的疾病防控综合系统

博主主页&#xff1a;猫头鹰源码 博主简介&#xff1a;Java领域优质创作者、CSDN博客专家、阿里云专家博主、公司架构师、全网粉丝5万、专注Java技术领域和毕业设计项目实战&#xff0c;欢迎高校老师\讲师\同行交流合作 ​主要内容&#xff1a;毕业设计(Javaweb项目|小程序|Pyt…

计算机设计大赛 深度学习猫狗分类 - python opencv cnn

文章目录 0 前言1 课题背景2 使用CNN进行猫狗分类3 数据集处理4 神经网络的编写5 Tensorflow计算图的构建6 模型的训练和测试7 预测效果8 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; **基于深度学习猫狗分类 ** 该项目较为新颖&a…

Python测试框架pytest介绍用法

1、介绍 pytest是python的一种单元测试框架&#xff0c;同自带的unittest测试框架类似&#xff0c;相比于unittest框架使用起来更简洁、效率更高 pip install -U pytest 特点&#xff1a; 1.非常容易上手,入门简单,文档丰富&#xff0c;文档中有很多实例可以参考 2.支持简单的单…

C++内存模型与内存序

写在前面 在真正了解Memory Order的作用之前&#xff0c;曾经简单地将Memory Order等同于mutex和atomic来进行线程间数据同步&#xff0c;或者用来限制线程间的执行顺序&#xff0c;其实这是一个错误的理解。直到后来仔细研究了Memory Order之后&#xff0c;才发现无论是功能还…