什么是分布式系统中的幂等性

最近很多人都在谈论幂等性,好吧,这回我也来聊聊这个话题,光看着俩字,一开始的确有点一头雾水,语文不好嘛,词太专业嘛,对吧

 

现如今我们的系统大多拆分为分布式SOA,或者微服务,一套系统中包含了多个子系统服务,而一个子系统服务往往会去调用另一个服务,而服务调用服务无非就是使用RPC通信或者restful,既然是通信,那么就有可能再服务器处理完毕后返回结果的时候挂掉,这个时候用户端发现很久没有反应,那么就会多次点击按钮,这样请求有多次,那么处理数据的结果是否要统一呢?那是肯定的!尤其再支付场景。

 

幂等性:就是用户对于同一操作发起的一次请求或者多次请求的结果是一致的,不会因为多次点击而产生了副作用。举个最简单的例子,那就是支付,用户购买商品使用约支付,支付扣款成功,但是返回结果的时候网络异常,此时钱已经扣了,用户再次点击按钮,此时会进行第二次扣款,返回结果成功,用户查询余额返发现多扣钱了,流水记录也变成了两条...

 

在以前的单应用系统中,我们只需要把数据操作放入事务中即可,发生错误立即回滚,但是再响应客户端的时候也有可能出现网络中断或者异常等等。

 

在增删改查4个操作中,尤为注意就是增加或者修改,

查询对于结果是不会有改变的,

删除只会进行一次,用户多次点击产生的结果一样

修改在大多场景下结果一样

增加在重复提交的场景下会出现

 

那么如何设计接口才能做到幂等呢?

方法一、单次支付请求,也就是直接支付了,不需要额外的数据库操作了,这个时候发起异步请求创建一个唯一的ticketId,就是门票,这张门票只能使用一次就作废,具体步骤如下:

  1. 异步请求获取门票
  2. 调用支付,传入门票
  3. 根据门票ID查询此次操作是否存在,如果存在则表示该操作已经执行过,直接返回结果;如果不存在,支付扣款,保存结果
  4. 返回结果到客户端

如果步骤4通信失败,用户再次发起请求,那么最终结果还是一样的

 

方法二、分布式环境下各个服务相互调用

这边就要举例我们的系统了,我们支付的时候先要扣款,然后更新订单,这个地方就涉及到了订单服务以及支付服务了。

用户调用支付,扣款成功后,更新对应订单状态,然后再保存流水。

而在这个地方就没必要使用门票ticketId了,因为会比较闲的麻烦

(支付状态:未支付,已支付)

步骤:

1、查询订单支付状态

2、如果已经支付,直接返回结果

3、如果未支付,则支付扣款并且保存流水

4、返回支付结果

如果步骤4通信失败,用户再次发起请求,那么最终结果还是一样的

对于做过支付的朋友,幂等,也可以称之为冲正,保证客户端与服务端的交易一致性,避免多次扣款。

 

最后来看一下我们的订单流程,虽然不是很复杂,但是最后在支付环境是一定要实现幂等性的

 

时间: 2024-10-08 06:17:35

什么是分布式系统中的幂等性的相关文章

如何解决分布式系统中的跨时区问题[实例篇]

关于如何解决分布式系统中的跨时区问题,上一篇详细介绍了解决方案的实现原理,在这一篇中我们通过一个完整的例子来对这个问题进行深入探讨.尽管<原理篇>中介绍了那么多,解决方案的本质就是:在进行服务调用过程中将客户端的时区信息作为上下文传入服务端,并以此作为时间转换的依据.我们首先定一个具体的类型来定义包含时区信息的上下文类型,我们将这个类型起名为ApplicationContext. 一.通过CallContext实现ApplicationContext 在<通过WCF扩展实现Context

一篇文读懂缓存在大型分布式系统中的最佳应用

本文大纲: 缓存概述 CDN缓存 反向代理缓存 分布式缓存 本地缓存 缓存架构示例 缓存常见问题        一.缓存概述       缓存是分布式系统中的重要组件,主要解决高并发,大数据场景下,热点数据访问的性能问题.提供高性能的数据快速访问.   1.缓存的原理   将数据写入/读取速度更快的存储(设备): 将数据缓存到离应用最近的位置: 将数据缓存到离用户最近的位置.   2.缓存分类   在分布式系统中,缓存的应用非常广泛,从部署角度有以下几个方面的缓存应用.   CDN缓存: 反向代

