接口幂等性详解

news2024/11/26 2:35:41

1. 什么是幂等性

幂等性指的是对同一个操作的多次执行所产生的影响与一次执行的影响相同。无论操作执行多少次，系统状态都应该保持一致。

在计算机科学和网络领域中，幂等性通常用来描述服务或操作的特性。对于RESTful API或HTTP方法，一个幂等操作的特点是：对于相同的输入，在多次执行之后，得到的结果是一致的。

例如，HTTP中的GET请求是幂等的，无论请求多少次，结果都是相同的。而POST请求则不一定是幂等的，因为每次执行时，可能会创建新的资源或状态，从而改变系统状态。

在处理分布式系统和网络通信时，保证操作的幂等性是非常重要的。因为网络中的请求可能因为重试、超时、丢包等原因被多次发送，而服务端必须能够正确处理这些重复的请求，而不会因为重复执行导致系统状态异常或资源多次创建等问题。

确保API的幂等性是设计和开发高质量、健壮系统的一个关键因素，可以减少因为重复操作导致的副作用，保障系统的可靠性和稳定性。

2. 什么是接口幂等性

接口幂等性是指针对同一个操作，无论执行多少次，系统的状态都保持一致。在Web开发中，特别是对于RESTful API，接口的幂等性是一种非常重要的性质。

一个幂等操作满足以下条件：

  1. 多次执行相同操作，产生的效果与执行一次相同操作的效果相同。
  2. 重复执行相同请求的结果与第一次执行该请求的结果相同。

这意味着无论对一个接口发送多少次相同的请求，系统都保持一致的状态，不会因为重复请求而导致状态的变化或资源的重复创建。在幂等性的设计中，服务端需要保证接收到重复请求时，不会因为重复执行操作而引起问题。

幂等性的设计对于解决由于网络延迟、超时、重试、系统问题等导致重复请求的情况非常重要。例如，对于一次性支付的操作，幂等性保证了即使用户在网络不稳定时多次点击支付按钮，系统也只会执行一次支付操作，避免重复扣款。

在RESTful API中，GET请求通常是幂等的，因为它只是获取资源而不会对资源状态做出改变；而POST请求一般不是幂等的，因为每次执行可能会创建新资源或改变系统状态。

确保接口的幂等性对于系统的正确性、可靠性和稳定性至关重要。
在这里插入图片描述

3. 如果忽略接口幂等性设计会出现哪些问题

忽略接口的幂等性设计可能导致以下问题：

  1. 重复操作导致资源状态异常： 如果接口不具有幂等性，重复执行同一个请求可能会导致资源状态的不一致或异常，例如多次创建相同的订单、重复扣款等。

  2. 重复创建资源： 对于非幂等的操作，可能会导致多次执行请求创建重复的资源，例如多次支付，每次请求都会创建新的支付记录。

  3. 系统副作用： 非幂等操作可能会对系统状态造成非预期的副作用，例如多次发送邮件、多次触发同一个事件，导致系统状态不一致。

  4. 用户体验下降： 如果接口不是幂等的，用户在网络波动或系统问题下多次发送相同请求时，可能会产生用户体验问题，例如重复下单、重复支付等。

  5. 系统负载增加： 重复请求可能导致系统负载增加，对服务器和数据库等资源产生不必要的压力，可能导致系统性能下降或宕机。

综上所述，忽略接口的幂等性设计可能导致系统状态不一致、资源重复创建、用户体验问题和系统负载增加等诸多问题，对系统的正确性和稳定性造成威胁。因此，确保接口的幂等性是设计和开发过程中的重要考虑因素。

4. 如何设计接口幂等性

4.1 使用Token+Redis

使用Token和Redis实现接口的幂等性通常涉及以下步骤：

  1. 生成并传递 Token：
    前端生成 Token： 在发送请求之前，前端生成一个唯一的 Token，通常是一个随机生成的字符串，比如 UUID，并将这个Token以客户ID为主键，以Token为值放入Redis
    Token 传递： 将 Token 放置于请求的 Header 或 Body 中。
  2. 服务端处理 Token：
    服务端接收 Token： 接收到请求后，服务端从请求中提取 Token。
  3. 验证 Token：
    检查 Token 是否存在于 Redis 中： 使用 Redis 数据库验证该 Token 是否已存在于数据库中。
  4. 保证幂等性：
    Token 存在： 如果 Token 已存在于 Redis 中，表示该请求已被处理过，服务端直接返回已存储的结果，不执行重复操作。（或者处理业务，并删除Token）
    Token 不存在： 如果 Token 不存在于 Redis 中，表示这是一个新的请求，服务端执行相应的业务逻辑，并将 Token 存储到 Redis，以防止重复请求。（或者直接返回）
    在这里插入图片描述示例伪代码：
    以下是一个简单的伪代码示例，演示了如何使用 Token+Redis 来确保接口的幂等性：
