快捷導(dǎo)航

java接口防重提交的處理方法

更新時間：2023年05月29日 09:48:10 作者：一枚路過的程序猿

本文主要介紹了java接口防重提交的處理方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

1.什么是接口防重？

在一定的時間內(nèi)多次請求同一接口，同一參數(shù)。由于請求是健康請求，會執(zhí)行正常的業(yè)務(wù)邏輯，從而產(chǎn)生大量的廢數(shù)據(jù)。

2.問題的產(chǎn)生及引發(fā)的問題

舉一個最簡單的例子：日常開發(fā)中crud在業(yè)務(wù)系統(tǒng)中普遍存在，在服務(wù)端沒有做任何處理，客戶端沒有做節(jié)流、防抖等限流操作時，同一秒一個用戶點了兩次新增按鈕，導(dǎo)致數(shù)據(jù)庫中存在同樣兩條數(shù)據(jù)，其結(jié)果可想而知，同理修改、刪除同樣的道理；查詢本身具有冪等性，但是在同一秒鐘同樣的操作，查詢多次和一次，有區(qū)別嗎？區(qū)別大了去了，不談用戶體驗如何，光是網(wǎng)絡(luò)開銷、流量占用、帶給服務(wù)器的壓力等等，生產(chǎn)中一點小的問題，如何不及時處理，可能會引發(fā)災(zāi)難性bug。

3.處理方法

第一種：前臺在請求接口的時候，傳遞一個唯一值，然后在對應(yīng)接口判斷該唯一值，在一定的時間內(nèi)是否被消費過
第二種：采用Spring AOP理念，實現(xiàn)請求的切割，在請求執(zhí)行到某個方法或某層時候，開始攔截進行，獲取該請求的參數(shù)，用戶信息，請求地址，存入redis中并放置過期時間，進行防重（推薦使用）

4.談?wù)勔韵聝煞N處理方法的利弊

第一種：局限性太高，前臺必須傳遞一個唯一值，就算請求到達(dá)指定后臺服務(wù)，寫一個攔截器，需要配置太多不需要攔截的方法，也許你會說，可以攔截有規(guī)則的請求地址，這樣真的好嗎?
第二種（推薦）：采用AOP面向切面編程的思想，在不污染源代碼的情況下，進行增強功能，切入到要防重的接口上，實現(xiàn)統(tǒng)一防重處理、業(yè)務(wù)解耦。此處采用AOP + 自定義注解，靈活實現(xiàn)防重功能。

5.具體代碼(采用第二種)

注解類

import java.lang.annotation.*;
/**
?* 防重
?* @date 2020/8/12
?* @return
?*/
//標(biāo)識該注解用于方法上
@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ù)提交
?* @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;
? ? /**
? ? ?* 防重
? ? ?* @date 2020/8/12
? ? ?* @return
? ? ?*/
? ? @Around("@annotation(com.qianxian.user.annotation.PreventSubmit)")
? ? public Object preventSubmitAspect(ProceedingJoinPoint joinPoint) throws Throwable {
? ? ? ? RLock lock = null;
? ? ? ? try {
? ? ? ? ? ? //獲取目標(biāo)方法的參數(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í)行目標(biāo)方法
? ? ? ? ? ? Object result = joinPoint.proceed(args);
? ? ? ? ? ? return result;
? ? ? ? }finally {
? ? ? ? ? ? if(lock != null){
? ? ? ? ? ? ? ? lock.unlock();
? ? ? ? ? ? }
? ? ? ? }
? ? }
}

到此這篇關(guān)于java接口防重提交的處理方法的文章就介紹到這了,更多相關(guān)java接口防重提交內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: