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,一经查实,立即删除!

相关文章

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

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

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

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

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

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

模版进阶C++

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

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

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

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

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

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

一、一阶线性微分方程 两种形式: 非齐次: 齐次: 推导过程 推导公式的过程一般由特殊到一般:所以先求解齐次方程的解 (然后对等式两边同时积分) 再来求非齐次方程的解,由…

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

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

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

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

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

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

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

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

Python测试框架pytest介绍用法

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

C++内存模型与内存序

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

力扣706:设计哈希映射

题目: 不使用任何内建的哈希表库设计一个哈希映射(HashMap)。 实现 MyHashMap 类: MyHashMap() 用空映射初始化对象void put(int key, int value) 向 HashMap 插入一个键值对 (key, value) 。如果 key 已经存在于映射中&#x…

【GPU驱动开发】- mesa编译与链接过程详细分析

前言 不必害怕未知,无需恐惧犯错,做一个Creator! 一、总体框架图 暂时无法在飞书文档外展示此内容 二、Mesa API 处理 OpenGL 函数调用 Mesa API 负责实现 OpenGL 和其他图形 API 的函数接口。Mesa API 表是一个重要的数据结构&#xf…

数据中台的演进与实践——构建企业的数字核心_光点科技

数据中台,一个在近年来被频繁提及的概念,已经成为众多企业数字化转型的核心组成部分。然而,尽管它的重要性被业界广泛认可,对于数据中台的深入理解和有效实践仍然是许多企业面临的挑战。在本文中,我们将从数据中台的演…

基于window安装Elasticsearch详细教程

目录 一、安装Java环境1.1 Java版本选择 二、下载和安装ES2.1 下载地址2.2 文件目录 3、启动服务3.1 以管理员身份打开cmd3.2 首次登录会有密码,需要记住3.3 访问 一、安装Java环境 1.1 Java版本选择 官网地址:https://www.elastic.co/cn/support/matr…

9个接口性能优化方案,RT从9000ms到180ms

昨天接到生产 SkyWalking 链路监控告警: 服务的百分位数响应时间在过去的 10 分钟内超过 2000 毫秒的次数达到 3 次。 经过不断的优化,将接口从 9000ms 优化到 180ms,先看结果 优化前: 优化后: 废话不多我们开始 一、定位性能差的…

Maven实战(2)之搭建maven私服

一, 背景: 如果使用国外镜像,下载速度比较慢; 如果使用阿里云镜像,速度还算OK,但是假如网速不好的时候,其实也是比较慢的; 如果没有网的情况下更加下载不了. 二, 本地仓库、个人/公司私服、远程仓库关系如下: 三, 下载安装nexus私服 略

Notepad3:告别Windows记事本,轻松进行文本编辑

名人说:莫道桑榆晚,为霞尚满天。——刘禹锡(刘梦得,诗豪) 创作者:Code_流苏(CSDN)(一个喜欢古诗词和编程的Coder😊) 目录 一、什么是Notepad3?①Notepad3②核…