import redis.clients.jedis.Jedis;

public class IdempotentAPIHandler {
    private Jedis jedis;

    public IdempotentAPIHandler() {
        this.jedis = new Jedis("localhost", 6379); // 连接 Redis
    }

    public String processRequest(String token, String requestData) {
        if (checkTokenInRedis(token)) {
            // Token 存在，直接返回已存储的处理结果
            return jedis.get(token);
        } else {
            // Token 不存在，处理请求并将结果存储到 Redis
            String result = processRequestData(requestData); // 处理请求数据，获取结果
            jedis.set(token, result, "NX", "EX", 3600); // 设置 Token 并存储结果，设置过期时间为 1 小时
            return result;
        }
    }

    public boolean checkTokenInRedis(String token) {
        return jedis.exists(token); // 检查 Token 是否存在于 Redis
    }

    public String processRequestData(String requestData) {
        // 处理请求数据，返回处理结果
        return "Processed data: " + requestData;
    }

    public String generateToken() {
        // 生成 Token，通常是一个唯一的字符串
        return "generated_token"; // 这里可以使用 UUID.randomUUID().toString() 等生成唯一标识
    }

    public static void main(String[] args) {
        IdempotentAPIHandler handler = new IdempotentAPIHandler();
        String token = handler.generateToken(); // 生成 Token

        // 模拟处理 API 请求
        String requestData = "some_data";
        String result = handler.processRequest(token, requestData);
        System.out.println("Result: " + result);
    }
}

以上伪代码演示了如何在Java中使用 Token+Redis 实现接口的幂等性。在实际应用中，你需要根据具体的业务需求和框架，对这个示例进行适当调整。

4.2 使用数据库唯一索引

使用数据库唯一索引来实现接口的幂等性是一种可行的方法。这通常涉及在数据库表中创建唯一索引，以确保请求的唯一性。以下是一些步骤和概念：

  1. 设计数据库表结构：
    在数据库中创建一张表来记录请求，可以包括请求的唯一标识、请求内容以及处理结果等字段。

  2. 创建唯一索引：
    使用数据库的唯一索引特性，将请求的唯一标识字段设置为唯一索引。这样，当重复插入具有相同唯一标识的请求时，数据库会拒绝插入重复的记录。

  3. 插入请求前进行唯一索引检查：
    在处理请求前，首先查询数据库检查要插入的唯一标识是否已存在。如果存在，则表明这个请求已经被处理过，可以直接返回已存储的结果。

  4. 处理请求并插入数据库：
    如果唯一索引检查结果表明这个请求是新的，可以执行相应的业务逻辑，并将请求的唯一标识及处理结果插入到数据库中。

示例伪代码：
以下是一个简单的伪代码示例，演示了如何使用数据库的唯一索引来确保接口的幂等性：

// 假设这里是数据库操作对象，这里使用伪代码表示
class DatabaseOperation {
    // 执行插入操作，以请求的唯一标识作为唯一索引
    public boolean insertRequest(String uniqueIdentifier, String requestData) {
        // 在数据库中执行插入操作，使用唯一索引来保证唯一性
        // 如果遇到唯一索引重复错误（比如DuplicateEntry），说明请求已存在，返回 false
        // 如果成功插入，说明请求是新的，返回 true
    }

    // 根据唯一标识查询请求
    public String getRequestResult(String uniqueIdentifier) {
        // 根据唯一标识从数据库中获取请求处理结果
    }
}

// 在处理请求的服务类中
class IdempotentAPIHandler {
    private DatabaseOperation db;

    public IdempotentAPIHandler() {
        this.db = new DatabaseOperation(); // 初始化数据库操作对象
    }

    public String processRequest(String uniqueIdentifier, String requestData) {
        // 检查请求是否已存在
        if (db.getRequestResult(uniqueIdentifier) != null) {
            // 请求已存在，直接返回结果
            return db.getRequestResult(uniqueIdentifier);
        } else {
            // 请求是新的，处理请求并将结果插入到数据库
            String result = processRequestData(requestData); // 处理请求数据，获取结果
            db.insertRequest(uniqueIdentifier, result); // 插入请求到数据库
            return result;
        }
    }

