欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java利用配置重試策略解決超時問題

 更新時間:2022年10月14日 11:15:20   作者:指北君  
在web應(yīng)用中,由于網(wǎng)絡(luò)原因或其他不可預(yù)測的原因,應(yīng)用間會出現(xiàn)調(diào)用失敗的情形,通過配置重試策略可以有效解決外在原因?qū)е碌南到y(tǒng)故障。本文就來詳細說說如何利用配置重試策略解決超時問題

在web應(yīng)用中,由于網(wǎng)絡(luò)原因或其他不可預(yù)測的原因,應(yīng)用間會出現(xiàn)調(diào)用失敗的情形,通過配置重試策略可以有效解決外在原因?qū)е碌南到y(tǒng)故障。

使用場景

  • 微服務(wù)間各個服務(wù)模塊間的調(diào)用
  • 第三方模塊遠程交易調(diào)用
  • 非業(yè)務(wù)異常導(dǎo)致可能失敗的情況

示例

構(gòu)建Retryer

private?Retryer?retryer?=?RetryerBuilder.newBuilder()
????????.retryIfException()?//?異常時重試
????????.retryIfResult(input?->?input!=null?&&?input?instanceof?Boolean?&&?!Boolean.valueOf((Boolean)?input))?//?返回值為false時重試
????????//?對應(yīng)Future獲取超時時間
????????.withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(4,?TimeUnit.SECONDS,Executors.newFixedThreadPool(2)))?//重試次數(shù)限制
????????.withRetryListener(new?RetryListener()?{?//?重試執(zhí)行邏輯
????????????@Override
????????????public?<V>?void?onRetry(Attempt<V>?attempt)?{
????????????????log.info("onRetry ->?重試次數(shù):{},距第一次重試時長:{}",?attempt.getAttemptNumber(),attempt.getDelaySinceFirstAttempt());
????????????????if(attempt.hasException()){?//?是否異常導(dǎo)致重試
????????????????????Throwable?exception?=?attempt.getExceptionCause();?//?執(zhí)行的異常
????????????????????log.info("異常:{}",?exception);
????????????????}
????????????????if(attempt.hasResult()){?//?是否有返回
????????????????????V?result?=?attempt.getResult();
????????????????????log.info("返回:{}",result);
????????????????}
????????????}
????????})
????????//?控制每次重試間隔時間,如果AttemptTimeLimiter設(shè)置多線程
????????.withWaitStrategy(WaitStrategies.fixedWait(3,TimeUnit.SECONDS))?//?等待策略
????????.withBlockStrategy(BlockStrategies.threadSleepStrategy())?//?阻塞策略
????????//
????????.withStopStrategy(StopStrategies.stopAfterAttempt(5))?//?停止策略
????????.build();

使用Retryer讓業(yè)務(wù)代碼擁有重試能力

前兩次執(zhí)行時模擬返回false,則會執(zhí)行重試;當(dāng)?shù)?次時,正常執(zhí)行業(yè)務(wù)代碼并返回true,結(jié)束重試

@Test
public?void?retryWhenResult()?throws?ExecutionException,?RetryException?{
???retryer.call(()?->?{
???????if(counter.incrementAndGet()?==?3){//?模擬前2此返回false,觸發(fā)重試
???????????log.info("?執(zhí)行業(yè)務(wù)代碼:{}次",counter.get());
???????????return?true;
???????}
???????return?false;?
???});
}

模擬前3次出現(xiàn)異常,則會執(zhí)行重試;當(dāng)?shù)?次時,正常執(zhí)行業(yè)務(wù)代碼,結(jié)束重試

@Test
public?void?retryWhenException()?throws?ExecutionException,?RetryException?{
????retryer.call(()?->?{
????????if(?counter.getAndIncrement()?==?3?){//?模擬前5此出現(xiàn)異常,觸發(fā)重試
????????????return?counter;
????????}
????????log.info("?執(zhí)行業(yè)務(wù)代碼:?{}次",?counter.get());
?????????throw?new?RuntimeException("ERROR");?
????});
}

模擬前5此出現(xiàn)異常,由于Retryer配置重試次數(shù)為5,則最終業(yè)務(wù)代碼不會執(zhí)行

@Test
public?void?retryWhenResultOnFailure()?throws?ExecutionException,?RetryException?{
????retryer.call(()?->?{
????????if(counter.incrementAndGet()?==?8){//?模擬前7此返回false,由于配置重試5次,因此最終失敗
????????????log.info("?執(zhí)行業(yè)務(wù)代碼:{}次",counter.get());
????????????return?true;
????????}
????????return?false;
????});
}

執(zhí)行流程

執(zhí)行流程

通過RetryerBuilder構(gòu)建Retryer,調(diào)用Retryer#call,封裝業(yè)務(wù)代碼為其回調(diào)函數(shù)

  • 開始循環(huán)執(zhí)行
  • 由AttemptTimeLimiter#call執(zhí)行回調(diào)函數(shù)
  • 將結(jié)果封裝為Attempt,包括兩種類型ResultAttempt,ExceptionAttempt。如果成功,記錄執(zhí)行結(jié)果、持續(xù)時長;如果失敗,記錄異常、持續(xù)時長
  • 執(zhí)行監(jiān)聽RetyrListener#onRetry,可以配置多個監(jiān)聽
  • 執(zhí)行拒絕斷言Predicate,根據(jù)返回值、執(zhí)行異常、返回異常類型判斷是否終止重試
  • 如果滿足條件,則繼續(xù)重試;否則結(jié)束重試,并返回Attempt包含回調(diào)結(jié)果
  • 根據(jù)終止策略StopStrategy判斷是否終止重試
  • 根據(jù)等待策略WaitStrategy獲取等待時長
  • 根據(jù)阻塞策略BlockStrategy與上一步等待時長阻塞重試,如果出現(xiàn)異常則拋出RetryException
  • 重復(fù)執(zhí)行以上邏輯

