当前位置：首页 > news >正文

java防抖，防止表单重复提交，aop注解形式

news 2025/7/4 17:34:56

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 AntiShake {
    // 默认过期时间3秒
    int expire() default 3;
}

防抖切面

import jakarta.annotation.Resource;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.lang.reflect.Method;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.concurrent.TimeUnit;

/**
 * 防抖
 */
@Aspect
@Component
public class AntiShakeAop {

    @Autowired
    private RedisUtil redisUtil;

    /**
     * 切入点
     */
    @Pointcut("@annotation(xx.xx.xx.xx.xx.AntiShake)")
    public void pt() {
    }

    @Around("pt()")
    public Object arround(ProceedingJoinPoint joinPoint) throws Throwable {
        StringBuilder sb = new StringBuilder();
        for (Object arg : joinPoint.getArgs()) {
            if (arg != null) {
                sb.append(arg.toString());
            }
        }
        String paramHash = md5(sb.toString());
        String key = "anti-shake:"+ joinPoint.getSignature().getName() + ":" + paramHash;
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        int expire = method.getAnnotation(AntiShake.class).expire();
        // 如果缓存中有这个url视为重复提交
        if (!redisUtil.hasKey(key)) {
            //然后存入redis 并且设置倒计时
            redisUtil.set(key, 0, expire, TimeUnit.SECONDS);
            //返回结果
            return joinPoint.proceed();
        } else {
            throw new RuntimeException("请勿重复提交或者操作过于频繁！");
        }

    }

    private String md5(String input) {
        try {
            MessageDigest md = MessageDigest.getInstance("MD5");
            byte[] messageDigest = md.digest(input.getBytes());
            StringBuilder hexString = new StringBuilder();
            for (byte b : messageDigest) {
                String hex = Integer.toHexString(0xFF & b);
                if (hex.length() == 1) hexString.append('0');
                hexString.append(hex);
            }
            return hexString.toString();
        } catch (NoSuchAlgorithmException e) {
            throw new RuntimeException(e);
        }
    }
}

用法

    @AntiShake
    @GetMapping("/test")
    public String test(@RequestParam String name ) throws Exception {
        log.info("防抖测试：{}", name);
        Thread.sleep(10000);
        return "success";
    }