    // 其他方法和业务逻辑
}

这个示例演示了如何利用数据库的唯一索引来确保接口的幂等性。在实际应用中，你需要根据具体的数据库和业务需求，调整这个示例。

4.3 使用分布式锁

使用分布式锁来确保接口的幂等性通常会涉及下列步骤：

  1. 获取分布式锁：
    在处理请求之前，尝试获取一个分布式锁，以确保在处理请求期间不会有其他请求来干扰。这样可以确保仅有一个请求能够进入关键的临界区。

  2. 处理请求：
    如果获取了分布式锁，就可以执行请求处理逻辑。这可以是具体的业务逻辑，确保在这个锁的作用下完成了唯一的处理操作。

  3. 释放分布式锁：
    在处理结束后，释放分布式锁，以允许其他请求进入临界区，继续执行接下来的操作。

示例伪代码：
以下是一个使用分布式锁实现接口幂等性的简单示例：

import redis.clients.jedis.Jedis;

public class IdempotentAPIHandler {
    private Jedis jedis;
    private String lockKey = "request_lock";

    public IdempotentAPIHandler() {
        this.jedis = new Jedis("localhost", 6379); // 连接 Redis
    }

    public String processRequest(String requestData) {
        String lockValue = acquireDistributedLock(); // 尝试获取分布式锁

        if (lockValue != null) {
            try {
                // 成功获取锁，处理请求
                String result = processRequestData(requestData); // 处理请求数据，获取结果
                return result;
            } finally {
                releaseDistributedLock(lockValue); // 处理结束后释放锁
            }
        } else {
            // 获取锁失败，可能有其他请求正在处理中
            return "Request is being processed. Please try again later.";
        }
    }

    public String acquireDistributedLock() {
        // 尝试获取分布式锁
        String lockValue = UUID.randomUUID().toString(); // 生成唯一的锁值
        String result = jedis.set(lockKey, lockValue, "NX", "EX", 60); // 设置锁，并设置过期时间
        if ("OK".equals(result)) {
            return lockValue; // 获取锁成功
        } else {
            return null; // 获取锁失败
        }
    }

    public void releaseDistributedLock(String lockValue) {
        // 释放分布式锁
        String currentValue = jedis.get(lockKey);
        if (currentValue != null && currentValue.equals(lockValue)) {
            jedis.del(lockKey); // 删除锁
        }
    }

    public String processRequestData(String requestData) {
        // 处理请求数据获取结果
        return "Processed data: " + requestData;
    }

    // 其他方法和业务逻辑
}

这个示例演示了如何使用Redis的分布式锁来确保在处理请求时只有一个请求能够进入关键的临界区，从而保证接口的幂等性。在实际应用中，你需要根据具体的业务需求和框架，对这个示例进行适当调整。

5. 案例：使用Token+Redis保证提交订单接口的幂等性

当设计一个电商网站的提交订单接口时，确保该接口的幂等性对于避免重复订单、重复支付等问题非常重要。以下是一个示例，使用Token+Redis实现提交订单接口的幂等性：

import redis.clients.jedis.Jedis;
import java.util.UUID;

public class OrderService {
    private Jedis jedis;

    public OrderService() {
        this.jedis = new Jedis("localhost", 6379); // 连接 Redis
    }

    public String submitOrder(String userId, String product) {
        String token = generateToken(userId, product); // 生成订单的唯一 Token

        if (checkIfOrderExists(token)) {
            // 订单已存在，直接返回已处理的结果
            return "Order already submitted.";
        } else {
            // 订单不存在，处理订单并存储到 Redis
            String result = processOrder(userId, product); // 处理订单逻辑，获取结果

            // 将订单信息存储到 Redis，并设置过期时间为一段合理时间，比如 24 小时
            jedis.set(token, result, "NX", "EX", 86400);

            return "Order submitted successfully.";
        }
    }

    private String generateToken(String userId, String product) {
        // 生成 Token，这里用 userId 和商品信息作为组合生成的 Token
        return "order_" + userId + "_" + product + "_" + UUID.randomUUID().toString();
    }

    private boolean checkIfOrderExists(String token) {
        // 检查订单是否已存在于 Redis 中
        return jedis.exists(token);
    }

    private String processOrder(String userId, String product) {
        // 处理订单的逻辑，可以包括数据库插入、支付等步骤
        return "Processed Order: " + product + " for User: " + userId;
    }

