在實際工作中，重試機制是一個很常見的場景，比如：發(fā)送消息失敗，下載網(wǎng)絡文件失敗等…，因為這些錯誤可能是網(wǎng)絡波動造成的，等待一些延遲就能成功處理。我們通常會使用try/catch、while循環(huán)等進行相關處理，但是這樣看起來比較臃腫復雜，且不好看。于是就有了spring提供的重試模塊—— @Retryable

@Retryable 簡介

一個spring提供的重試機制注解模塊，簡單的注解，提供有效的幫助。雖然有一些限制，但是在大多數(shù)情況下還是可以很好的解決我們的問題——優(yōu)雅，永不過時。

使用步驟

1.引入依賴

gradle 引入方式如下

implementation 'org.springframework.retry:spring-retry:1.3.3'

maven 引入方式

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

2.啟用@Retryable

在項目啟動類上加上注解@EnableRetry

@SpringBootApplication
@EnableRetry
public class NfljApplication {

? ? public static void main(String[] args) {
? ? ? ? SpringApplication.run(NfljApplication.class, args);
? ? }
}

3.添加@Retryable注解

新建service方法，添加如下方法

public interface CodeService {
    String code() throws Exception;
}

新建實現(xiàn)類，在我們要使用的方法上添加@Retryable注解

在同一個實現(xiàn)類下加上回調方法@Recover（如果不需要回調方法，可以直接不寫回調方法），實現(xiàn)的效果是，重試次數(shù)完了后，如果還是沒成功沒符合業(yè)務判斷，就拋出異常

@Service
public class CodeServiceImpl implements CodeService {

? ? @Override
? ? @Retryable(value = Exception.class,maxAttempts = 3,backoff = @Backoff(delay = 1000,multiplier = 1.5))
? ? public String code() throws Exception {
? ? ? ? System.out.println("開始調用----------");
? ? ? ? if (0 == 0) {
? ? ? ? ? ? throw new Exception("調用出錯啦?。?！");
? ? ? ? }
? ? ? ? System.out.println("成功調用");
? ? ? ? return "200";
? ? }
? ??
? ? /**
? ? ?* 回調方法
? ? ?*
? ? ?* @return
? ? ?*/
? ? @Recover
? ? public String recover(Exception e) {
? ? ? ? System.out.println("---------------回調方法執(zhí)行----------------");
? ? ? ? //記錄日志到數(shù)據(jù)庫
? ? ? ? return "500";
? ? }
}

4.測試

編寫測試類進行測試

    @Autowired
    private CodeService codeService;
    @Test
    void test4() throws Exception {
        String code = codeService.code();
        System.out.println(code);
    }

測試的打印結果如下，可以證明，完美的進行了重試

開始調用----------
開始調用----------
開始調用----------
---------------回調方法執(zhí)行----------------
500

注意事項

1. @Retryable注解參數(shù)

value：拋出我們指定異常才會重試
include：和value一樣，默認為空，當exclude也為空時，默認所有異常
exclude：指定不處理的異常
maxAttempts：最大重試次數(shù)，默認3次，包括第一次請求也算在其中
backoff：重試等待策略，默認使用@Backoff，@Backoff的value默認為1000L
multiplier（指定延遲倍數(shù)）默認為0，表示固定暫停1秒后進行重試，如果把multiplier設置為1.5，則第一次重試為2秒，第二次為3秒，第三次為4.5秒。

2. @Recover 注解

方法的返回值必須與@Retryable方法一致
方法的第一個參數(shù)，必須是Throwable類型的，建議是與@Retryable配置的異常一致，其他的參數(shù)，需要哪個參數(shù)，寫進去即可
回調方法與重試方法寫在同一個實現(xiàn)類里面

最后

由于是基于AOP實現(xiàn)，所以不支持類里自調用方法，且需引入aop依賴

implementation 'org.springframework.boot:spring-boot-starter-aop:2.6.3'

如果重試失敗需要給@Recover注解的方法做后續(xù)處理，那這個重試的方法不能有返回值，只能是void
方法內不能使用try catch，只能往外拋異常
@Recover注解來開啟重試失敗后調用的方法(注意,需跟重處理方法在同一個類中)，此注解注釋的方法參數(shù)一定要是@Retryable拋出的異常，否則無法識別，可以在該方法中進行日志處理