為什么要實(shí)現(xiàn)冪等性校驗(yàn) 如何實(shí)現(xiàn)接口的冪等性校驗(yàn)

packageorg.example.exception;

/**
*運(yùn)行時(shí)異常
*@authorbinbin.hou
*@since0.0.1
*/
publicclassRequestManyValidationExceptionextendsRuntimeException{

publicRequestManyValidationException(){
}

publicRequestManyValidationException(Stringmessage){
super(message);
}

publicRequestManyValidationException(Stringmessage,Throwablecause){
super(message,cause);
}

publicRequestManyValidationException(Throwablecause){
super(cause);
}

publicRequestManyValidationException(Stringmessage,Throwablecause,booleanenableSuppression,booleanwritableStackTrace){
super(message,cause,enableSuppression,writableStackTrace);
}
}

「模式工廠」

packageorg.example.factory;

importorg.example.exception.RequestManyValidationException;

/**
*@authorzrq
*@ClassNameRequestManyStrategy
*@date2023/11/229:04
*@DescriptionTODO
*/
publicinterfaceRequestManyStrategy{
voidvalidate(Stringkey,Integertime)throwsRequestManyValidationException;
}

「模式實(shí)現(xiàn)01」

packageorg.example.factory.impl;

importorg.example.exception.RequestManyValidationException;
importorg.example.factory.RequestManyStrategy;
importorg.example.utils.RedisCache;
importorg.springframework.stereotype.Component;

importjavax.annotation.Resource;
importjava.util.concurrent.TimeUnit;

/**
*@authorzrq
*@ClassNameRedisIdempotentStrategy
*@date2023/11/229:07
*@DescriptionTODO
*/
@Component
publicclassRedisIdempotentStrategyimplementsRequestManyStrategy{
@Resource
privateRedisCacheredisCache;

@Override
publicvoidvalidate(Stringkey,Integertime)throwsRequestManyValidationException{
if(redisCache.hasKey(key)){
thrownewRequestManyValidationException("請(qǐng)求次數(shù)過多");
}else{
redisCache.setCacheObject(key,"1",time,TimeUnit.MINUTES);
}
}
}

「模式實(shí)現(xiàn)02」

packageorg.example.factory.impl;

importorg.example.exception.RequestManyValidationException;
importorg.example.factory.RequestManyStrategy;
importorg.example.utils.RedisCache;
importorg.springframework.data.redis.connection.RedisConnectionFactory;
importorg.springframework.data.redis.connection.jedis.JedisConnectionFactory;
importorg.springframework.data.redis.core.RedisTemplate;
importorg.springframework.data.redis.serializer.StringRedisSerializer;
importorg.springframework.stereotype.Component;
importorg.springframework.web.context.request.RequestContextHolder;
importorg.springframework.web.context.request.ServletRequestAttributes;

importjavax.annotation.Resource;
importjavax.servlet.http.HttpServletRequest;

/**
*@authorzrq
*@ClassNameTokenIdempotentStrategy
*@date2023/11/229:13
*@DescriptionTODO
*/
@Component
publicclassTokenIdempotentStrategyimplementsRequestManyStrategy{
@Resource
privateRedisCacheredisCache;
@Override
publicvoidvalidate(Stringkey,Integertime)throwsRequestManyValidationException{
HttpServletRequestrequest=((ServletRequestAttributes)RequestContextHolder.getRequestAttributes()).getRequest();
Stringtoken=request.getHeader("token");
if(token==null||token.isEmpty()){
thrownewRequestManyValidationException("未授權(quán)的token");
}
//根據(jù)key和token執(zhí)行冪等性校驗(yàn)
booleanisDuplicateRequest=performTokenValidation(key,token);
if(!isDuplicateRequest){
thrownewRequestManyValidationException("多次請(qǐng)求");
}
}
privatebooleanperformTokenValidation(Stringkey,Stringtoken){
//執(zhí)行根據(jù)Token進(jìn)行冪等性校驗(yàn)的邏輯
//這里可以使用你選擇的合適的方法，比如將Token存儲(chǔ)到數(shù)據(jù)庫(kù)或緩存中，然后檢查是否已存在
StringstoredToken=redisCache.getCacheObject(key);
//比較存儲(chǔ)的Token和當(dāng)前請(qǐng)求的Token是否一致
returntoken.equals(storedToken);
}
}

「redisutil類」

packageorg.example.utils;

importlombok.extern.slf4j.Slf4j;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.data.redis.connection.BitFieldSubCommands;
importorg.springframework.data.redis.core.*;
importorg.springframework.stereotype.Component;

importjava.util.*;
importjava.util.concurrent.TimeUnit;

@SuppressWarnings(value={"unchecked","rawtypes"})
@Component
@Slf4j
publicclassRedisCache
{
@Autowired
publicRedisTemplateredisTemplate;
@Autowired
privateStringRedisTemplatestringRedisTemplate;

/**
*緩存基本的對(duì)象，Integer、String、實(shí)體類等
*
*@paramkey緩存的鍵值
*@paramvalue緩存的值
*/
publicvoidsetCacheObject(finalStringkey,finalTvalue)
{
redisTemplate.opsForValue().set(key,value);
}

/**
*緩存基本的對(duì)象，Integer、String、實(shí)體類等
*
*@paramkey緩存的鍵值
*@paramvalue緩存的值
*@paramtimeout時(shí)間
*@paramtimeUnit時(shí)間顆粒度
*/
publicvoidsetCacheObject(finalStringkey,finalTvalue,finalIntegertimeout,finalTimeUnittimeUnit)
{
redisTemplate.opsForValue().set(key,value,timeout,timeUnit);
}

/**
*設(shè)置有效時(shí)間
*
*@paramkeyRedis鍵
*@paramtimeout超時(shí)時(shí)間
*@returntrue=設(shè)置成功；false=設(shè)置失敗
*/
publicbooleanexpire(finalStringkey,finallongtimeout)
{
returnexpire(key,timeout,TimeUnit.SECONDS);
}
publicbooleanhasKey(finalStringkey)
{
returnBoolean.TRUE.equals(redisTemplate.hasKey(key));
}

/**
*設(shè)置有效時(shí)間
*
*@paramkeyRedis鍵
*@paramtimeout超時(shí)時(shí)間
*@paramunit時(shí)間單位
*@returntrue=設(shè)置成功；false=設(shè)置失敗
*/
publicbooleanexpire(finalStringkey,finallongtimeout,finalTimeUnitunit)
{
returnredisTemplate.expire(key,timeout,unit);
}

/**
*獲得緩存的基本對(duì)象。
*
*@paramkey緩存鍵值
*@return緩存鍵值對(duì)應(yīng)的數(shù)據(jù)
*/
publicTgetCacheObject(finalStringkey)
{
ValueOperationsoperation=redisTemplate.opsForValue();
returnoperation.get(key);
}

/**
*刪除單個(gè)對(duì)象
*
*@paramkey
*/
publicbooleandeleteObject(finalStringkey)
{
returnredisTemplate.delete(key);
}

/**
*刪除集合對(duì)象
*
*@paramcollection多個(gè)對(duì)象
*@return
*/
publiclongdeleteObject(finalCollectioncollection)
{
returnredisTemplate.delete(collection);
}

/**
*緩存List數(shù)據(jù)
*
*@paramkey緩存的鍵值
*@paramdataList待緩存的List數(shù)據(jù)
*@return緩存的對(duì)象
*/
publiclongsetCacheList(finalStringkey,finalListdataList)
{
Longcount=redisTemplate.opsForList().rightPushAll(key,dataList);
returncount==null?0:count;
}

/**
*獲得緩存的list對(duì)象
*
*@paramkey緩存的鍵值
*@return緩存鍵值對(duì)應(yīng)的數(shù)據(jù)
*/
publicListgetCacheList(finalStringkey)
{
returnredisTemplate.opsForList().range(key,0,-1);
}

/**
*緩存Set
*
*@paramkey緩存鍵值
*@paramdataSet緩存的數(shù)據(jù)
*@return緩存數(shù)據(jù)的對(duì)象
*/
publicBoundSetOperationssetCacheSet(finalStringkey,finalSetdataSet)
{
BoundSetOperationssetOperation=redisTemplate.boundSetOps(key);
Iteratorit=dataSet.iterator();
while(it.hasNext())
{
setOperation.add(it.next());
}
returnsetOperation;
}

/**
*獲得緩存的set
*
*@paramkey
*@return
*/
publicSetgetCacheSet(finalStringkey)
{
returnredisTemplate.opsForSet().members(key);
}

/**
*緩存Map
*
*@paramkey
*@paramdataMap
*/
publicvoidsetCacheMap(finalStringkey,finalMapdataMap)
{
if(dataMap!=null){
redisTemplate.opsForHash().putAll(key,dataMap);
}
}

/**
*獲得緩存的Map
*
*@paramkey
*@return
*/
publicMapgetCacheMap(finalStringkey)
{
returnredisTemplate.opsForHash().entries(key);
}

/**
*往Hash中存入數(shù)據(jù)
*
*@paramkeyRedis鍵
*@paramhKeyHash鍵
*@paramvalue值
*/
publicvoidsetCacheMapValue(finalStringkey,finalStringhKey,finalTvalue)
{
redisTemplate.opsForHash().put(key,hKey,value);
}

/**
*獲取Hash中的數(shù)據(jù)
*
*@paramkeyRedis鍵
*@paramhKeyHash鍵
*@returnHash中的對(duì)象
*/
publicTgetCacheMapValue(finalStringkey,finalStringhKey)
{
HashOperationsopsForHash=redisTemplate.opsForHash();
returnopsForHash.get(key,hKey);
}

/**
*刪除Hash中的數(shù)據(jù)
*
*@paramkey
*@paramhkey
*/
publicvoiddelCacheMapValue(finalStringkey,finalStringhkey)
{
HashOperationshashOperations=redisTemplate.opsForHash();
hashOperations.delete(key,hkey);
}

/**
*獲取多個(gè)Hash中的數(shù)據(jù)
*
*@paramkeyRedis鍵
*@paramhKeysHash鍵集合
*@returnHash對(duì)象集合
*/
publicListgetMultiCacheMapValue(finalStringkey,finalCollection