    public static void main(String[] args) {
        OrderService orderService = new OrderService();

        // 模拟订单提交
        String userId = "user123";
        String product = "ProductABC";
        String submissionResult = orderService.submitOrder(userId, product);
        System.out.println(submissionResult);
    }
}

这个示例演示了一个简单的订单提交接口，确保了订单的幂等性。在实际应用中，你需要根据实际业务需求和框架，对这个示例进行适当调整。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1179276.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【Linux】服务器与磁盘补充知识，硬raid操作指南

【Linux】服务器与磁盘补充知识，硬raid操作指南

服务器硬件 cpu 主板 内存 硬盘 网卡 电源 raid卡 风扇 远程管理卡 1.硬盘尺寸： 目前生产环境中主流的两种类型硬盘 3.5寸 和2.5寸硬盘 2.5寸硬盘可以通过使用硬盘托架后适用于3.5寸硬盘的服务器 但是3.5寸没法转换成2.5寸 2.如何在服务器上制作raid 华为服务器为例子做…
阅读更多...
DAY46 139.单词拆分 + 多重背包 + 背包问题总结篇

DAY46 139.单词拆分 + 多重背包 + 背包问题总结篇

139.单词拆分 题目要求：给定一个非空字符串 s 和一个包含非空单词的列表 wordDict，判定 s 是否可以被空格拆分为一个或多个在字典中出现的单词。 说明： 拆分时可以重复使用字典中的单词。 你可以假设字典中没有重复的单词。 思路 完全背…
阅读更多...
NVMe FDP会被广泛使用吗？

NVMe FDP会被广泛使用吗？

文章开头，我们需要先了解固态硬盘的读写机制。我们知道，固态硬盘的存储单元是由闪存颗粒组成的，无法实现物理性的数据覆盖，只能擦除然后写入，重复这一过程。因而，我们可以想象得到，在实际读写过…
阅读更多...
04-SpringBoot的基础配置及其配置文件分类,解决Yaml文件失效问题

04-SpringBoot的基础配置及其配置文件分类,解决Yaml文件失效问题

SpringBoot的配置 SpringBoot是用来提高Spring程序的开发效率的,使用SpringBoot后几乎不用做任何配置功能就有了,因为很多功能已经有默认配置帮我们做好了 配置文件的相关配置 在一个项目中不同的技术对应不同的配置文件并且这些配置文件的格式也不统一 SpringBoot提供了一…
阅读更多...
打印由*组成的菱形

打印由*组成的菱形

如图所示，这是我们要用代码所实现的图形。 那么我们该如何实现这个呢，对于这种题，我们只有静下心来找其中的规律了。 我们先来看看它的上面部分： 它是由空格和星号组成的，那么我们是不是可以先打印空格然后再打印星号…
阅读更多...
2023 年 API 安全状况

2023 年 API 安全状况

在当今快速变革的数字世界中，API 已成为快速交付业务功能的关键。这些数字连接器支撑着我们今天见证的大部分企业创新，从无缝的客户体验到集成的合作伙伴生态系统。 随着 API 使用量的激增，潜在风险呈指数级增长。让我们用硬数据来说明 API …
阅读更多...
【redis 面试题】③ 缓存雪崩

【redis 面试题】③ 缓存雪崩

文章目录 前言一、什么是缓存雪崩二、缓存雪崩的解决方案 前言 跟着B站的黑马程序员学习面试题，目前是redis的第三个内容——缓存雪崩 课程传送门：redis——缓存雪崩 一、什么是缓存雪崩 缓存雪崩是设置缓存时采用了相同的过期时间，导致缓存…
阅读更多...
Pytorch 快速参数权重初始化

Pytorch 快速参数权重初始化

定义一个函数： 这里比如要初始化2维卷积权重值，采用xaiver 数据分布，还有很多其他的数据分布可以探索 def weights_init(m):if isinstance(m, nn.Conv2d):xavier(m.weight.data)xavier(m.bias.data) 然后定义一个含2维卷积的网络&#xff…
阅读更多...
HTML5+CSS3小实例：带功能区的图片悬停特效

HTML5+CSS3小实例：带功能区的图片悬停特效

实例：带功能区的图片悬停特效 技术栈：HTML+CSS 效果： 源码： 【HTML】 <!DOCTYPE html> <html><head><meta http-equiv="content-type" content="text/html; charset=utf-8"><meta name="viewport" content=&…
阅读更多...
esxi 6.7下安装黑裙

esxi 6.7下安装黑裙

esxi上创建一个黑裙系统的虚拟机&#xff0c;用来存资料 一、工具 硬件&#xff1a; 工控机&#xff1a;装有esxi6.7系统&#xff08;192.168.100.2&#xff09;&#xff0c;配置&#xff1a;3865U&#xff0c;16G内存&#xff0c;120Gmsata120sata硬盘&#xff0c;6个网口 主…
阅读更多...
oracle转换人大金仓全过程

oracle转换人大金仓全过程

前提 Oracle服务器&#xff1a;创建用户&#xff0c;导入数据库人大金仓服务&#xff1a;创建用户 注意&#xff1a;两者的参数设置要保持一致&#xff08;数字集UTF-8&#xff09;&#xff0c;人大金仓设置大小字符不敏感 人大金仓工具介绍 数字库开发管理工具&#xff1a;链…
阅读更多...
【PTE-day03 报错注入】

【PTE-day03 报错注入】

报错注入 1、报错注入 group by count2、报错注入 extractvalue3、报错注入updatexml1、报错注入 group by count http://124.222.124.9:8888/Less-5/?id=-1 union select 1,count(*),concat((select database()),ceil(rand(0)*2)) as a from information_schema.tables grou…
阅读更多...
思维模型 飞轮效应

思维模型 飞轮效应

本系列文章 主要是 分享 思维模型&#xff0c;涉及各个领域&#xff0c;重在提升认知。万事开头难&#xff0c;坚持就不难。 1 飞轮效应的应用 1.1使用飞轮效应的亚马逊 亚马逊的创始人杰夫贝索斯&#xff08;Jeff Bezos&#xff09;提出了“飞轮理论”&#xff0c;即通过不断…
阅读更多...
jira Licenses更新步骤

jira Licenses更新步骤

有时候我们不想花钱使用jira,那么只有通过一个月以续期的方式来使用jira。下面提供下自己实测的方式 1、获取License Key 登录地址&#xff1a;https://my.atlassian.com 登录自己的Google账号&#xff0c;进入到下面账号&#xff0c;然后点击“New Trial License” product上…
阅读更多...
HTB——introduction to active directory

HTB——introduction to active directory

文章目录 一、Active directory structure二、Active Directory Terminology 一、Active directory structure Active Directory &#xff08;AD&#xff09; 是用于 Windows 网络环境的目录服务。它是一种分布式分层结构&#xff0c;允许集中管理组织的资源&#xff0c;包括用…
阅读更多...
【java】实现自定义注解校验——方法一

【java】实现自定义注解校验——方法一

自定义注解校验的实现步骤&#xff1a; 1.创建注解类&#xff0c;编写校验注解&#xff0c;即类似NotEmpty注解 2.编写自定义校验的逻辑实体类&#xff0c;编写具体的校验逻辑。(这个类可以实现ConstraintValidator这个接口&#xff0c;让注解用来校验) 3.开启使用自定义注解进…
阅读更多...
14.2 并发与竞争实验

14.2 并发与竞争实验

一、原子操作实验 这节使用原子操作来实现对 LED 设备的互斥访问&#xff0c;也就是只有一个应用程序能使用 LED。 1.1 实验程序编写 因为是 12 章已经修改了设备树&#xff0c;所以这里暂时不用修改。 在 /linux/atk-mpl/Drivers 该目录下创建 7_atomic 子目录&#xff0c;并且…
阅读更多...
大数据商城人流数据分析与可视化 - python 大数据分析 计算机竞赛

大数据商城人流数据分析与可视化 - python 大数据分析 计算机竞赛

0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 基于大数据的基站数据分析与可视化 该项目较为新颖&#xff0c;适合作为竞赛课题方向&#xff0c;学长非常推荐&#xff01; &#x1f947;学长这里给一个题目综合评分(每项满分5分) 难度…
阅读更多...
pandas DataFrame转成字典

pandas DataFrame转成字典

目录 dict形式list形式records形式split形式 dict形式 原数据 DateFrame.to_dict() pd.read_excel(r"D:\Users\admin\Desktop\授信额度使用.xlsx").to_dict()list形式 DateFrame.to_dict(‘list’) pd.read_excel(r"D:\Users\admin\Desktop\授信额度使用.x…
阅读更多...
Python 爬虫基础

Python 爬虫基础

Python 爬虫基础 1.1 理论 在浏览器通过网页拼接【/robots.txt】来了解可爬取的网页路径范围 例如访问&#xff1a; https://www.csdn.net/robots.txt User-agent: * Disallow: /scripts Disallow: /public Disallow: /css/ Disallow: /images/ Disallow: /content/ Disallo…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023