1.什么是接口防重？
在一定的時間內(nèi)請求同一接口，同一參數(shù)洲押。由于請求是健康請求戈抄，會執(zhí)行正常的業(yè)務(wù)邏輯席噩，從而產(chǎn)生大量的廢數(shù)據(jù)。
2.處理方法
第一種：前臺在請求接口的時候，傳遞一個唯一值桌肴，然后在對應(yīng)接口判斷該唯一值寸潦，在一定的時間內(nèi)是否被消費過
第二種：采用Spring AOP理念色鸳，實現(xiàn)請求的切割，在請求執(zhí)行到某個方法或某層時候见转，開始攔截進行命雀，獲取該請求的參數(shù)，用戶信息斩箫，請求地址吏砂，存入redis中并放置過期時間，進行防重（推薦使用）
3.談?wù)勔陨蟽煞N處理方法的利弊
第一種：局限性太高乘客，前臺必須傳遞一個唯一值狐血，就算請求到達指定后臺服務(wù)，寫一個攔截器易核，需要配置太多不需要攔截的方法匈织，也許你會說，可以攔截有規(guī)則的請求地址耸成，這樣真的好嗎?
第二種：作為一名JAVA后臺開發(fā)报亩，Spring應(yīng)該是熟悉的不能再熟悉了，Spring核心AOP又用了多少井氢，針對以上請求，只需要寫一個注解類岳链，然后切面到該注解上花竞，在需要防重的方法上只需添加注解即可
4.具體代碼(采用第二種)
注解類
import java.lang.annotation.*;
/**
* 防重
* @author haodongdong
* @date 2020/8/12
* @return
*/
//標識該注解用于方法上
@Target({ElementType.METHOD})
//申明該注解為運行時注解，編譯后改注解不會被遺棄
@Retention(RetentionPolicy.RUNTIME)
//javadoc工具記錄
@Documented
public @interface PreventSubmit
{
}
切面類
import com.qianxian.common.exception.AppException;
import com.qianxian.common.util.TokenUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import javax.servlet.http.HttpServletRequest;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;
/**
* 防重復(fù)提交
* @author haodongdong
* @date 2020/8/12
* @return
*/
@Component
@Aspect
@Slf4j
public class PreventSubmitAspect {
/**
* 放重redis前綴
*/
private static String API_PREVENT_SUBMIT = "api:preventSubmit:";
/**
* 放重分布式鎖前綴
*/
private static String API_LOCK_PREVENT_SUBMIT = "api:preventSubmit:lock:";
/**
* 失效時間
*/
private static Integer INVALID_NUMBER = 3;
/**
* redis
*/
@Autowired
private StringRedisTemplate stringRedisTemplate;
/**
* 分布式鎖
*/
@Autowired
private RedissonClient redissonClient;
/**
* 防重
* @author haodongdong
* @date 2020/8/12
* @return
*/
@Around("@annotation(com.qianxian.user.annotation.PreventSubmit)")
public Object preventSubmitAspect(ProceedingJoinPoint joinPoint) throws Throwable {
RLock lock = null;
try {
//獲取目標方法的參數(shù)
Object[] args = joinPoint.getArgs();
//獲取當(dāng)前request請求
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
HttpServletRequest request = (HttpServletRequest) requestAttributes.resolveReference(RequestAttributes.REFERENCE_REQUEST);
//獲取請求地址
String requestUri = request.getRequestURI();
//獲取用戶ID
Long userId = null;
try {
userId = TokenUtil.getUserId(request);
}catch (Exception e){}
//拼接鎖前綴掸哑，采用同一方法约急，同一用戶,同一接口
String temp = requestUri.concat(Arrays.asList(args).toString()) + (userId != null ? userId : "");
temp = temp.replaceAll("/","");
//拼接rediskey
String lockPrefix = API_LOCK_PREVENT_SUBMIT.concat(temp);
String redisPrefix = API_PREVENT_SUBMIT.concat(temp);
/**
* 對同一方法同一用戶同一參數(shù)加鎖,即使獲取不到用戶ID,每個用戶請求數(shù)據(jù)也會不一致，不會造成接口堵塞
*/
lock = this.redissonClient.getLock(lockPrefix);
lock.lock();
String flag = this.stringRedisTemplate.opsForValue().get(redisPrefix);
if(StringUtils.isNotEmpty(flag)){
throw new AppException("您當(dāng)前的操作太頻繁了,請稍后再試!");
}
//存入redis,設(shè)置失效時間
this.stringRedisTemplate.opsForValue().set(redisPrefix,redisPrefix,INVALID_NUMBER, TimeUnit.SECONDS);
//執(zhí)行目標方法
Object result = joinPoint.proceed(args);
return result;
}finally {
if(lock != null){
lock.unlock();
}
}
}
}
