前言
在很多場景中,我們需要“重試”伟端,重試意味著反復(fù)執(zhí)行一段代碼直至成功,或者重試多次無果后標(biāo)記失敗∏匦В“重試”的出發(fā)點(diǎn)有可能是為了保持狀態(tài)的一致,也有可能是為了容忍被調(diào)用方短暫的不可用云芦±謇蓿“重試”邏輯有可能是同步執(zhí)行,也有可能是異步執(zhí)行嚼吞。異步有可能是將信息存入數(shù)據(jù)庫定時任務(wù)重試盒件,也有可能是通過異步消息,利用消息的重試機(jī)制舱禽,等等炒刁,不一而論。
把“重試”邏輯進(jìn)行抽象的目前知道的有兩個誊稚,一個Spring Retry翔始,另外一個是Guava Retrier。本文的目的一方面是為了簡單記錄下Spring Retry的原理里伯;另一方面是為了學(xué)習(xí)Spring Retry是如何對“重試”方方面面進(jìn)行抽象的城瞎。
簡單使用
簡單使用部分請參考:官方文檔
Spring Retry提倡以注解的方式對方法進(jìn)行重試,重試邏輯是同步執(zhí)行的疾瓮,重試的“失敗”針對的是Throwable脖镀,如果你要以返回值的某個狀態(tài)來判定是否需要重試,可能只能通過自己判斷返回值然后顯式拋出異常了爷贫。
Spring 對于Retry的抽象
“抽象”是每個程序員必備的素質(zhì)认然。對于資質(zhì)平平的我來說,沒有比模仿與理解優(yōu)秀源碼更好地進(jìn)步途徑了吧漫萄。為此卷员,我將其核心邏輯重寫了一遍...下面就看看Spring Retry對于“重試”的抽象。
“重試”邏輯
while(someCondition()) {
try{
doSth();
break;
} catch(Throwable th) {
modifyCondition();
wait();
}
}
if(stillFail) {
doSthWhenStillFail();
}
同步重試代碼基本可以表示為上述腾务,但是Spring Retry對其進(jìn)行了非常優(yōu)雅地抽象毕骡,雖然主要邏輯不變,但是看起來卻是舒服多了。主要的接口抽象如下圖所示:
- RetryCallback: 封裝你需要重試的業(yè)務(wù)邏輯(上文中的doSth)
- RecoverCallback:封裝在多次重試都失敗后你需要執(zhí)行的業(yè)務(wù)邏輯(上文中的doSthWhenStillFail)
- RetryContext: 重試語境下的上下文未巫,可用于在多次Retry或者Retry 和Recover之間傳遞參數(shù)或狀態(tài)(在多次doSth或者doSth與doSthWhenStillFail之間傳遞參數(shù))
- RetryOperations : 定義了“重試”的基本框架(模板)窿撬,要求傳入RetryCallback,可選傳入RecoveryCallback叙凡;
- RetryListener:典型的“監(jiān)聽者”劈伴,在重試的不同階段通知“監(jiān)聽者”(例如doSth,wait等階段時通知)
- RetryPolicy : 重試的策略或條件握爷,可以簡單的進(jìn)行多次重試跛璧,可以是指定超時時間進(jìn)行重試(上文中的someCondition)
- BackOffPolicy: 重試的回退策略,在業(yè)務(wù)邏輯執(zhí)行發(fā)生異常時新啼。如果需要重試追城,我們可能需要等一段時間(可能服務(wù)器過于繁忙,如果一直不間隔重試可能拖垮服務(wù)器)燥撞,當(dāng)然這段時間可以是0座柱,也可以是固定的,可以是隨機(jī)的(參見tcp的擁塞控制算法中的回退策略)物舒∩矗回退策略在上文中體現(xiàn)為wait();
- RetryTemplate :RetryOperations的具體實(shí)現(xiàn)茶鉴,組合了RetryListener[]锋玲,BackOffPolicy,RetryPolicy涵叮。
看到上文中的XXXOperations(包括其中的execute()方法),XXXCallback,XXXTemplate是不是感覺很熟悉伞插?沒錯割粮,JDBCTemplate也是用的這一套抽象命名!
總結(jié)
簡單記錄了對于Spring Retry的學(xué)習(xí)媚污,備忘舀瓢!