@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface RepeatSubmit {
    String value() default "";
    int interval() default 3000; // 默認(rèn)3秒
    String message() default "請(qǐng)勿重復(fù)提交";
}

@RestController
public class UserController {

    @PostMapping("/submitForm")
    @RepeatSubmit(interval = 5000, message = "請(qǐng)等待5秒后再提交")
    public ResponseEntity<String> submitForm(@RequestBody FormData formData) {
        // 處理表單提交邏輯
        return ResponseEntity.ok("表單提交成功");
    }
}

   @Target(ElementType.METHOD)
   @Retention(RetentionPolicy.RUNTIME)
   public @interface RepeatSubmit {
       String value() default "";
       int interval() default 3000; // 默認(rèn)3秒
       String message() default "請(qǐng)勿重復(fù)提交";
   }
   

   @Aspect
   @Component
   public class RepeatSubmitAspect {

       @Around("@annotation(repeatSubmit)")
       public Object around(ProceedingJoinPoint joinPoint, RepeatSubmit repeatSubmit) throws Throwable {
           // 獲取方法簽名
           MethodSignature signature = (MethodSignature) joinPoint.getSignature();
           Method method = signature.getMethod();

           // 獲取請(qǐng)求上下文
           HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();

           // 獲取注解參數(shù)
           int interval = repeatSubmit.interval();
           String message = repeatSubmit.message();

           // 從 session 中獲取上次請(qǐng)求的時(shí)間戳
           Long lastRequestTime = (Long) request.getSession().getAttribute(method.getName());

           // 檢查是否重復(fù)提交
           if (lastRequestTime != null && System.currentTimeMillis() - lastRequestTime < interval) {
               throw new RuntimeException(message);
           }

           // 記錄當(dāng)前請(qǐng)求的時(shí)間戳
           request.getSession().setAttribute(method.getName(), System.currentTimeMillis());

           // 繼續(xù)執(zhí)行目標(biāo)方法
           return joinPoint.proceed();
       }
   }
   

   @RestController
   public class UserController {

       @PostMapping("/submitForm")
       @RepeatSubmit(interval = 5000, message = "請(qǐng)等待5秒后再提交")
       public ResponseEntity<String> submitForm(@RequestBody FormData formData) {
           // 處理表單提交邏輯
           return ResponseEntity.ok("表單提交成功");
       }
   }
   

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface RepeatSubmit {
    String value() default "";
    int interval() default 3000; // 默認(rèn)3秒
    String message() default "請(qǐng)勿重復(fù)提交";
}
// 創(chuàng)建切面
@Aspect
@Component
public class RepeatSubmitAspect {

    @Autowired
    private RedisTemplate<String, Long> redisTemplate;

    @Around("@annotation(repeatSubmit)")
    public Object around(ProceedingJoinPoint joinPoint, RepeatSubmit repeatSubmit) throws Throwable {
        // 獲取方法簽名
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();

        // 獲取請(qǐng)求上下文
        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();

        // 獲取注解參數(shù)
        int interval = repeatSubmit.interval();
        String message = repeatSubmit.message();

        // 生成唯一的請(qǐng)求標(biāo)識(shí)
        String key = method.getName() + ":" + request.getRemoteAddr();

        // 從 Redis 中獲取上次請(qǐng)求的時(shí)間戳
        Long lastRequestTime = redisTemplate.opsForValue().get(key);

        // 檢查是否重復(fù)提交
        if (lastRequestTime != null && System.currentTimeMillis() - lastRequestTime < interval) {
            throw new RuntimeException(message);
        }

        // 記錄當(dāng)前請(qǐng)求的時(shí)間戳
        redisTemplate.opsForValue().set(key, System.currentTimeMillis(), interval, TimeUnit.MILLISECONDS);

        // 繼續(xù)執(zhí)行目標(biāo)方法
        return joinPoint.proceed();
    }
}
// 在控制器方法中使用注解
@RestController
public class UserController {

    @PostMapping("/submitForm")
    @RepeatSubmit(interval = 5000, message = "請(qǐng)等待5秒后再提交")
    public ResponseEntity<String> submitForm(@RequestBody FormData formData) {
        // 處理表單提交邏輯
        return ResponseEntity.ok("表單提交成功");
    }
}

flowchart TD
    A[開始] --> B[接收請(qǐng)求]
    B --> C[生成唯一請(qǐng)求標(biāo)識(shí)]
    C --> D[從 Redis 獲取上次請(qǐng)求時(shí)間戳]
    D -->|存在且未過期| E[返回重復(fù)提交提示信息]
    D -->|不存在或已過期| F[記錄當(dāng)前請(qǐng)求時(shí)間戳]
    F --> G[繼續(xù)執(zhí)行目標(biāo)方法]
    G --> H[返回成功響應(yīng)]
    H --> I[結(jié)束]