前言

作為后端程序員，我們的日常工作就是調用一些第三方服務，將數據存入數據庫，返回信息給前端。但你不能保證所有的事情一直都很順利。像有些第三方API，偶爾會出現超時。此時，我們要重試幾次，這取決于你的重試策略。

下面舉一個我在日常開發中多次看到的例子：

public interface OutSource {
    List;
}

@Service
public class OutSourceImpl implements OutSource {

    static Random random = new Random();
    @Override
    public List{
        //mock failure
        if (random.nextInt(2) == 1)
            throw new TimeOutException();
        return List.of(1, 2, 3);
    }
}


@Slf4j
@Service
public class ManuallyRetryService {

    @Autowired
    private OutSource outSource;

    public List{
        log.info("trigger time:{}", retryTimes);

        if (retryTimes > 3) {
            return List.of();
        }

        try {
            List

看看上面這段代碼，我認為它可以正常工作，當retryTimes達到4時，無論如何我們都會得到最終結果。但是你覺得寫的好嗎？優雅嗎？下面我來介紹Spring中的一個組件：spring-retry，我們不妨來試一試。

Spring-Retry介紹使用

spring-retry是Spring中的提供的一個重試框架，提供了注解的方式，在不入侵原有業務邏輯代碼的方式下，優雅的實現重處理功能。

安裝依賴

• 如果你的是gradle應用，引入下面的依賴

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

• 如果你的項目使用的是maven項目，引入下面的依賴

<dependency>
    <groupId>org.springframework.retry<span class="hljs-name"groupId>
    <artifactId>spring-retry<span class="hljs-name"artifactId>
<span class="hljs-name"dependency>

<dependency>
    <groupId>org.springframework.boot<span class="hljs-name"groupId>
    <artifactId>spring-boot-starter-aop<span class="hljs-name"artifactId>
<span class="hljs-name"dependency>

啟用重試功能

添加@EnableRetry注解在入口的類上從而啟用功能。

@SpringBootApplication
//看過來
@EnableRetry
public class TestSpringApplication {

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

}

應用

我們以前面的為例，看看怎么使用，如下面的代碼：

public interface OutSource {
    List;
}

@Service
public class OutSourceImpl implements OutSource {

    static Random random = new Random();
    @Override
    public List{
        //mock failure will throw an exception every time
        throw new TimeOutException();
    }
}

@Slf4j
@Service
public class RetryableService {

    @Autowired
    private OutSource outSource;

    // 看這里
    @Retryable(value = {TimeOutException.class}, maxAttempts = 3)
    public List{
        log.info("trigger timestamp:{}", System.currentTimeMillis() / 1000);

        List

• 關鍵在于Service層中的實現類中添加了 @Retryable注解，實現了重試, 指定value是TimeOutException異常會進行重試，最大重試maxAttempts3次。

驗證

這一次，當我們訪問http://localhost:8080/retryable時，我們將看到瀏覽器上的結果失敗。然后在你的終端上看到：

INFO 66776 --- [nio-9997-exec-1] c.m.testspring.service.RetryableService  : trigger timestamp:1668236840
 INFO 66776 --- [nio-9997-exec-1] c.m.testspring.service.RetryableService  : trigger timestamp:1668236841
 INFO 66776 --- [nio-9997-exec-1] c.m.testspring.service.RetryableService  : trigger timestamp:1668236842
ERROR 66776 --- [nio-9997-exec-1] c.m.t.controller.RetryTestController     : retryable final exception

總結

本文分享了spring-retry重試框架最基礎的使用，可以無侵入業務代碼進行重試。關于spring-retry更多的使用建議可以自己去官網https://github.com/spring-projects/spring-retry 探索。