接口幂等性这一概念源于数学，原意是指一个操作如果连续执行多次所产生的结果与仅执行一次的效果相同，那么我们就称这个操作是幂等的。在互联网领域，特别是在Web服务、API设计和分布式系统中，接口幂等性具有非常重要的意义。
具体到HTTP接口或者服务间的API调用，接口幂等性就可以理解为当客户端对同一接口发起多次相同的请求时，服务端系统也应该确保只执行一次相应的操作，并且不论接收到了多少次请求，系统的状态变更始终是一致的，不会因为重复的请求而导致数据的错误。
比如我们常常遇到的订单创建，支付等业务。
要向杜绝幂等性，那么我们就要之道导致接口幂等性问题的原因有哪些。接口幂等性问题通常由以下多种原因引起：
总的来说，导致接口幂等性问题可以粗略的归类于两种情况：前端调用以及服务端调用，那么我们可以针对这两种情况看一下如何去保证接口幂等。
页面调用接口时可以通过禁用（如按钮置灰或显示加载状态）防止用户在请求未完成前重复点击，从而减少不必要的重复请求和可能的数据冲突。虽然在前端进行按钮置灰等操作可以辅助提高系统的幂等性表现，但是这个方式只是从用户体验和用户行为控制的角度来避免重复提交的一种方法，并没有从系统设计层面完全解决接口本身的幂等性问题。
PRG（POST/Redirect/GET）模式是一种前端交互策略，旨在解决用户刷新页面时可能导致表单数据重复提交的问题。它巧妙地利用了HTTP协议的特性，具体的交互流程如下：
Token机制是一种广泛应用互联网领域的认证与授权方法，特别是Web服务系统。token可以理解为一种安全凭证，它是由服务端生成并颁发给客户端的一段经过加密处理的字符串或数据结构，用来代表用户的某种状态或权限。
通过Token机制，我们可以解决接口幂等性问题。在接口中，我们允许重复提交，但是要保证重复提交不产生副作用，比如点击n次只产生一条记录，客户端每次请求都需要携带一个唯一的Token，而服务器则验证这个Token的有效性。如果服务器收到了一个已经使用过的Token就会认为这是一个重复请求并拒绝处理，从而确保接口的幂等性具体流握如下Token机制是一种常用的方法，用于确保接口的幂等性和防止重复请求。具体流程如下：
图片
在服务端接口处理逻辑时，可以通过通过一些特定的标识符或请求参数来校验请求的幂等性，以确保同样的请求不会被重复处理。
客户端每次发起请求会携带一个全局唯一的标识符。服务器接收到请求后就会对这个标识符进行检查，若服务器发现该标识符已经在系统中存在，表明这是一个重复请求，此时服务器可以选择忽略该请求，或者向客户端返回已处理过相同请求的结果信息。若服务器未找到该标识符存在于系统内，则认定该请求为新请求，服务器将继续对其进行正常处理，并将此唯一标识符保存至系统中，以便于后续对接收的请求进行有效性校验，防止同一请求的重复处理。比如我们在要求上游ERP系统对接订单平台时就会要求上游传递一个账号下全局唯一的一个参考单号，这个参考单号一个很重要的作用就是保证接口幂等性。
某些请求参数确实可以用来辅助校验请求的幂等性。例如，时间戳可以作为一种可能的请求参数，在处理请求时，服务器可以通过比较时间戳与服务器当前时间来判断请求的有效性。若时间戳与当前时间之间的差异超出预设的合理范围（如几秒钟到几分钟不等，具体阈值视业务场景而定），服务器可以推测该请求可能是由于网络延迟或者其他原因导致的重复提交。
单纯依靠时间戳来判断幂等性和重复请求并不完全准确，因为不同的客户端时间可能并不精确同步，而且时间戳本身无法保证全局唯一性。但是它可以作为一种有效的辅助手段来减少重复处理的可能性。
对于状态转移类的操作类型的业务，可采用状态机设计，每次请求只允许合法的状态变迁，非法状态变迁（如已经完成的订单不允许再次支付）将被拒绝。
在更新数据时，可以通过版本号或时间戳等机制判断数据是否已被修改，防止因并发请求导致的多次更新问题。具体做法：
如果一致，说明在这期间数据没有被其他事务修改过，于是更新数据并递增版本号或更新时间戳。
如果不一致，说明数据已经被修改过，此时服务器拒绝本次更新请求，返回错误提示，客户端可以根据错误信息决定是否重新获取最新数据再尝试更新。
通过这种方式，即使客户端因为网络原因或其他因素导致同一请求被多次发送，乐观锁机制能确保只有在数据未被其他事务修改的前提下，才会执行更新操作，从而达到接口幂等的效果。
从上述的几种解决幂等性问题的方案来看，使用token机制可以保证在不同请求动作下的幂等性。所以我们以此作为方案作为示例方案。
我们使用Redis保存Token令牌，引入SpringBoot，Redis，ULID相关的依赖。
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <version>2.7.0</version></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <version>2.7.0</version></dependency><dependency> <groupId>com.github.f4b6a3</groupId> <artifactId>ulid-creator</artifactId> <version>5.2.0</version></dependency>Redis相关的配置：
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使用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令牌 */@Overridepublic 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;}这里我们使用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<Long> 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 生成的订单号 */@Overridepublic 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中统一异常处理，统一结果响应，请查看：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个请求并发操作。
图片
执行结果如下：
图片
控制台打印日志如下：
图片
可以看见只有1个请求成功了，并且控制台中打印只有一个token校验成功。
幂等性是开发当中很常见也很重要的一个需求，尤其是订单，支付以及与金钱挂钩的服务，保证接口幂等性尤其重要。在实际开发中，我们需要针对不同的业务场景我们需要灵活的选择幂等性的实现方式：
最后强调一下，实现幂等性需要先理解自身业务需求，根据业务逻辑来实现这样才合理，处理好其中的每一个结点细节，完善整体的业务流程设计，才能更好的保证系统的正常运行。
本文链接：http://www.28at.com/showinfo-26-76559-0.html我们一起聊聊如何保证接口幂等性？高并发下的接口幂等性如何实现？
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号
