java对重复请求限制_java相关：Springboot通过AOP防止API重复请求代码实例

java相关&＃xff1a;Spring boot通过AOP防止API重复请求代码实例

发布于 2020-4-28|

复制链接

摘记: 这篇文章主要介绍了Spring boot通过AOP防止API重复请求代码实例,文中通过示例代码介绍的非常详细&＃xff0c;对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下实现思路基于Spring Boot 2.x自定义注解&＃xff0c;用来标记是哪些API是需要监控是否重复请求 ..

这篇文章主要介绍了Spring boot通过AOP防止API重复请求代码实例,文中通过示例代码介绍的非常详细&＃xff0c;对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下实现思路基于Spring Boot 2.x自定义注解&＃xff0c;用来标记是哪些API是需要监控是否重复请求通过Spring AOP来切入到Controller层&＃xff0c;进行监控检验重复请求的Key&＃xff1a;Token &＃43; ServletPath &＃43; SHA1RequestParas Token&＃xff1a;用户登录时&＃xff0c;生成的Token

ServletPath&＃xff1a;请求的Path

SHA1RequestParas&＃xff1a;将请求参数使用SHA-1散列算法加密

使用以上三个参数拼接的Key作为去判断是否重复请求由于项目是基于集群的&＃xff0c;使用Redis存储Key&＃xff0c;而且redis的特性&＃xff0c;key可以设定在规定时间内自动删除。这里的这个规定时间&＃xff0c;就是api在规定时间内不能重复提交。自定义注解(注解作用于Controller层的API)

&＃96;&＃96;&＃96;java

&＃64;Target(ElementType.METHOD)

&＃64;Retention(RetentionPolicy.RUNTIME)

public &＃64;interface NoRepeatSubmission {

}

&＃96;&＃96;&＃96;

切面逻辑

&＃96;&＃96;&＃96;java

import com.gotrade.apirepeatrequest.annotation.NoRepeatSubmission;

import com.gotrade.apirepeatrequest.common.JacksonSerializer;

import com.gotrade.apirepeatrequest.model.Result;

import lombok.extern.slf4j.Slf4j;

import org.aspectj.lang.ProceedingJoinPoint;

import org.aspectj.lang.annotation.Around;

import org.aspectj.lang.annotation.Aspect;

import org.aspectj.lang.reflect.MethodSignature;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.redis.core.RedisTemplate;

import org.springframework.data.redis.core.ValueOperations;

import org.springframework.stereotype.Component;

import org.springframework.web.context.request.RequestContextHolder;

import org.springframework.web.context.request.ServletRequestAttributes;

import javax.servlet.http.HttpServletRequest;

import java.nio.charset.StandardCharsets;

import java.security.MessageDigest;

import java.security.NoSuchAlgorithmException;

import java.util.Objects;

import java.util.concurrent.ConcurrentHashMap;

import java.util.concurrent.TimeUnit;

&＃64;Slf4j

&＃64;Aspect

&＃64;Component

public class NoRepeatSubmissionAspect {

&＃64;Autowired

RedisTemplate redisTemplate;

/**

* 环绕通知

* &＃64;param pjp

* &＃64;param ars

* &＃64;return

*/

&＃64;Around("execution(public * com.gotrade.apirepeatrequest.controller..*.*(..)) && &＃64;annotation(ars)")

public Object doAround(ProceedingJoinPoint pjp, NoRepeatSubmission ars) {

ValueOperations opsForValue &＃61; redisTemplate.opsForValue();

try {

if (ars &＃61;&＃61; null) {

return pjp.proceed();

}

HttpServletRequest request &＃61; ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();

String token &＃61; request.getHeader("Token");

if (!checkToken(token)) {

return Result.failure("Token无效");

}

String servletPath &＃61; request.getServletPath();

String jsonString &＃61; this.getRequestParasJSONString(pjp);

String sha1 &＃61; this.generateSHA1(jsonString);

// key &＃61; token &＃43; servlet path

String key &＃61; token &＃43; "-" &＃43; servletPath &＃43; "-" &＃43; sha1;

log.info("\n{\n\tServlet Path: {}\n\tToken: {}\n\tJson String: {}\n\tSHA-1: {}\n\tResult Key: {} \n}", servletPath, token, jsonString, sha1, key);

// 如果Redis中有这个key, 则url视为重复请求

if (opsForValue.get(key) &＃61;&＃61; null) {

Object o &＃61; pjp.proceed();

opsForValue.set(key, String.valueOf(0), 3, TimeUnit.SECONDS);

return o;

} else {

return Result.failure("请勿重复请求");

}

} catch (Throwable e) {

e.printStackTrace();

return Result.failure("验证重复请求时出现未知异常");

}

}

/**

* 获取请求参数

* &＃64;param pjp

* &＃64;return

*/

private String getRequestParasJSONString(ProceedingJoinPoint pjp) {

String[] parameterNames &＃61; ((MethodSignature) pjp.getSignature()).getParameterNames();

ConcurrentHashMap args &＃61; null;

if (Objects.nonNull(parameterNames)) {

args &＃61; new ConcurrentHashMap(parameterNames.length);

for (int i &＃61; 0; i >> 4 & 0xf];

buf[k&＃43;&＃43;] &＃61; hexDigits[byte0 & 0xf];

}

return new String(buf);

} catch (NoSuchAlgorithmException e) {

e.printStackTrace();

}

return null;

}

}

&＃96;&＃96;&＃96;