1使用背景

在實際項目中其中一部分邏輯可能會因為調(diào)用了外部服務(wù)或者等待鎖等情況下出現(xiàn)不可預(yù)料的異常，在這個時候我們可能需要對調(diào)用這部分邏輯進行重試，代碼里面主要就是使用for循環(huán)寫一大坨重試的邏輯，各種硬編碼，各種辣眼睛的補丁。

特別是針對重試的邏輯，到處都有。所以我決定用一個重試組件spring-retry優(yōu)化一波。它的出現(xiàn)，解決掉這部分丑陋的代碼！

這個組件的源碼地址如下：https://github.com/spring-projects/spring-retry

廢話不多說，直接上代碼吧！

2開始上代碼

首先引入依賴：

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
    <version>1.3.2</version>
</dependency>

由于該組件是依賴于 AOP 給你的，所以還需要引入這個依賴（如果你其他 jar 包中引用過了，當然也就不需要再次引用了）：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-aop</artifactId>
    <version>2.6.1</version>
</dependency>

開啟重試：

@SpringBootApplication
@EnableRetry
public class ApplicationStarter {
  public static void main(String[] args) {
  SpringApplication.run(ApplicationStarter.class);
  }
}

Controller層

@RestController
public class TestController {
@Autowired
private IRecursiveCallService recursiveCallService;
 
    @GetMapping("test2")
    public Object test2() {
        return recursiveCallService.testService();
    }
}

Service層

public interface IRecursiveCallService {
    /**
     * 測試service
     *
     * @return
     */
    List<Integer> testService();
}

Service層具體實現(xiàn)

@Service
public class RecursiveCallServiceImpl implements IRecursiveCallService {
 
    @Override
    @Retryable(recover = "testService3")
    public List<Integer> testService() {
        System.out.println("到此一游！");
        System.out.println(1 / 0);
        return null;
    }
 
    @Recover
    public List<String> testService1() {
        System.out.println("錯誤的返回");
        return Collections.singletonList("S");
    }
 
    @Recover
    public List<Integer> testService2(String i) {
        System.out.println("正確的返回");
        return Collections.singletonList(1);
    }
 
    @Recover
    public List<Integer> testService3() {
        System.out.println("正確的返回2");
        return Collections.singletonList(2);
    }
}

3@Retryable注解重要屬性解析

• recover: 此類中用于恢復(fù)的方法的名稱。方法必須用 {@link Recover} 注釋標記。
• value: 可重試的異常類型。包括（）的同義詞。默認為空（如果 excludes 也為空，則重試所有異常）。
• exclude: 不可重試的異常類型。默認為空（如果包含也為空，則重試所有異常）。如果 include 為空但 excludes 不是，則重試所有未排除的異常
• maxAttempts: 方法重試調(diào)用次數(shù)，默認3次
• backoff: 指定用于重試此操作的其他屬性

4@backoff注解

• value：重試之間間隔時間
• delay：重試之間的等待時間(以毫秒為單位)
• maxDelay：重試之間的最大等待時間(以毫秒為單位)
• multiplier：指定延遲的倍數(shù)
• delayExpression：重試之間的等待時間表達式
• maxDelayExpression：重試之間的最大等待時間表達式
• multiplierExpression：指定延遲的倍數(shù)表達式
• random：隨機指定延遲時間

5@Recover注解

主要作用是標記方法為一個重試方法的補償方法?。。?/p>

6注意事項

方法重試依賴于 spring 注入，所以調(diào)用的方法的類必須是被spring管理的，然后通過 @Autowired 或 @Resource 引入使用，不然不會生效

方法重試的前提是方法拋出了異常，在方法執(zhí)行出現(xiàn)了異常且沒有被捕獲的情況下重試

方法重試需要在方法上面加上注解 @Retryable

方法重試的補償方法上面必須攜帶@Recover注解

@Recover方法需要和@Retryable方法在同一個類中才能生效@Recover方法(@Recover方法在父類中也可以生效)

使用@Retryable注解，如果類中沒有被@Recover標示的方法，無論是否使用 recover 屬性都拋出原有異常

使用@Retryable注解同時 recover 屬性不是空，如果類中有@Recover標示的方法，但是標示的方法不是 recover 指定的方法，拋出ExhaustedRetryException異常

使用@Retryable注解同時 recover 屬性不是空，同時方法有注解@Recover，但是補償方法的參數(shù)不是當前異常或者異常的父類，拋出ExhaustedRetryException 異常

使用@Retryable注解不使用 recover 屬性，如果類中被@Recover標示的方法有和原方法返回值一樣的，使用當前被@Recover標示的方法（此時方法參數(shù)可隨意，但是不能是除開當前異常的類及父類的異常類）

總結(jié)

到此這篇關(guān)于使用注解@Recover優(yōu)化丑陋的循環(huán)的文章就介紹到這了,更多相關(guān)注解@Recover優(yōu)化循環(huán)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論