什么是接口幂等性
接口幂等性这一概念源于数学,原意是指一个操纵如果连续实行多次所产生的结果与仅实行一次的效果相同,那么我们就称这个操纵是幂等的。在互联网范畴,特别是在Web服务、API筹划和分布式系统中,接口幂等性具有非常重要的意义。
具体到HTTP接口或者服务间的API调用,接口幂等性就可以理解为当客户端对同一接口发起多次相同的请求时,服务端系统也应该确保只实行一次相应的操纵,并且不论接收到了多少次请求,系统的状态变更始终是一致的,不会由于重复的请求而导致数据的错误。
好比我们经常遇到的订单创建,支付等业务。
如果一个“创建订单”接口实现了幂等性,当收到两次同样的创建请求时,系统应该要么拒绝第二个请求(由于它已经是重复请求),要么确保只有一个订单被创建,而不是两个完全一样的订单。
对于一个“支付”接口,幂等性要求即便用户由于网络原因反复点击支付按钮,服务端也只会扣除用户账户一次金额,克制重复扣费。
导致接口幂等性问题的原因
要向杜绝幂等性,那么我们就要之道导致接口幂等性问题的原因有哪些。接口幂等性问题通常由以下多种原因引起:
网络波动不稳定:
网络通信中的丢包、延迟等情况大概导致客户端未收到服务端的相应或服务端未收到客户端的请求,此时客户端大概会重试发送请求,导致接口被重复调用。
用户操纵:
用户快速重复点击导致,例如用户在等待相应时,由于不确定是否操纵乐成,大概会多次点击提交按钮,进而发送多次相同的请求。再好比页用户频繁刷新页面,尤其是在某些提交操纵尚未完成时,刷新页面大概会重新发送请求。还有用户大概在浏览器上点击回退然后再重复之间的提交操纵,这都大概会导致重新发送请求。
重试机制:
在高可用性筹划中,客户端经常设置有重试机制,当请求失败或超时时会主动重新发起请求。而在分布式系统中,服务间调用也大概有重试策略,以应对临时故障。好比Nginx重试,RPC重试,或者调用方业务层中进行重试。
定时使命或异步处理:
在定时使命中如果定时使命调度或逻辑筹划不当,大概会导致同一使命被实行多次。或者在消息队列中,消息大概会由于异常等原因被重复消费。
并发控制:
缺乏有用的并发控制手段,导致在并发情况下,针对同一资源的操纵被多次实行。
总的来说,导致接口幂等性问题可以大略的归类于两种情况:前端调用以及服务端调用,那么我们可以针对这两种情况看一下怎样去保证接口幂等。
怎样保证接口幂等?
前端调用
页面控制
页面调用接口时可以通过禁用(如按钮置灰或显示加载状态)防止用户在请求未完成前重复点击,从而减少不必要的重复请求和大概的数据冲突。虽然在前端进行按钮置灰等操纵可以辅助进步系统的幂等性表现,但是这个方式只是从用户体验和用户行为控制的角度来克制重复提交的一种方法,并没有从系统筹划层面完全办理接口本身的幂等性问题。
利用RPG模式
PRG(POST/Redirect/GET)模式是一种前端交互策略,旨在办理用户刷新页面时大概导致表单数据重复提交的问题。它奇妙地利用了HTTP协议的特性,具体的交互流程如下:
用户在网页表单中填写数据,并通过POST请求将其发送至服务器进行处理,例如创建新资源或更新现有数据。
服务器接收到POST请求后,对提交的数据进行有用处理和持久化存储,并在操纵乐成后不直接返回处理结果,而是通过HTTP相应码302或303实现重定向,指示客户端发起一个新的GET请求去访问一个特定的URL。
客户端依照服务器的重定向指示,主动发送GET请求访问新的URL,此时返回的页面将展示之前POST操纵处理完毕的结果。
当用户在此后刷新页面时,浏览器只会按照常规方式重新发起GET请求,而非重新提交POST数据,因此有用地克制了重复提交引发的潜伏问题
Token机制
Token机制是一种广泛应用互联网范畴的认证与授权方法,特别是Web服务系统。token可以理解为一种安全凭据,它是由服务端天生并颁发给客户端的一段经过加密处理的字符串或数据结构,用来代表用户的某种状态或权限。
通过Token机制,我们可以办理接口幂等性问题。在接口中,我们允许重复提交,但是要保证重复提交不产生副作用,好比点击n次只产生一条记录,客户端每次请求都需要携带一个唯一的Token,而服务器则验证这个Token的有用性。如果服务器收到了一个已经利用过的Token就会以为这是一个重复请求并拒绝处理,从而确保接口的幂等性具体流握如下Token机制是一种常用的方法,用于确保接口的幂等性和防止重复请求。具体流程如下:
天生Token
当用户开始实行一个需要确保幂等性的操纵(如支付、下单、更新用户信息等)时,服务端会天生一个唯一的、有时效性的token。这个token可以是一个随机字符串或者带有时间戳和其他干系信息的哈希值,确保其唯一性。
存储Token
天生的token会被存储在服务端的一个临时存储介质中,如Redis、Memcached或数据库,同时设置一个公道的逾期时间(例如15分钟)。
传递Token
将天生的token返回给客户端,客户端在进行后续的API调用时,需将此token作为请求参数或放在请求头中一并发送给服务端。
验证Token
服务端在接收到带有token的请求时,首先检查token是否存在并且有用(未逾期且未被利用过)。如果token有用且未被利用,则实行相应的业务逻辑,并在实行完成后立即从存储介质中移除或标记为已利用。若token已失效或已被利用,则拒绝此次请求,返回相应的错误提示,确保同一个操纵不会被实行两次。
限定并发
在并发场景下,通过原子操纵(如Redis的SETNX命令)确保在验证token有用的同时,将其删除或更新状态,克制多个请求同时通过验证。
image.png
image.png
服务端控制
在服务端接口处理逻辑时,可以通过通过一些特定的标识符或请求参数来校验请求的幂等性,以确保同样的请求不会被重复处理。
唯一标识符
客户端每次发起请求会携带一个全局唯一的标识符。服务器接收到请求后就会对这个标识符进行检查,若服务器发现该标识符已经在系统中存在,表明这是一个重复请求,此时服务器可以选择忽略该请求,或者向客户端返回已处理过相同请求的结果信息。若服务器未找到该标识符存在于系统内,则认定该请求为新请求,服务器将继续对其进行正常处理,并将此唯一标识符生存至系统中,以便于后续对接收的请求进行有用性校验,防止同一请求的重复处理。好比我们在要求上游ERP系统对接订单平台时就会要求上游传递一个账号下全局唯一的一个参考单号,这个参考单号一个很重要的作用就是保证接口幂等性。
请求参数
某些请求参数确实可以用来辅助校验请求的幂等性。例如,时间戳可以作为一种大概的请求参数,在处理请求时,服务器可以通过比较时间戳与服务器当前时间来判定请求的有用性。若时间戳与当前时间之间的差别超出预设的公道范围(如几秒钟到几分钟不等,具体阈值视业务场景而定),服务器可以推测该请求大概是由于网络延迟或者其他原因导致的重复提交。
单纯依赖时间戳来判定幂等性和重复请求并不完全准确,由于差别的客户端时间大概并不精确同步,而且时间戳本身无法保证全局唯一性。但是它可以作为一种有用的辅助手段来减少重复处理的大概性
状态机筹划
对于状态转移类的操纵范例的业务,可接纳状态机筹划,每次请求只允许合法的状态变迁,非法状态变迁(如已经完成的订单不允许再次支付)将被拒绝。
乐观锁
在更新数据时,可以通过版本号或时间戳等机制判定数据是否已被修改,防止因并发请求导致的多次更新问题。具体做法:
在数据库表中增长一个版本号字段(version)或者时间戳字段(timestamp)。
客户端第一次请求时获取数据的版本号或时间戳。
客户端发起更新操纵时,将上次读取的版本号或时间戳一起发送回服务器。
服务器在实行更新操纵前,首先检查当前数据库中的版本号或时间戳是否与客户端提交的一致。
如果一致,说明在这期间数据没有被其他事务修改过,于是更新数据并递增版本号或更新时间戳。
如果不一致,说明数据已经被修改过,此时服务器拒绝本次更新请求,返回错误提示,客户端可以根据错误信息决定是否重新获取最新数据再尝试更新。
通过这种方式,即使客户端由于网络原因或其他因素导致同一请求被多次发送,乐观锁机制能确保只有在数据未被其他事务修改的前提下,才会实行更新操纵,从而到达接口幂等的效果。
实现幂等性方案示例
从上述的几种办理幂等性问题的方案来看,利用token机制可以保证在差别请求动作下的幂等性。所以我们以此作为方案作为示例方案。
预备工作
我们利用Redis生存Token令牌,引入SpringBoot,Redis,ULID干系的依赖
org.springframework.boot spring-boot-starter-data-redis 2.7.0 org.springframework.boot spring-boot-starter-web 2.7.0 com.github.f4b6a3 ulid-creator 5.2.0Redis干系的配置spring.redis.database=0
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.timeout=60
server.port=8080
server.servlet.context-path=/coderacademy
天生Token令牌
利用ULID天生随机字符串,然后将其生存在Redis当中。这里以idempotent_token+账户+请求操纵范例+token作为key。
private StringRedisTemplate stringRedisTemplate;
/**
- 存入 Redis 的 Token 键的前缀
*/
private static final String IDEMPOTENT_TOKEN_PREFIX = "idempotent_token:%s s:%s";
/**
- 天生token令牌
- @param accountSecret 账户令牌
- @param operatorType 接口请求范例,可以是接口url或者其他可以区分接口服务范例的值
- @return token令牌
*/
@Override
public String generateToken(String accountSecret, String operatorType) {
// 创建或获取ULID天生器实例
long timestampInMillis = LocalDateTime.now().atZone(ZoneOffset.systemDefault()).toInstant().toEpochMilli();
Ulid ulid = UlidCreator.getUlid(timestampInMillis);
String token = ulid.toString();
// 设置存入 Redis 的 Key
String key = String.format(IDEMPOTENT_TOKEN_PREFIX, accountSecret, operatorType, token);
// 存储 Token 到 Redis,且设置逾期时间为5分钟
stringRedisTemplate.opsForValue().set(key, accountSecret, 5, TimeUnit.MINUTES);
// 返回 Token
return token;
}
校验Token令牌
这里我们利用Redis实行Lua命令去查找以及删除key,Lua 表达式能保证命令实行的原子性。
/**
* 验证 Token 正确性
*
* @param token token 字符串
* @param operatorType 接口请求范例,可以是接口url或者其他可以区分接口服务范例的值
* @return 验证结果
*/
private boolean validToken(String token, String accountSecret, String operatorType) {
// 设置 Lua 脚本,其中 KEYS[1] 是 key,KEYS[2] 是 value
String script = "if redis.call('get', KEYS[1]) == KEYS[2] then return redis.call('del', KEYS[1]) else return 0 end";
RedisScript redisScript = new DefaultRedisScript(script, Long.class);
// 根据 Key 前缀拼接 Key
String key = String.format(IDEMPOTENT_TOKEN_PREFIX, accountSecret, operatorType, token);
// 实行 Lua 脚本
Long result = stringRedisTemplate.execute(redisScript, Arrays.asList(key, operatorType));
// 根据返回结果判定是否乐成乐成匹配并删除 Redis 键值对,若果结果不为空和0,则验证通过
if (result != null && result != 0L) {
System.out.println(String.format("验证 token=%s,key=%s,value=%s 乐成", token, key, operatorType));
return true;
}
System.err.println(String.format("验证 token=%s,key=%s,value=%s 失败", token, key, operatorType));
return false;
}
业务代码以及接口
我们在实现模拟创建订单的服务,在创建订单之前,首先校验token令牌。
/**
- 创建订单接口
- @param requestVO 创建订单参数
- @param accountSecret 账户令牌
- @param token token令牌
- @return 天生的订单号
*/
@Override
public String createOrder(OrderCreateRequestVO requestVO, String accountSecret, String token) {
// 根据 Token 和与用户干系的信息到 Redis 验证是否存在对应的信息
boolean result = validToken(token, accountSecret, "createOrder");
if (!result){
// 这里需要自界说异常,同一处理异常,再同一相应返回
throw new RuntimeException("重复的请求");
}
// 根据验证结果相应差别信息
return "Success";
}
校验如果不存在token,则说明请求时重复请求,直接抛出异常,由同一异常管理,直接返回客户端请求失败的错误信息。关于SpringBoot中同一异常处理,同一结果相应,请查看:
我们在界说获取Token令牌的接口,以及创建订单的接口
@RestController
@RequestMapping("order")
public class OrderController {- private IOrderService orderService;
- /**
- * 获取token接口
- * @param secret 账户令牌
- * @return
- */
- @GetMapping("getToken")
- public String getToken(@RequestHeader("secret") String secret){
- return orderService.generateToken(secret, "createOrder");
- }
- /**
- * 创建订单接口
- * @param requestVO 参数
- * @param token token令牌
- * @param secret 账户令牌
- * @return 响应信息
- */
- @PostMapping("create")
- public OrderCreateResponseVO createOrder(@RequestBody OrderCreateRequestVO requestVO,
- @RequestHeader("token") String token,
- @RequestHeader("secret") String secret){
- OrderCreateResponseVO responseVO = new OrderCreateResponseVO();
- String result = orderService.createOrder(requestVO, secret, token);
- responseVO.setSuccess(Boolean.TRUE);
- responseVO.setMsg(result);
- return responseVO;
- }
- @Autowired
- public void setOrderService(IOrderService orderService) {
- this.orderService = orderService;
- }
复制代码 }
我们利用Apifox模拟3个请求并发操纵
image.png
image.png
实行结果如下:
image.png
image.png
控制台打印日记如下
image.png
image.png
可以看见只有1个请求乐成了,并且控制台中打印只有一个token校验乐成。
总结
幂等性是开发当中很常见也很重要的一个需求,尤其是订单,支付以及与金钱挂钩的服务,保证接口幂等性尤其重要。在现实开发中,我们需要针对差别的业务场景我们需要灵活的选择幂等性的实现方式:
如果是web服务,客户端可以采取在页面上利用按钮置灰禁用,利用PRG模式,或者搭配后端的Token令牌进行办理。
在服务端,我们可以采取唯一标识符,乐观锁,Token令牌,状态机等校验方式。
最后强调一下,实现幂等性需要先理解自身业务需求,根据业务逻辑来实现这样才公道,处理好其中的每一个结点细节,美满团体的业务流程筹划,才能更好的保证系统的正常运行。
本文已收录于我的个人博客:码农Academy的博客,专注分享Java技术干货,包括Java基础、Spring Boot、Spring Cloud、Mysql、Redis、Elasticsearch、中间件、架构筹划、面试题、程序员攻略等
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |