这样的接口幂等实现我认为最为优雅(防重复提交)

- **创建订单、支付等关键操作**：当用户提交订单或进行支付时，如果因网络问题或其他原因导致请求被重复发送，系统应该能够识别这些重复请求并避免产生重复的订单或支付。此类操作通常需要幂等性。
- **更新操作**：例如更新用户信息、修改配置等操作。幂等性确保多次相同的请求只会对系统状态产生一次性影响，避免因重复操作导致数据不一致。

- **公共API**：如果你的接口是对外公开的API，可能会有多种不同的客户端调用它们。为了保证系统的稳定性和安全性，确保接口幂等性是非常必要的。

- 在一些不稳定的网络环境中，重复请求很容易发生。幂等性可以防止由于网络重试导致的数据问题。

- **GET 请求**：通常用于查询数据的GET请求天然是幂等的，无论执行多少次查询操作，都不会改变系统的状态。因此，这类请求不需要特别设计幂等性。

- **日志记录、访问统计等**：例如向数据库中写入日志信息、更新访问统计次数等，这些操作即使重复多次，也不会对系统的核心数据产生重大影响。因此，不一定需要做到幂等。

- 如果接口仅用于内部服务之间的通信，并且调用逻辑受控（如在事务中执行的操作），则不一定需要特别考虑幂等性。

package fun.acowbo.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * @author xiaobo
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Idempotent {
    // 模块名称
    String module() default "";
    // Token 过期时间，单位为分钟
    long expiryTime() default 10;
}

- **清晰的业务区分**：通过指定模块名称，可以在处理幂等性逻辑时，对不同的业务模块进行区分。这有助于根据不同模块的需求进行定制化处理，避免全局统一处理带来的灵活性不足。
- **易于维护**：在项目扩展时，可以方便地查看和管理不同模块的幂等性设置，增强代码的可维护性和可读性。

- **动态调整**：通过设置不同的方法过期时间，允许根据业务需求动态调整幂等令牌的有效期。例如，对于某些操作，幂等性可能只需要短时间内有效，而对于另一些操作，则可能需要更长的有效期。
- **安全性提升**：过期时间限制了幂等令牌的生命周期，降低了长期存在的幂等令牌可能被滥用的风险，进一步增强了接口的安全性。

package fun.acowbo.aspect;


import fun.acowbo.annotation.Idempotent;
import fun.acowbo.utils.BoRedisUtil;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.concurrent.TimeUnit;

/**
 * @author <a href="https://acowbo.fun">acowbo</a>
 * @since 2024/9/3
 */
@Aspect
@Component
public class IdempotentAspect {

    @Resource
    private HttpServletRequest request;
    @Around("@annotation(idempotent)")
    public Object handleIdempotency(ProceedingJoinPoint joinPoint, Idempotent idempotent) throws Throwable {
        // 获取请求 Token（例如从请求头或方法参数中获取）
        String token = extractTokenFromRequest();

        // 检查 Token 是否已存在
        boolean tokenStored = BoRedisUtil.setIfAbsent(idempotent.module() + ":" + token, "1", idempotent.expiryTime(), TimeUnit.MINUTES);

        if (!tokenStored) {
            // 如果 Token 已存在，则表示请求重复，返回错误或结果
            throw new RuntimeException("订单已经存在了！");
        }

        // 如果 Token 存储成功，则执行目标方法
        return joinPoint.proceed();
    }

    private String extractTokenFromRequest() {
        // 从请求头中提取 Token
        String token = request.getHeader("Idempotency-Token");
        if (token == null || token.isEmpty()) {
            throw new RuntimeException("没有请求token");
        }
        return token;
    }
}

package fun.acowbo.controller;


import fun.acowbo.annotation.Idempotent;
import fun.acowbo.service.OrderService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;

/**
 * @author <a href="https://acowbo.fun">acowbo</a>
 * @since 2024/9/3
 */

@RestController
@RequestMapping("/orders")
@RequiredArgsConstructor
public class OrderController {

    private final OrderService orderService;


    @GetMapping("/create/{orderNo}")
    @Idempotent(module = "order", expiryTime = 3)
    public String createOrder(@PathVariable String orderNo) {
        return orderService.createOrder(orderNo);
    }
}

package fun.acowbo.service;

import org.springframework.stereotype.Service;

/**
 * @author <a href="https://acowbo.fun">acowbo</a>
 * @since 2024/9/3
 */

@Service
public class OrderService {

    public String createOrder(String orderNo) {
        // 处理创建订单的逻辑
        // 此处省略实际的业务处理代码
        return "订单创建成功: " + orderNo;
    }
}

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>按钮禁用示例</title>
</head>
<body>

<form id="myForm">
    <input type="text" name="username" placeholder="Enter your name" required>
    <button type="submit" id="submitButton">Submit</button>
</form>

<script>
document.getElementById("myForm").addEventListener("submit", function(event) {
    var submitButton = document.getElementById("submitButton");
    
    // 禁用按钮
    submitButton.disabled = true;

    // 模拟表单提交过程
    setTimeout(function() {
        // 在这里通常是发送表单数据到服务器，完成后可以恢复按钮状态
        // submitButton.disabled = false;

        alert("Form submitted!");
    }, 2000); // 模拟2秒的网络延迟
});
</script>

</body>
</html>

npm install axios

import axios from 'axios';

// 存储正在进行的请求
const pendingRequests = new Map();

// 生成唯一标识符
function generateRequestKey(config) {
    const { method, url, params, data } = config;
    return [method, url, JSON.stringify(params), JSON.stringify(data)].join('&');
}

// 添加请求拦截器
axios.interceptors.request.use(
    config => {
        const requestKey = generateRequestKey(config);

        if (pendingRequests.has(requestKey)) {
            // 如果请求已经存在，抛出错误或取消请求
            return Promise.reject({ message: '重复请求' });
        }

        // 记录请求
        pendingRequests.set(requestKey, true);

        return config;
    },
    error => {
        return Promise.reject(error);
    }
);

// 添加响应拦截器
axios.interceptors.response.use(
    response => {
        const requestKey = generateRequestKey(response.config);

        // 请求完成后移除记录
        pendingRequests.delete(requestKey);

        return response;
    },
    error => {
        const requestKey = generateRequestKey(error.config || {});

        // 请求失败时也移除记录
        pendingRequests.delete(requestKey);

        return Promise.reject(error);
    }
);