日日操夜夜添-日日操影院-日日草夜夜操-日日干干-精品一区二区三区波多野结衣-精品一区二区三区高清免费不卡

公告:魔扣目錄網(wǎng)為廣大站長(zhǎng)提供免費(fèi)收錄網(wǎng)站服務(wù),提交前請(qǐng)做好本站友鏈:【 網(wǎng)站目錄:http://www.ylptlb.cn 】, 免友鏈快審服務(wù)(50元/站),

點(diǎn)擊這里在線咨詢客服
新站提交
  • 網(wǎng)站:51998
  • 待審:31
  • 小程序:12
  • 文章:1030137
  • 會(huì)員:747

前言

小黑在開(kāi)發(fā)中遇到個(gè)問(wèn)題,我負(fù)責(zé)的模塊需要調(diào)用某個(gè)三方服務(wù)接口查詢信息,查詢結(jié)果直接影響后續(xù)業(yè)務(wù)邏輯的處理;

這個(gè)接口偶爾會(huì)因網(wǎng)絡(luò)問(wèn)題出現(xiàn)超時(shí),導(dǎo)致我的業(yè)務(wù)邏輯無(wú)法繼續(xù)處理;

這個(gè)問(wèn)題該如何解決呢?,小黑首先想到的就是重試嘛,如果失敗了就再調(diào)用一次。

問(wèn)題來(lái)了,如果又失敗了呢?接著重試嘛。我們循環(huán)處理,比如循環(huán)5次,全失敗則任務(wù)服務(wù)不可用,結(jié)束調(diào)用。

如果我又想著5次調(diào)用間隔一段時(shí)間呢?第一次先隔1秒,然后3秒,然后5秒呢?

小黑發(fā)現(xiàn)事情沒(méi)那么簡(jiǎn)單,如果自己搞容易出BUG呀。

Guava Retryer輕松實(shí)現(xiàn)接口重試

 

轉(zhuǎn)念一想,這個(gè)常見(jiàn)挺常見(jiàn),網(wǎng)上應(yīng)該有輪子呀,找找看。一不小心就讓我給找著啦,哈哈。

Guava Retryer

This is a small extension to google’s Guava library to allow for the creation of configurable retrying strategies for an arbitrary function call, such as something that talks to a remote service with flaky uptime.

使用Guava Retryer你可以自定義來(lái)執(zhí)行重試,同時(shí)也可以監(jiān)控每次重試的結(jié)果和行為,最重要的基于 Guava 風(fēng)格的重試方式真的很方便。

引入依賴

<dependency>
      <groupId>com.github.rholder</groupId>
      <artifactId>guava-retrying</artifactId>
      <version>2.0.0</version>
</dependency>

快速開(kāi)始

Callable<Boolean> callable = new Callable<Boolean>() {
    public Boolean call() throws Exception {
        return true; // do something useful here
    }
};

Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
    .retryIfResult(Predicates.<Boolean>isNull()) // callable返回null時(shí)重試
    .retryIfExceptionOfType(IOException.class) // callable拋出IOException重試
    .retryIfRuntimeException() // callable拋出RuntimeException重試
    .withStopStrategy(StopStrategies.stopAfterAttempt(3)) // 重試3次后停止
    .build();
try {
    retryer.call(callable);
} catch (RetryException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    e.printStackTrace();
}

在Callable的call()方法返回null,拋出IOException或者RuntimeException時(shí)會(huì)重試; 將在嘗試重試3次后停止,并拋出包含上次失敗嘗試信息的RetryException; 如果call()方法中彈出任何其他異常,它將被包裝并在ExecutionException中重新調(diào)用。

指數(shù)退避(Exponential Backoff)

根據(jù)wiki上對(duì)Exponential backoff的說(shuō)明,指數(shù)補(bǔ)償是一種通過(guò)反饋,成倍地降低某個(gè)過(guò)程的速率,以逐漸找到合適速率的算法。

在以太網(wǎng)中,該算法通常用于沖突后的調(diào)度重傳。根據(jù)時(shí)隙和重傳嘗試次數(shù)來(lái)決定延遲重傳。

在c次碰撞后(比如請(qǐng)求失敗),會(huì)選擇0和2^c - 1之間的隨機(jī)值作為時(shí)隙的數(shù)量。

對(duì)于第1次碰撞來(lái)說(shuō),每個(gè)發(fā)送者將會(huì)等待0或1個(gè)時(shí)隙進(jìn)行發(fā)送。 而在第2次碰撞后,發(fā)送者將會(huì)等待0到3( 由2^2 -1 計(jì)算得到)個(gè)時(shí)隙進(jìn)行發(fā)送。 而在第3次碰撞后,發(fā)送者將會(huì)等待0到7( 由2^3 - 1 計(jì)算得到)個(gè)時(shí)隙進(jìn)行發(fā)送。 以此類(lèi)推……

Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
        .retryIfExceptionOfType(IOException.class)
        .retryIfRuntimeException()
        .withWaitStrategy(WaitStrategies.exponentialWait(100, 5, TimeUnit.MINUTES)) // 指數(shù)退避
        .withStopStrategy(StopStrategies.neverStop()) // 永遠(yuǎn)不停止重試
        .build();

