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

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Idempotent {}

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;

import java.util.concurrent.ConcurrentHashMap;

@Aspect
@Component
public class IdempotencyInterceptor {

    private static final ConcurrentHashMap<String, Boolean> REQUEST_IDS = new ConcurrentHashMap<>();

    @Around("@annotation(Idempotent)")
    public Object intercept(ProceedingJoinPoint joinPoint) throws Throwable {
        String requestId = getRequestIdFromContext(); // 假設(shè)這是一個(gè)從上下文中獲取請(qǐng)求ID的方法

        if (REQUEST_IDS.putIfAbsent(requestId, Boolean.TRUE) != null) {
            // 如果requestId已經(jīng)存在，說明是重復(fù)請(qǐng)求，直接返回結(jié)果
            return handleDuplicateRequest(); // 自定義處理重復(fù)請(qǐng)求的方法
        }

        try {
            return joinPoint.proceed(); // 執(zhí)行原方法
        } finally {
            // 無論請(qǐng)求是否成功，都應(yīng)該在finally塊中移除requestId，防止內(nèi)存泄漏
            REQUEST_IDS.remove(requestId);
        }
    }

    // 自定義獲取請(qǐng)求ID的方法（需要根據(jù)實(shí)際情況實(shí)現(xiàn)）
    private String getRequestIdFromContext() {
        // TODO: 實(shí)現(xiàn)從上下文中獲取請(qǐng)求ID的邏輯
        return "dummyRequestId"; // 示例返回值
    }

    // 自定義處理重復(fù)請(qǐng)求的方法（可以根據(jù)需要返回不同的結(jié)果）
    private Object handleDuplicateRequest() {
        return "Duplicate request detected, no action taken.";
    }
}

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/api")
public class DemoController {

    @Idempotent
    @GetMapping("/testIdempotency")
    public String testIdempotency() {
        // 模擬一些業(yè)務(wù)邏輯
        return "Operation successful";
    }
}