如何处理消息队列消费过程当中的重复消息&如何实现幂等性

什么是幂等

幂等原本是数学上的概念，它的定义是这样的： 若是一个函数 f(x) 知足：f(f(x)) = f(x)，则函数 f(x) 知足幂等性。

在计算机领域用来描述一个操做、方法或者服务。一个幂等操做的特色是，其任意屡次执行所产生的影响均与一次执行的影响相同。

场景

将林志玲帐户的余额加 100 元

方法一：利用数据库的惟一约束实现幂等

咱们在数据库中建一张转帐流水表，这个表有三个字段：转帐单 ID、帐户 ID 和变动金额，而后给转帐单 ID 和帐户 ID 这两个字段联合起来建立一个惟一约束，这样对于相同的转帐单 ID 和帐户 ID，表里至多只能存在一条记录。

方法二：为更新的数据设置前置条件（将方法实现幂等）

1. 方法入参传入林志玲的帐户余额，拿参数中的余额与数据库中的余额作比较若是相同则执行变动操做。
2. 最简单的作法给数据增长一个版本号属性，每次更改数据前，比较当前数据的版本号是否和消息中的版本一致，若是不一致就拒绝更新数据，更新数据的同时将版本号+1。（和乐观锁原理同样）

方法三： 令牌机制 （记录并检查操做）

在发送消息时,给每条消息指定一个全局惟一的ID,消费时,先根据这个ID检查这条消息是否有被消费过,若是没有消费过更新数据,而后将消费状态置为已消费。 （先向服务器请求token，再拿着这个token请求服务器，服务器对比这个token是否存在存在正常调用，不存在忽略这个请求，调用成功删除服务器存储的这个token）

码字不易若是对你有帮助请给个关注

爱技术爱生活 QQ群: 894109590