什么是幂等：
贴一张百度百科的图：
简单来说幂等保证了只要调用接口成功,外部多次调用对系统的影响是一致的，也就是一个请求多次重试的问题。
需要考虑幂等的场景：
客户端存在多次提交或者超时重试的情况；
分布式架构中因网络波动采用重试机制，如Dubbo的重试机制；
消息推送重试，如MQ重试；
不幂等带来的影响：比如在支付场景下，消费者消费扣款消息，对一笔订单进行扣款操作，该扣款操作需要扣除100元，在不幂等的情况下，如果消费者多次发起请求，就会造成多次扣款。
幂等性问题解决方案
幂等问题演示：
执行如下SQL，初始化金额为100；
create table order_pay
(
id int default 0 not null
primary key,
amt decimal(9, 2) default 0.00 null comment '金额',
status int null comment '状态:0已完成/1处理中'
)comment '订单支付表';
INSERT INTO test.order_pak (id, amt, status) VALUES (1, 100.00, 0);
复制代码
pay接口:
@RestController
@RequestMapping("/test/order-pay")
public class OrderPayController {
@Autowired
IOrderPayService orderPayService;
@ApiOperation(httpMethod = "POST", value = "幂等性测试")
@PostMapping("pay")
public Resp pay(@RequestBody Req req) {
PayReq payReq = req.getData();
OrderPay order = orderPayService.getOne(new LambdaQueryWrapper().eq(OrderPay::getId, payReq.getBizId()));
order.setAmt(order.getAmt().subtract(payReq.getAmt()));
orderPayService.updateById(order);
return Resp.success("剩余金额更新为"+order.getAmt());
}
}
复制代码
在不控制幂等的情况下，对pay接口连续发起5次请求，每一次扣减金额为10.00：
可以看到最后剩余金额更新为50 .00，我们发起一次请求，应该只扣除10.00，当遇到网络重复或系统bug在不控制幂等的情况下会导致系统进行了多次扣款。那如何进行幂等控制呢？有什么方法呢？
幂等性的实现
保证幂等性的措施包括但不限于：
1、表单提交后按钮置灰
限制客户端请求
2、添加唯一索引
把唯一标识作为唯一索引，在重复创建时会抛出唯一约束异常
3、全局唯一ID
针对业务操作和内容生产全局唯一ID，在执行操作时判断ID是否存在来判断是否已执行
4、一锁二查三更新
如果在流程处理过程中，业务要求不能并发执行，可以在流程执行之前根据业务ID获取锁，其他流程执行时获取锁就会失败，也就是同一时间该流程只能有一个能执行成功，执行完成后，释放锁，同时也需要在入口处增加业务状态的判断，以避免对请求的多次处理。这种方式不止可用于幂等的控制，也可以防止并发操作带来的异常。
@ApiOperation(httpMethod = "POST", value = "幂等性测试")
@PostMapping("pay")
public Resp pay(@RequestBody Req req) throws Exception {
PayReq payReq = req.getData();
// 获取分布式锁
redisTools.lock(payReq.getBizId().toString());
OrderPay order = orderPayService.getOne(new LambdaQueryWrapper().eq(OrderPay::getId, payReq.getBizId()));
if (order.getStatus()==1){
order.setAmt(order.getAmt().subtract(payReq.getAmt()));
order.setStatus(0);
orderPayService.updateById(order);
}
// 释防锁
redisTools.unlock(payReq.getBizId().toString());
return Resp.success("剩余金额为"+order.getAmt());
}
复制代码
以下是对pay接口进行并发请求5次的结果：
可以看到，只有1个请求可以请求成功，另外4个请求在 redisTools.lock(payReq.getBizId().toString())获取分布式锁的步骤中抛出异常。
不加锁与加锁的区别
如果把分布式锁的步骤去掉会发生什么样的情况呢？
@ApiOperation(httpMethod = "POST", value = "幂等性测试")
@PostMapping("pay")
public Resp pay(@RequestBody Req req) throws Exception {
PayReq payReq = req.getData();
OrderPay order = orderPayService.getOne(new LambdaQueryWrapper().eq(OrderPay::getId, payReq.getBizId()));
if (order.getStatus()==1){
order.setAmt(order.getAmt().subtract(payReq.getAmt()));
order.setStatus(0);
orderPayService.updateById(order);
}
return Resp.success("剩余金额为"+order.getAmt());
}
复制代码
依旧对pay接口进行并发请求5次，查看日志：
5次请求都成功了，但是逻辑执行了5遍，在复杂的业务流程下可能会引发其他不必要问题。
总结：
在系统设计中，实现幂等的方案有很多种，要根据自身系统的特性优先选择小而巧方案，避免形成过于复杂的方案。
