巴彦淖尔网站建设分销平台
啥是幂等？
客户端对同一API的多次调用应该产生相同的服务器状态。
通俗的说：某个行为重复的执行，最终获取的结果是相同的，不会因为重复执行对系统造成变化。
比如说同步数据的功能，重复可以重复同步，如果可以就表示是幂等的。
常见场景
HTTP方法：
幂等方法：GET、PUT、DELETE
非幂等方法：POST、PATCH
支付系统：重复支付请求不应导致多次扣款
订单创建：重复提交订单不应创建多个相同订单
实现幂等性的方法
唯一标识符：为每个操作分配唯一ID，服务器记录已处理ID
版本号/时间戳：资源更新时携带版本信息
状态机：确保操作只在特定状态下执行
数据库约束：利用唯一索引防止重复数据
具体
1 update + where，利用数据库的行级锁保证查询和更新是原子性的。伪代码如下。
String rechargeId = "充值订单id";// 根据rechargeId去找充值记录，如果已处理过，则直接返回成功
RechargePO rechargePo = select * from t_recharge where id = #{rechargeId};// 充值记录已处理过，直接返回成功
if(rechargePo.status==1){return "SUCCESS";
}开启Spring事务// 下面这个sql是重点，重点在where后面要加 status = 0 这个条件；count表示影响行数
int count = (update t_recharge set status = 1 where id = #{rechargeId} and status = 0);// count = 1，表示上面sql执行成功
if(count!=1){// 走到这里，说明有并发，直接抛出异常throw new RuntimeException("系统繁忙，请重试")
}else{//给账户加钱update t_account set balance = balance + #{rechargePo.price} where id = #{rechargePo.accountId}
}提交Spring事务
2 基于版本号的乐观锁
String rechargeId = "充值订单id";// 根据rechargeId去找充值记录，如果已处理过，则直接返回成功
RechargePO rechargePo = select * from t_recharge where id = #{rechargeId};// 充值记录已处理过，直接返回成功
if(rechargePo.status==1){return "SUCCESS";
}开启Spring事务// 期望的版本号
Long exceptVersion = rechargePo.version;// 下面这个sql是重点，重点在set后面要有version = version + 1，where后面要加 status = 0 这个条件；count表示影响行数
int count = (update t_recharge set status = 1,version = version + 1 where id = #{rechargeId} and version = #{exceptVersion});// count = 1，表示上面sql执行成功
if(count!=1){// 走到这里，说明有并发，直接抛出异常throw new RuntimeException("系统繁忙，请重试")
}else{//给账户加钱update t_account set balance = balance + #{rechargePo.price} where id = #{rechargePo.accountId}
}提交spring事务
3 关联一个唯一约束辅助表
-- 幂等辅助表
create table if not exists t_idempotent
(id varchar(50) primary key comment 'id，主键',idempotent_key varchar(200) not null comment '需要确保幂等的key',unique key uq_idempotent_key (idempotent_key)
) comment '幂等辅助表';
重点关注第二个字段idempotent_key，这个字段添加了唯一约束，说明同时向这个表中插入同样值的idempotent_key，则只有一条记录会执行成功，其他的请求会报异常，而失败，让事务回滚。
String rechargeId = "充值订单id";// 根据rechargeId去找充值记录，如果已处理过，则直接返回成功
RechargePO rechargePo = select * from t_recharge where id = #{rechargeId};// 充值记录已处理过，直接返回成功
if(rechargePo.status==1){return "SUCCESS";
}// 生成idempotentKey，这里可以使用，业务id:业务类型，那么我们这里可以使用rechargeId+":"+"RECHARGE_CALLBACK"
String idempotentKey = rechargeId+":"+"RECHARGE_CALLBACK";// 幂等表是否存在记录，如果存在说明处理过，直接返回成功
IdempotentPO idempotentPO = select * from t_idempotent where idempotent_key = #{idempotentKey};
if(idempotentPO!=null){return "SUCCESS";
}开启Spring事务(这里千万不要漏掉，一定要有事务)// count表示影响行数，这个sql比较特别，看起来并发会出现问题，实际上配合唯一约束辅助表，就不会有问题了
int count = update t_recharge set status = 1 where id = #{rechargeId};// count != 1，表示未成功
if(count!=1){// 走到这里，直接抛出异常，让事务回滚throw new RuntimeException("系统繁忙，请重试")
}else{//给账户加钱update t_account set balance = balance + #{rechargePo.price} where id = #{rechargePo.accountId}
}String idempotentId = "";
// 这里是关键一步，向 t_recharge 插入记录，如果有并发过来，只会有一个成功，其他的会报异常导致事务回滚，上面的
insert into t_recharge (id, idempotent_key) values (#{idempotentId}, #{idempotentKey});提交spring事务