通过aop注解实现防止重复提交

通过注解和aop来实现，后端的重复提交校验

1.定义防止重复提交的注解

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface PreventDuplicateSubmissions {

    /** 过期时间 */
    long expire() default 3;
}

2.实现防止重复提交的拦截器

@Aspect
@Component
@Slf4j
public class PreventDuplicateSubmissionsInterceptor {

    @Autowired private Cache cache;

    @Before("@annotation(preventDuplicateSubmissions)")
    public void interceptor(PreventDuplicateSubmissions preventDuplicateSubmissions) {

        try {
            Long count = cache.incr(getParams(), preventDuplicateSubmissions.expire());
            // 如果超过2或者设置的参数，则表示重复提交了
            if (count.intValue() >= 2) {
                throw new ServiceException(ResultCode.LIMIT_ERROR);
            }
        }
        // 如果参数为空，则表示用户未登录，直接略过，不做处理
        catch (NullPointerException ignored) {
        } catch (ServiceException e) {
            throw e;
        } catch (Exception e) {
            log.error("防重复提交拦截器异常", e);
            throw new ServiceException(ResultCode.ERROR);
        }
    }

    /**
     * 获取表单参数
     *
     * @return
     */
    private String getParams() {
        HttpServletRequest request =
                ((ServletRequestAttributes)
                                Objects.requireNonNull(RequestContextHolder.getRequestAttributes()))
                        .getRequest();
        // 请求地址
        return request.getRequestURI()
                + Objects.requireNonNull(UserContext.getCurrentUser()).getId()
                + UserContext.getCurrentUser().getUsername();
    }
}

3.具体的使用

@PreventDuplicateSubmissions(expire = 5)
@GetMapping("/retry")
public String retry() {
    log.info("aop执行");
    throw new RetryException("aop执行");
}