详解分布式系统的幂等后端

幂等是指一次和多次请求某一个资源应该具有同样的作用。
什么是分布式的幂等首先，我们来设想以下几个场景：
场景一：在 App 上确认订单的时候，点击多次没有反应，只能反复点击几次。在这种情况下，如果无法保证该接口的幂等性，那么将会出现重复下单的问题。
场景二：在接收消息的时候，消息推送重复。如果处理消息的接口无法保证幂等，那么重复消费的消息影响可能会非常大。
通常，为了满足高可用、高性能和高可扩展的特性，分布式系统拥有众多服务节点，但是却容易导致服务调用链冗长复杂，服务节点之间网络通信复杂度指数级增加，一处轻微网络故障就可能导致整个服务异常。
同时，考虑到硬件设备自身故障的可能性，所以分布式系统面临一个共同的问题：一个消息（任务）可能会被重复消费。因此，如何确保同一个消息单次消费和多次重复消费具有相同的效果，也就是消息的幂等性成为一个热点问题。
其他常见的分布式解决方案 1、数据库添加唯一索引，比如订单号是唯一索引，防止生产重复订单；
2、使用分布式锁，防止应用程序出现并发操作；
3、采用 Token 机制，有效防止重复提交。提交后台时带 Token 值，需要先判断 Token 是否存在，若是存在，则删除 Token，执行业务逻辑；
4、数据库通过乐观锁；(update table_name set version=version+1 where version=0)
5、数据库悲观锁，通常是通过主键或唯一索引和事务一起实现。
以上是其他常见的幂等解决方案，往往在不同的业务场景下会采用不同的方法。由于我们的主要业务是分布式存储，IO 从 Client 到 Server 的链路都不会很长，所以我们参考 Token 机制，实现了一套“新”机制来处理业务场景里存在的幂等问题。
不同状态的消息处理
文章图片

如图所示，这是一个简单的任务系统，Server 成功执行了 ① 发送来的命令，但是并没有收到对应的结果。这是因为有网络因素的存储遇到问题，Client 都需要去重试任务，以排除网络不稳定带来的影响，但是在不同情况下，Server 收到重试消息时，需要有不同的应对方案。这时，可能会出现以下三种情况：
第一种情况，Server 并没有收到对应的消息，因为有网络不稳定的情况存在，Client 是需要去重试的，这时 Server 会重新收到消息并且进行处理，正常处理之后返回对应的结果。
第二种情况，Server 收到了对应的消息，还正在处理，由于其他因素导致任务执行时间过长。这是因为任务仍然在执行，所以为了保证幂等，我们需要等之前的任务执行完成后，再获取其执行的结果返回给客户端。
【详解分布式系统的幂等】第三种情况，Server 收到了对应的消息，并且已经处理完成，但是网络因素导致 Client没有收到 ② 的结果，Server 收到重试的请求之后，直接获取已经收到结果返回给 Client。
为了做到上面的功能，我们需要有一套合理的机制来保存已经收到的消息状态，并且需要在能够判断消息已经被 Client 收到结果时清理这个状态，这里我们引入了 SeqNumber 来做到这些事情。
SeqNumber 的机制我们每次的请求都会带着一个之前已经完成的请求序号 ACK 和当前序号 Seq，Server 在处理时会根据 Seq 来判断当前消息的状态，保证一个 Seq 不会被执行多次。同时，会释放 ACK 对应的序号，因为只有在这个时候才能保证 Client 已经正确的完成了对应的请求。

文章图片

我们在 Client 端有两个队列 finished 和 running，分别存有正在执行的和已经完成的任务 ID。在 Server 端有一个 map，保存了所有未清理的消息（包括正在执行，执行完成）。我们一个请求有以下几个步骤：
1、生成一个未使用的 Seq，如图在 request 里生成了 12；
2、将这个 Seq 插入 running 队列；
3、从已经完成的 finished 队列获取最小的 Seq 作为 ACK，如图 ACK=1，到这里 Client 将准备好的消息发送给 Server；
4、Server 收到请求，首先会将 ACK 对应的请求的缓存释放掉，然后获取对应 Seq 的消息，如果没有就说明是新的消息，直接插入，否则根据 map 之中的状态做对应的处理（对应到上文中三种状态的处理方式）；
5、完成任务之后，返回结果给 Client，到这里 Server 已经完成了任务处理；
6、Client 收到了消息的结果，可以确认 Server 已经完成任务，这时候释放 finished 队列中 ACK=1 的项，然后将刚刚完成是 Seq=12 的任务移动到 finished 之中。
总结分布式系统是一个非常庞大且复杂的系统，幂等只是其中非常重要且复杂的问题，在分布式系统的构建中，不同的系统对于幂等有着不同的需求，希望这篇文章能够对大家有所帮助。

详解分布式系统的幂等

推荐阅读

什么是碱性岩

洛阳奥斯卡影院6月13号放映什么电影？洛阳奥斯卡影院今日放映表

京东“京银计划” 是什么怎么参与？

共栅极放大电路分析,场效应管共栅极放大电路

2022年三伏天时间表？

活珠子不适合哪些人吃

m当前“最接近完美”的五款手机，别看价格贵，用三年毫无压力

上海电商有哪些什么是电商上海，什么是电商上海人

家用茶具多少钱的合适 – 高档茶盘图片价格表

冰箱不结冰是怎么回事？原因分析与解决方法

热水器不烧水怎么办,是因为这些原因

增加注册资本后股东的股权比例

白发傅筹第几集知道身世

CPB水前肌底精华好不好？CPB水前肌底精华怎么用

兄弟T310如何清零废墨？

炒杜仲与生杜仲的区别炒杜仲与生杜仲的不同之处

《侠客风云传前传》激活方法及特权简单介绍

取暖器品牌排名？哪个比较好的？

中风|女性中风有奇特症状？盘点易被女性忽视的11个中风症状！

减肥可以吃红枣吗