• 冪等性
• 什么場景下需要用到冪等
• 冪等的實現(xiàn)原理
• 冪等的代碼實現(xiàn)
  • 冪等的使用

冪等性

今天我們來談?wù)勈裁词?code style="font-size:14px;padding:2px 4px;margin-right:2px;margin-left:2px;color:rgb(30,107,184);background-color:rgba(27,31,35,.05);font-family:'Operator Mono', Consolas, Monaco, Menlo, monospace;">冪等性？

引用百度百科的解析如下：

?

冪等（idempotent、idempotence）是一個數(shù)學(xué)與計算機學(xué)概念，常見于抽象代數(shù)中。

在編程中一個冪等操作的特點是其任意多次執(zhí)行所產(chǎn)生的影響均與一次執(zhí)行的影響相同。冪等函數(shù)，或冪等方法，是指可以使用相同參數(shù)重復(fù)執(zhí)行，并能獲得相同結(jié)果的函數(shù)。這些函數(shù)不會影響系統(tǒng)狀態(tài)，也不用擔(dān)心重復(fù)執(zhí)行會對系統(tǒng)造成改變。例如，“setTrue()”函數(shù)就是一個冪等函數(shù),無論多次執(zhí)行，其結(jié)果都是一樣的.更復(fù)雜的操作冪等保證是利用唯一交易號(流水號)實現(xiàn)。

?

這解析，確實有點長了，大家話看看就行了！！！(●'?'●)

那對于我們程序員來說，我們關(guān)心的更多是下面這些問題：

?

什么地方，什么場景下需要用到冪等？

冪等，我們需要怎么做，如何實現(xiàn)冪等呢？

?

基于 Spring Boot + MyBatis Plus + Vue & Element 實現(xiàn)的后臺管理系統(tǒng) + 用戶小程序，支持 RBAC 動態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

• 項目地址：https://github.com/YunaiV/ruoyi-vue-pro
• 視頻教程：https://doc.iocoder.cn/video/

什么場景下需要用到冪等

• 前端表單重復(fù)提交問題
• 用戶訂單支付問題
• 銀行業(yè)務(wù)辦理取號問題
• 用戶惡意進行調(diào)接口問題
• 接口超時重復(fù)提交問題
• MQ消息進行重復(fù)消費
• ...

當(dāng)然了，還有很多場景會用到冪等，這里咱們就不一一列舉出來了。

那我們要如何設(shè)計一個冪等功能呢，而且還是代碼非侵入式？

代碼非侵入式的意思，就是，我們的業(yè)務(wù)邏輯代碼，不需要處理冪等校驗的邏輯。

業(yè)務(wù)功能不處理？那交給誰處理呢？別著急，聽哥們一一道來。^_^

這里，要實現(xiàn)代碼非侵入式的冪等校驗，我們就要使用到切面編程了（@Aspect）

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 實現(xiàn)的后臺管理系統(tǒng) + 用戶小程序，支持 RBAC 動態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

• 項目地址：https://github.com/YunaiV/yudao-cloud
• 視頻教程：https://doc.iocoder.cn/video/

冪等的實現(xiàn)原理

在系統(tǒng)中一些接口需要增加冪等處理，冪等的概念是一個業(yè)務(wù)請求只能執(zhí)行一次。類似銀行業(yè)務(wù)辦理，首先需要取一個號，然后用戶使用這個號去柜臺辦理業(yè)務(wù)。這個號只能使用一次，如果過期或者已辦理這個號就無效了。

我們的冪等也是使用這種原理。

?

• 1.首先客戶端調(diào)用通過我們的系統(tǒng)獲取一個號，我們稱之為冪等號，這個號已經(jīng)存在我們的系統(tǒng)中。
• 2.客戶端使用這個號，調(diào)用我們的接口。
• 3.我們系統(tǒng)判斷這個號在我們的系統(tǒng)中已經(jīng)存在，如果存在則允許業(yè)務(wù)辦理，如果不存在，則表示這是一個非法的號，我們直接拋出異常。
• 4.當(dāng)業(yè)務(wù)處理完成，我們會將這個號從我們的系統(tǒng)中刪除掉。

?

好了，這實現(xiàn)步驟，也是十分清晰了呀！！！^_^

那么我們下面就來看代碼如何實現(xiàn)了

冪等的代碼實現(xiàn)

• 定義一個冪等處理接口

publicinterfaceIdempotence{
/**
*檢查是否存在冪等號
*@paramidempotenceId冪等號
*@return是否存在
*/
booleancheck(StringidempotenceId);

/**
*記錄冪等號
*@paramidempotenceId冪等號
*/
voidrecord(StringidempotenceId);

/**
*記錄冪等號
*@paramidempotenceId冪等號
*@paramtime過期時間
*/
voidrecord(StringidempotenceId,Integertime);

/**
*刪除冪等號
*@paramidempotenceId冪等號
*/
voiddelete(StringidempotenceId);

}

• 定義一個冪等處理接口實現(xiàn)類

