通过注解开发来实现下单接口的防重提交

/**
 * 自定义防重提交注解，用于标识是这次request的类型是方法参数还是token类型
 * @author lianglin
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RepeatSubmit {
    /**
     * 防重提交类型：
     * 1、方法参数类型 ： key=ip+method+param
     * 2、token类型：key=accountNo+token
     */
    enum Type {
        PARAM,
        TOKEN
    }
    /**
     * 默认防重提交是方法参数
     * @return
     */
    Type limitType() default Type.PARAM;
    /**
     * 加锁过期时间是5秒
     * @return
     */
    long LockTime() default 5;
}

/**
 * 定义切面类
 */
@Aspect
@Component
@Slf4j
public class RepeatSubmitAspect {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    /**
     * 定义 @Pointcut注解表达式，
     *  方式一：@annotation：当执行的方法上拥有指定的注解时生效（我们采用这）
     *  方式二：execution：一般用于指定方法的执行
     * 
     * @param repeatSubmit
     */
    @Pointcut("@annotation(repeatSubmit)")
    public void pointcutNoRepeatSubmit(RepeatSubmit repeatSubmit) {
    }
    /**
     * 环绕通知, 围绕着方法执行
     * @Around 可以用来在调用一个具体方法前和调用后来完成一些具体的任务。
     *
     * 方式一：单用 @Around("execution(* net.xdclass.controller.*.*(..))")可以
     * 方式二：用@Pointcut和@Around联合注解也可以（我们采用这个）
     *
     *
     * 两种方式
     * 方式一：加锁 固定时间内不能重复提交
     * <p>
     * 方式二：先请求获取token，这边再删除token,删除成功则是第一次提交
     *
     * @param joinPoint
     * @param noRepeatSubmit
     * @return
     * @throws Throwable
     * 所有@RepeatSubmit注解的方法都添加该环绕通知
     */
    @Around("pointcutNoRepeatSubmit(noRepeatSubmit)")
    public Object around(ProceedingJoinPoint joinPoint, RepeatSubmit noRepeatSubmit) throws Throwable {
        //获取request请求
        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
        boolean res=false;
        String type = noRepeatSubmit.limitType().name();
        if (type.equals(RepeatSubmit.Type.PARAM.name())) {
            //方式一方法参数            TODO
        } else {
            //方式二,令牌形式
            String requestToken = request.getHeader("request-token");
            if (StringUtils.isBlank(requestToken)) {
                throw new BizException(BizCodeEnum.ORDER_CONFIRM_TOKEN_EQUAL_FAIL);
            }
            LoginUser loginUser = LoginInterceptor.threadLocal.get();
            //"order:submit:%s:%s"
            String key = String.format(RedisKey.SUBMIT_ORDER_TOKEN_KEY, loginUser.getAccountNo(),requestToken);
            /**
             * 提交表单的token key
             * 方式一：不用lua脚本获取再判断，之前是因为 key组成是 order:submit:accountNo, value是对应的token，所以需要先获取值，再判断
             * 方式二：可以直接key是 order:submit:accountNo:token,然后直接删除成功则完成
             */
            res = stringRedisTemplate.delete(key);
        }
        if (!res) {
            //删除失败，说明redis中没有这个token
            throw new BizException(BizCodeEnum.ORDER_CONFIRM_REPEAT);
        }
        System.out.println("目标方法执行前");
        //被自定义注解标识的方法继续执行
        Object object = joinPoint.proceed();
        System.out.println("目标方法执行后");
        return object;
    }
}

/**
 * 测试下单token的获取
 * @return
 */
@GetMapping("test")
@RepeatSubmit(limitType = RepeatSubmit.Type.TOKEN)
public JsonData testRequestToken(){
    return JsonData.buildSuccess("测试成功");
}