SpringBoot中使用SpringRetry实现重试机制(重试调用第三方API)

场景

Springboot+FastJson实现解析第三方http接口json数据为实体类(时间格式化转换、字段包含中文):

Springboot+FastJson实现解析第三方http接口json数据为实体类(时间格式化转换、字段包含中文)_fastjson 发送http请求 接收实体,出现日期转换异常-CSDN博客

在调用第三方接口时,可能会出现因为网络波动等原因导致的接口连接超时等短暂的问题。

如何在调用时添加重试机制,可以通过添加注解的方式给指定的方法配置指定的策略执行重试机制。

Spring Retry

Spring Retry提供了自动重新调用失败的操作的功能。这在错误可能是暂时的(例如瞬时网络故障)的情况下很有用。

GitHub - spring-projects/spring-retry

注:

博客:
霸道流氓气质-CSDN博客

实现

1、引入项目依赖

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

        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.9.4</version>
        </dependency>

2、启动类添加注解@EnableRetry

@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class })
@EnableRetry
public class RuoYiApplication
{
    public static void main(String[] args)
    {
        SpringApplication.run(RuoYiApplication.class, args);
    }
}

3、新建接口,用来调用第三方接口

public interface IRetryService {

    String getThirdApiData();

}

4、接口实现

​
import cn.hutool.http.HttpRequest;
import com.ruoyi.system.service.IRetryService;
import org.springframework.retry.annotation.Backoff;
import org.springframework.retry.annotation.Recover;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;

@Service
public class RetryServiceImpl implements IRetryService {

    //value :针对指定抛出的异常类型,进行重试,这里指定的是Exception
    //maxAttempts :配置最大重试次数,这里配置为10次(包含第一次和最后一次)
    //delay: 第一次重试延迟间隔,这里配置的是2s
    //multiplier :每次重试时间间隔是前一次几倍,这里是1.5倍

    @Override
    @Retryable(value = Exception.class, maxAttempts = 10, backoff = @Backoff(delay = 2000,multiplier = 1.5))
    public String getThirdApiData() {
        System.out.println("调用一次");
        return HttpRequest
                .get("http://127.0.0.1:4523/m1/2858210-0-default/testFastJson")
                .timeout(4000)
                .execute()
                .body();
    }

    @Recover
    public String recover(Exception e){
        return "请求失败";
    }
}

​

其中在需要重试的方法上添加注解@Retryable,并配置重试策略

value :针对指定抛出的异常类型,进行重试,这里指定的是Exception

maxAttempts :配置最大重试次数,这里配置为10次(包含第一次和最后一次)

delay: 第一次重试延迟间隔,这里配置的是2s

multiplier :每次重试时间间隔是前一次几倍,这里是1.5倍

注解@Recover用来配置所有重试都失败后的回调方法。

5、编写单元测试

@RunWith(SpringRunner.class)
@SpringBootTest(classes = RuoYiApplication.class,webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class SpringRetryTest {

    @Autowired
    private IRetryService iRetryService;

    @Test
    public void getThirdApiDataTest() {
        try {
            String thirdApiData = iRetryService.getThirdApiData();
            System.out.println(thirdApiData);
        } catch (Exception exception) {
            exception.printStackTrace();
        }
    }
}

6、首先将重试次数设置为5次,运行测试结果

当接口一直不通时

再将重试次数设置为10次,并在重试过程中将接口打开

7、@Retryable注解还可指定重试指定类型的异常

    @Retryable(
        value = { RestClientException.class, TimeoutException.class },
        maxAttempts = 3,
        backoff = @Backoff(delay = 1000, multiplier = 2)
    )

方法会在发生RestClientException或TimeoutException异常时进行重试。

还可排除指定类型的异常

    @Retryable(
        value = { RestClientException.class },
        maxAttempts = 3,
        backoff = @Backoff(delay = 1000, multiplier = 2),
        exclude = { TimeoutException.class }
    )

方法会在发生RestClientException异常时进行重试,但排除了TimeoutException异常。

相关推荐

  1. SpringBoot实现调用API

    2024-01-12 09:56:03       35 阅读
  2. Spring Boot调用API

    2024-01-12 09:56:03       43 阅读
  3. Springboot 接口服务机制

    2024-01-12 09:56:03       26 阅读
  4. Golang函数机制实现

    2024-01-12 09:56:03       15 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-01-12 09:56:03       18 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-01-12 09:56:03       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-01-12 09:56:03       19 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-01-12 09:56:03       20 阅读

热门阅读

  1. linux下驱动学习—平台总线 (3)

    2024-01-12 09:56:03       42 阅读
  2. uniapp-x uts 介绍

    2024-01-12 09:56:03       40 阅读
  3. Android 车联网——CarDiagnosticService介绍(十八)

    2024-01-12 09:56:03       37 阅读
  4. Mysql字段的各种时间类型

    2024-01-12 09:56:03       35 阅读
  5. 无人机群ros通信

    2024-01-12 09:56:03       36 阅读
  6. Linux中如何更换yum源

    2024-01-12 09:56:03       29 阅读
  7. 编程江湖:Python探秘之旅-----数据结构的迷宫(四)

    2024-01-12 09:56:03       38 阅读
  8. 【Axure视频教程】可视化饼图

    2024-01-12 09:56:03       43 阅读
  9. GitHub SSH 身份验证原理

    2024-01-12 09:56:03       29 阅读
  10. QtService、托盘程序使用

    2024-01-12 09:56:03       40 阅读
  11. 使用OpenGL 和 opengl ES 渲染YUV图片文件的QT示例

    2024-01-12 09:56:03       39 阅读
  12. WebRTC协议研究

    2024-01-12 09:56:03       33 阅读