@Component
publicclassRedisIdempotenceimplementsIdempotence{
@Autowired
privateRedisRepositoryredisRepository;

@Override
publicbooleancheck(StringidempotenceId){
returnredisRepository.exists(idempotenceId);
}

@Override
publicvoidrecord(StringidempotenceId){
redisRepository.set(idempotenceId,"1");
}

@Override
publicvoidrecord(StringidempotenceId,Integertime){
redisRepository.setExpire(idempotenceId,"1",time);
}

@Override
publicvoiddelete(StringidempotenceId){
redisRepository.del(idempotenceId);
}
}

?

這個實現(xiàn)類，咱們就用redis存儲這個冪等號 實現(xiàn)4個方法：

檢查是否存在冪等號

記錄冪等號

記錄冪等號（帶過期時間）

刪除冪等號

?

• 冪等工具類

@Component
publicclassIdempotenceUtil{
@Autowired
privateRedisRepositoryredisRepository;
/**
*生成冪等號
*@return
*/
publicStringgenerateId(){
Stringuuid=UUID.randomUUID().toString();
StringuId=Base64Util.encode(uuid).toLowerCase();
redisRepository.setExpire(uId,"1",1800);
returnuId;
}

/**
*從Header里面獲取冪等號
*@return
*/
publicStringgetHeaderIdempotenceId(){
ServletRequestAttributesattributes=(ServletRequestAttributes)RequestContextHolder.getRequestAttributes();
HttpServletRequestrequest=attributes.getRequest();
StringidempotenceId=request.getHeader("idempotenceId");
returnidempotenceId;
}
}

?

這個工具類，提供兩個方法。

1.生成一個冪等號，咱們就用uuid

2.從Header里面獲取冪等號

?

• 定義一個注解

/**
*接口增加冪等性
*/
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public@interfaceIdempotenceRequired{

}

• 切面

@Aspect
@Slf4j
@Component
publicclassIdempotenceSupportAdvice{
@Autowired
privateIdempotenceidempotence;
@Autowired
IdempotenceUtilidempotenceUtil;

/**
*攔截有@IdempotenceRequired注解的方法。
*/
@Pointcut("@annotation(xxx.xxx.IdempotenceRequired)")
publicvoididempotenceMethod(){}

@AfterThrowing(value="idempotenceMethod()()",throwing="e")
publicvoidafterThrowing(Throwablee){
if(!(einstanceofIdempotencyException)){
//從HTTPheader中獲取冪等號idempotenceId
StringidempotenceId=idempotenceUtil.getHeaderIdempotenceId();
idempotence.record(idempotenceId,1800);
}
}

@Around(value="idempotenceMethod()")
publicObjectaround(ProceedingJoinPointjoinPoint)throwsThrowable{
//從HTTPheader中獲取冪等號idempotenceId
StringidempotenceId=idempotenceUtil.getHeaderIdempotenceId();
if(StringUtils.isEmpty(idempotenceId)){
//不存在冪等號則不進行額外操作
returnjoinPoint.proceed();
}
//前置操作冪等號是否存在
booleanexisted=idempotence.check(idempotenceId);
if(!existed){
thrownewIdempotencyException("{success:false,message:"操作重復(fù)，請重新輸入冪等號重試！",data:-2}");
}
//刪除冪等號
idempotence.delete(idempotenceId);
Objectresult=joinPoint.proceed();

returnresult;
}
}

• 定義個controller

@RequestMapping("/idempotence")
publicclassIdempotenceController{
/**
*生成冪等號
*@return
*/
@GetMapping("/generateId")
publicJsonResultgenerateId(){
IdempotenceUtilidempotenceUtil=SpringUtil.getBean(IdempotenceUtil.class);
StringuId=idempotenceUtil.generateId();
returnJsonResult.success("成功生成！").setData(uId);
}
}

好了，實現(xiàn)的代碼，就是這些了，理解起來也是比較簡單，沒有過多復(fù)雜的邏輯。

接下來，就是如何使用的問題了，

這個使用，也是十分的簡單啦！！！

冪等的使用

「服務(wù)端：」

不是所有的方法都需要切面攔截 ，只有 IdempotenceRequired 注解的方法才會被攔截。

例如下面接口：

@IdempotenceRequired
@PostMapping("/getUsers")
publicJsonResultgetUsers(){

//執(zhí)行正常業(yè)務(wù)邏輯
...
}

在開發(fā)冪等接口時，只需要在方法上簡單增加一個 IdempotenceRequired 注解即可。

這基本上就是代碼非侵入式了呀！！！

「客戶端：」

服務(wù)端處理好后，在客戶端訪問接口的時候需要執(zhí)行以下步驟：

?

• 需要先獲取冪等號
• 然后將冪等號添加到請求頭中

?

• 1.獲取冪等號http://服務(wù)地址/idempotence/generateIdhttp://xn--zfry9hnb732h/idempotence/generateId

• 2.請求調(diào)用

?

往header中添加冪等號

?

好了，到這里冪等的實現(xiàn)，就已經(jīng)完成了！！！^_^

那我們就可以愉快的編寫代碼了！！！^_^