配置

構(gòu)建Retryer主要通過RetryerBuilder.newBuilder()實現(xiàn),其相關(guān)配置如下:

配置策略名稱描述
AttemptTimeLimiters 任務(wù)執(zhí)行時長限制 
 NoAttemptTimeLimit無時長限制 
 FixedAttemptTimeLimit固定時長限制 
WaitStrategies 重試等待策略 
 ExponentialWaitStrategy指數(shù)等待策略按指數(shù)增加重試間隔時長,比如第一次2^1100、2^2100、2^3*100...最多300000
 FibonacciWaitStrategy斐波那契等待策略1100、1100、2100、3100、5*100...
 FixedWaitStrategy固定時長等待策略按配置的固定間隔時間
 RandomWaitStrategy隨機時長等待策略隨機間隔時間,可以設(shè)置隨機值范圍
 IncrementingWaitStrategy遞增等待策略根據(jù)配置的初始值與增量進行累加時間
 ExceptionWaitStrategy異常等待策略根據(jù)異常類型指定等待時間
 CompositeWaitStrategy復(fù)合等待策略可配置多個策略進行組合
BlockStrategies 阻塞策略根據(jù)WaitStrategies獲取阻塞時長
 ThreadSleepStrategy線程等等策略通過Thread.sleet()實現(xiàn)
StopStrategies 重試停止策略 
 NeverStopStrategy無限制策略 
 StopAfterAttemptStrategy限定次數(shù)策略 
 StopAfterDelayStrategy限定時長策略 
 NoAttemptTimeLimit限定次數(shù) 

注意

AttemptTimeLimiter中的FixedAttemptTimeLimit依賴于guava中的SimpleTimeLimiter,但是在guava高版本中該類已經(jīng)成了私有類

總結(jié)

Guava Retrying模塊能夠通過簡單的將代碼實現(xiàn)業(yè)務(wù)邏輯重試的功能,并且其配置中包含了重試的次數(shù)、時長控制、重試阻塞、終止策略等等, 在項目中是非常常用的一項技術(shù)。

到此這篇關(guān)于Java利用配置重試策略解決超時問題的文章就介紹到這了,更多相關(guān)Java配置重試策略解決超時內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 淺談在Spring中如何使用數(shù)據(jù)源(DBCP、C3P0、JNDI)

    淺談在Spring中如何使用數(shù)據(jù)源(DBCP、C3P0、JNDI)

    這篇文章主要介紹了淺談在Spring中如何使用數(shù)據(jù)源(DBCP、C3P0、JNDI),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-10-10
  • Dubbo+zookeeper?最簡單的分布式搭建方案

    Dubbo+zookeeper?最簡單的分布式搭建方案

    這篇文章主要介紹了Dubbo+zookeeper?最簡單的分布式搭建,本例采用?dubbo+zookeeper?搭建分布式系統(tǒng),環(huán)境?jdk1.8,需要的朋友可以參考下
    2022-04-04
  • Java實現(xiàn)多線程大批量同步數(shù)據(jù)(分頁)

    Java實現(xiàn)多線程大批量同步數(shù)據(jù)(分頁)

    這篇文章主要為大家詳細介紹了Java實現(xiàn)多線程大批量同步數(shù)據(jù)(分頁),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-08-08
  • MyBatis-Plus之邏輯刪除的實現(xiàn)

    MyBatis-Plus之邏輯刪除的實現(xiàn)

    這篇文章主要介紹了MyBatis-Plus之邏輯刪除的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-11-11
  • 如何在springMVC的controller中獲取request

    如何在springMVC的controller中獲取request

    這篇文章主要介紹了如何在springMVC的controller中獲取request,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-12-12
  • Java實現(xiàn)學(xué)生選課管理系統(tǒng)

    Java實現(xiàn)學(xué)生選課管理系統(tǒng)

    這篇文章主要為大家詳細介紹了Java實現(xiàn)學(xué)生選課管理系統(tǒng),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-07-07
  • Java別說取余(%)運算簡單你真的會嗎

    Java別說取余(%)運算簡單你真的會嗎

    這篇文章主要介紹了Java別說取余(%)運算簡單你真的會嗎,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-07-07
  • java獲取IP和IP的歸屬地的方法實踐

    java獲取IP和IP的歸屬地的方法實踐

    在Java中獲取IP地址通常指的是獲取本地機器的IP地址或者通過某種方式獲取的遠程IP地址,本文就來詳細的介紹一下,感興趣的可以了解一下
    2024-05-05
  • java接口返回參數(shù)按照請求參數(shù)進行排序方式

    java接口返回參數(shù)按照請求參數(shù)進行排序方式

    這篇文章主要介紹了java接口返回參數(shù)按照請求參數(shù)進行排序方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-09-09
  • Java使用橋接模式實現(xiàn)開關(guān)和電燈照明功能詳解

    Java使用橋接模式實現(xiàn)開關(guān)和電燈照明功能詳解

    這篇文章主要介紹了Java使用橋接模式實現(xiàn)開關(guān)和電燈照明功能,較為詳細的講述了橋接模式的概念、原理并結(jié)合實例形式分析了Java使用橋接模式實現(xiàn)開關(guān)和電燈照明功能相關(guān)操作步驟與注意事項,需要的朋友可以參考下
    2018-05-05

最新評論