分布式系统中的RPC请求经常出现乱序的情况 写一个算法来将一个乱序的序列保序输出

分布式系统中的RPC请求经常出现乱序的情况.  写一个算法来将一个乱序的序列保序输出.例如,假设起始序号是1,对于(1, 2, 5, 8, 10, 4, 3, 6, 9, 7)这个序列,输出是:  1  2  3, 4, 5  6  7, 8, 9, 10 上述例子中,3到来的时候会发现4,5已经在了.因此将已经满足顺序的整个序列(3, 4, 5)输出为一行. 要求:  1. 写一个高效的算法完成上述功能,实现要尽可能的健壮.易于维护  2. 为该算法设计并实现单元测试 我的思路是:  假设输入

通信-在分布式系统中怎么建立深度优先生成树

问题描述 在分布式系统中怎么建立深度优先生成树 问题如下,在分布式系统中怎么建立深度优先生成树,要考虑到通信的时间延迟等问题.

如何解决分布式系统中的跨时区问题[原理篇]

一.场景以及需求 为了让大家本文介绍的主题有一个比较直观的认识,我们给出一个具体的应用场景.一个跨国公司开发一套统一的办公系统,供遍布全球的所有分公司使用.客户端的UI采用Smart Client (Windows Forms应用),而主要的业务逻辑均通过WCF服务的形式提供.我们将承载业务服务的服务器成为应用服务器,如右图(点击看大图)所示,应用服务器部属于中国境内(东8区).主要的客户端(分公司)分布于三个主要的国家和地区:北美.欧州和澳洲. 不论客户端和服务器之间,还是不同的客户端之间所处

浅析分布式系统中的 Linearizability

在分布式系统里,出于可靠性(reliability)或者性能的考虑,数据通常会被复制为多个副本.因此,系统需要定义一组协议,来规定用户读写多副本时的行为.这组协议称之为 consistency model. 最终一致性(eventually consistency),linearizability(atomic consistency)是不同类型的一致性模型.下图是最终一致性模型的示例,用户 B/C 在读取不同的副本时看到了不同的 x 的值.请注意,用户A,B,C的操作是完全串行执行的,即操作在

一起谈.NET技术,如何解决分布式系统中的跨时区问题[原理篇]

一.场景以及需求   为了让大家本文介绍的主题有一个比较直观的认识,我们给出一个具体的应用场景.一个跨国公司开发一套统一的办公系统,供遍布全球的所有分公司使用.客户端的UI采用Smart Client (Windows Forms应用),而主要的业务逻辑均通过WCF服务的形式提供.我们将承载业务服务的服务器成为应用服务器,如右图(点击看大图)所示,应用服务器部属于中国境内(东8区).主要的客户端(分公司)分布于三个主要的国家和地区:北美.欧州和澳洲. 不论客户端和服务器之间,还是不同的客户端之间

tfs分布式系统中提交时保留.refresh文件,去掉.dll文件

在bin下,若对其添加到TFS,则项目成员在生成时回相互签出,操作不便,而若掩蔽Bin文件,则.refresh文件则也被掩蔽,若添加新的引用,就不能让项目组其他成员获取. 解决方法,有TFS提供的掩蔽文件,指定哪些不添加进tfs,若dll 方法: 自动生成.tfignore文件 在 *** 挂起的更改 *** 页上,在 *** 排除的更改 *** 部分中,选择 *** 检测更改 *** 链接. *** 提升候选更改 *** 出现对话框. 选择文件,打开其快捷菜单,并选择 *** 忽略此本地项目

分布式系统中并发的问题!?

问题描述 我做了一个项目ssh+mysql,是一个兑换系统,部署在6台服务器上. 现在有一个问题请教大家: 一个商品,兑换总数是1000个,每次兑换成功就减一.但是兑完后兑换总数总大于1000. 我的程序流程是 hibernate加载 商品,产生订单,商品总数减一,提交事物. 请问各位大虾.除了把数据库加锁外,还有没别的解决方案? 问题补充:mercyblitz 写道 解决方案 分布式事物处理,这个还需要研究解决方案二:独立的数据源 是不是都读取不同的DB呢?如果不同的DB(六台)话,是不是DB