阿里、蚂蚁金服面试--幂等性实现

悠悠 2022-09-02 01:16 131阅读 0赞

### 文章目录 ###

*  前言
 *  参考文章
 *  MQ方案
 *   *  相关思想
 *  DB方案
 *  redis方案

# 前言 #

由于之前没有总结完整，导致在面试的时候老是有卡壳，比如说最近微众银行的二面，如果通过数据库来实现幂等性

# 参考文章 #

*  [阿里经典面试题：消息队列的消费幂等性如何保证？][Link 1]

# MQ方案 #

在服务端的时候是at lease one，就是会多次发送保证说在网络问题或者客户端宕机等等情况下，可以进行多次发送，保证客户端能接收到。那么这时就需要去重。  
**去重**  
主要通过messageId进行相应的去重

## 相关思想 ##

就是有消息状态表，还有对应的标识，可以是messageId或者业务id，去重过程是去查询是否已经消费这条消息，当然如果客户端代码有问题，那么会进行消息重试机制。

# DB方案 #

可以参照mq的方案，下面是几种情况

1.  就是会有个消息表，以业务id来构建唯一键，然后插入成功，就执行业务，然后标识消息执行完成的状态。
2.  插入消息成功，但是业务失败的话，会改成失败的标识，方便后续重试。
3.  插入消息成功，宕机了，那么这里像文章里面讲的，消息表需要一个过期的时间，也就是那些正在执行的消息，过了某个过期时间还没修改状态，那么需要剔除。
4.  插入消息失败，证明重复消费，剔除即可

其他简单的像：查询的时候用for update，其他就修改不了这条数据。进行相应的修改等等

# redis方案 #

只需要实现分布式锁，以业务id为key，然后先查询有没有对应的数据，没有再插入，然后释放锁。  
这时像那些重发很快的请求，肯定是没有拿到锁的，直接剔除。  
如果说业务执行完，因为种种原因导致又重发，可以在查询对应数据的步骤，将请求剔除。  
比如说订单id为1，用户A给商家b付款，这时肯定有相应的支付流水，可以根据这个去作为判断。

[Link 1]: https://mp.weixin.qq.com/s?__biz=MzU3MjQ1ODcwNQ==&mid=2247488225&idx=1&sn=ee91e9be2b7e7a2dee8ac1b603f39e5e&chksm=fcd1c15fcba64849e3576c29b7ae61bf52d7712ef848a7dc65f2d1ccb0e0b54af33fd5ad520e&mpshare=1&scene=24&srcid=07288yvvVcQZteQIrYsVE9Tz&sharer_sharetime=1627470559994&sharer_shareid=cded50ac01d784d35c8ca2a1912ee86e#rd