創(chuàng)建一個(gè)永遠(yuǎn)重試的重試器,在每次重試失敗后以指數(shù)級(jí)退避間隔遞增,直到最多5分鐘。5分鐘后,從那時(shí)起每隔5分鐘重試一次。

斐波那契退避(Fibonacci Backoff)

斐波那契數(shù)列指的是這樣一個(gè)數(shù)列:

0,1,1,2,3,5,8,13,21,34,55,89...

這個(gè)數(shù)列從第3項(xiàng)開(kāi)始,每一項(xiàng)都等于前兩項(xiàng)之和。

Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
        .retryIfExceptionOfType(IOException.class)
        .retryIfRuntimeException()
        .withWaitStrategy(WaitStrategies.fibonacciWait(100, 2, TimeUnit.MINUTES)) // 斐波那契退避
        .withStopStrategy(StopStrategies.neverStop())
        .build();

創(chuàng)建一個(gè)永遠(yuǎn)重試的重試器,在每次重試失敗后以增加斐波那契退避間隔的方式等待,直到最多2分鐘。2分鐘后,從那時(shí)起每隔2分鐘重試一次。

與指數(shù)退避策略類(lèi)似,斐波那契退避策略遵循一種模式,即在每次嘗試失敗后等待的時(shí)間越來(lái)越長(zhǎng)。

對(duì)于這兩種策略的性能英國(guó)利茲大學(xué)專門(mén)做過(guò)性能測(cè)試,相比指數(shù)退避策略,斐波那契退避策略可能性能更好,吞吐量可能也更好。

重試監(jiān)聽(tīng)器

當(dāng)重試發(fā)生時(shí),如果需要額外做一些動(dòng)作,比如發(fā)送郵件通知之類(lèi)的,可以通過(guò)RetryListener,Guava Retryer在每次重試之后會(huì)自動(dòng)回調(diào)監(jiān)聽(tīng)器,并且支持注冊(cè)多個(gè)監(jiān)聽(tīng)。

@Slf4j
class diyRetryListener<Boolean> implements RetryListener {
    @Override
    public <Boolean> void onRetry(Attempt<Boolean> attempt) {
        log.info("重試次數(shù):{}",attempt.getAttemptNumber());
        log.info("距離第一次重試的延遲:{}",attempt.getDelaySinceFirstAttempt());
        if(attempt.hasException()){
            log.error("異常原因:",attempt.getExceptionCause());
        }else {
            System.out.println("正常處理結(jié)果:{}" + attempt.getResult());
        }
    }
}

定義監(jiān)聽(tīng)器之后,需要在Retryer中進(jìn)行注冊(cè)。

        Retryer<Boolean> retryer = RetryerBuilder.<Boolean>newBuilder()
                .retryIfResult(Predicates.<Boolean>isNull()) // callable返回null時(shí)重試
                .retryIfExceptionOfType(IOException.class) // callable拋出IOException重試
                .retryIfRuntimeException() // callable拋出RuntimeException重試
                .withStopStrategy(StopStrategies.stopAfterAttempt(3)) // 重試3次后停止
                .withRetryListener(new DiyRetryListener<Boolean>()) // 注冊(cè)監(jiān)聽(tīng)器
                .build();

小結(jié)

Guava Retryer不光在重試策略上支持多種選擇,并且將業(yè)務(wù)邏輯的處理放在Callable中,和重試處理邏輯分開(kāi),實(shí)現(xiàn)了解耦,這比小黑自己去寫(xiě)循環(huán)處理要優(yōu)秀太多啦,Guava確實(shí)強(qiáng)大。

分享到:
標(biāo)簽:重試 接口
用戶無(wú)頭像

網(wǎng)友整理

注冊(cè)時(shí)間:

網(wǎng)站:5 個(gè)   小程序:0 個(gè)  文章:12 篇

  • 51998

    網(wǎng)站

  • 12

    小程序

  • 1030137

    文章

  • 747

    會(huì)員

趕快注冊(cè)賬號(hào),推廣您的網(wǎng)站吧!
最新入駐小程序

數(shù)獨(dú)大挑戰(zhàn)2018-06-03

數(shù)獨(dú)一種數(shù)學(xué)游戲,玩家需要根據(jù)9

答題星2018-06-03

您可以通過(guò)答題星輕松地創(chuàng)建試卷

全階人生考試2018-06-03

各種考試題,題庫(kù),初中,高中,大學(xué)四六

運(yùn)動(dòng)步數(shù)有氧達(dá)人2018-06-03

記錄運(yùn)動(dòng)步數(shù),積累氧氣值。還可偷

每日養(yǎng)生app2018-06-03

每日養(yǎng)生,天天健康

體育訓(xùn)練成績(jī)?cè)u(píng)定2018-06-03

通用課目體育訓(xùn)練成績(jī)?cè)u(píng)定