当前位置：首页 > 科技 > 软件

聊聊接口重试机制的几种解决方案

来源：责编：时间：2023-11-06 08:53:25 166观看

导读1.前言接口请求重试机制是保证系统稳定性和容错能力的重要手段之一。当接口请求发生失败或暂时性错误时,通过重试机制可以提高请求的成功率。本文将详细介绍接口请求重试机制的几种常见方法。2.几种方法2.1循环重试它

1.前言

接口请求重试机制是保证系统稳定性和容错能力的重要手段之一。当接口请求发生失败或暂时性错误时,通过重试机制可以提高请求的成功率。本文将详细介绍接口请求重试机制的几种常见方法。

2.几种方法

2.1循环重试

它的基本思路是:

定义重试次数,如最大重试5次
发送请求,如果失败则进入重试逻辑
在循环内部,记录当前已重试次数,如当前已重试2次
判断当前重试次数是否达到最大次数,如果达到则终止循环,否则进行重试
在循环内部,可以添加定时重试间隔,也可以使用指数退避算法
发送重试请求,重复判断是否成功,直到成功、达到最大次数或其他终止条件

示例

public class Retry {private static final int MAX_RETRIES = 5;public static Response request() throws Exception {  int retries = 0;  while (true) {    try {      // 发送请求,返回响应      Response response = HttpClient.sendRequest();      // 请求成功则返回响应      if (response.isSuccess()) {        return response;      }    } catch (Exception e) {      // 请求失败进行重试    }    // 判断是否超过最大重试次数    if (++retries >= MAX_RETRIES) {      throw new Exception("Exceeded max retries");    }    // 增加间隔后重试    int interval = (int) (Math.random() * 1000);    Thread.sleep(interval);  }}public static void main(String[] args) throws Exception {  Response response = request();  // ...}}

2.2 使用Spring Retry库

使用 Spring Retry 库可以很方便地实现接口请求的重试机制。

2.2.1 添加 Maven 依赖

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

2.2.2 添加 @EnableRetry 注解启用重试功能

2.2.3 在需要重试的方法上添加 @Retryable 注解

@Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 5000))public User getUser(String id) {// 远程调用接口}

@Retryable 定义了重试规则:- value - 重试的异常类型- maxAttempts - 最大重试次数- backoff - 重试等待策略

2.2.4. 还可以自定义 RetryTemplate 进行更复杂的重试控制

RetryTemplate template = new RetryTemplate();template.execute(context -> {// 可在此处自定义重试逻辑 return remoteClient.invoke();});

Spring Retry 为接口请求重试提供了完善和易用的解决方案,可以灵活控制各种重试参数,适用于复杂系统的容错要求。

2.3 并发框架异步重试

使用并发框架的异步请求方式可以较简单地实现接口请求的重试机制。以CompletableFuture为例:

2.3.1 发送请求使用CompletableFuture封装:

CompletableFuture<Response> future = CompletableFuture.supplyAsync(() -> {return service.call();});

2.3.2 当请求失败时,使用retryAsync自动完成重试:

future = future.exceptionally(e -> {return service.retryAsync();});

2.3.3 可以链式调用,自定义重试逻辑:

future.exceptionally(e -> {    // 处理异常}).thenApplyAsync(resp -> {    // 处理响应}).retryAsync(retryCount, delay);

主要优点是:

线程安全的异步请求
自动重试失败任务
简洁的链式编程方式
避免阻塞主线程

使用并发框架可以便捷地实现异步重试机制,提高系统容错性。其他框架如RxJava也有类似的重试机制。

2.4 消息队列重试

使用消息队列可以实现接口请求的异步重试机制。

基本思路是:

接口请求发送失败后,将请求信息封装为消息,发送到请求重试的队列中。
消息消费者从队列中获取失败的请求,根据策略进行重试。
重复重试直到成功、重试次数用尽或其他终止条件。
成功后将消息移除队列,失败则保留消息供再次重试。

主要步骤:

创建请求重试队列,如“request.retry.queue”
接口请求失败后,生成重试消息,发送到队列
消费者启动线程从队列中取消息重试
根据重试策略进行定时重试或最大重试数
成功则确认消息,失败则重新入队

使用消息队列进行重试有利于:

异步重试,不阻塞主线程
可靠地完成重试任务
灵活控制重试策略

示例

// 1. 创建队列Queue retryQueue = new Queue("request.retry.queue");// 2. 请求失败,发送重试消息  public void request() {try {  // 调用接口  httpClient.post(url, payload);} catch (Exception e) {  // 发送重试消息  Message msg = new Message(url, payload, maxRetries);  retryQueue.send(msg);}}// 3. 消费者线程进行重试class RetryConsumer implements Runnable {public void run() {  while (true) {    Message msg = retryQueue.take();         for (int i = 0; i < msg.getMaxRetries(); i++) {      try {        // 重试请求        httpClient.post(msg.getUrl(), msg.getPayload());        // 请求成功,结束循环        break;      } catch (Exception e) {        // 等待后继续重试      }      }         // 重试完成后,确认消息    retryQueue.confirm(msg);  }}}

这就是使用消息队列实现接口重试的基本流程,可以根据需求扩展重试策略、异常处理等逻辑。

2.5 自定义重试工具类

使用自定义的重试工具类来实现接口请求的重试机制,提高代码的复用性和可维护性。

重试工具类的实现思路:

提供重试方法,参数包括请求函数、重试策略等
在重试方法内部执行循环请求
每次请求失败时,根据策略等待一段时间
记录当前重试次数,与最大次数比较
请求成功或者达到最大重试次数则结束循环

示例:

public class RetryUtil {public static <T> T retry(RetryCallable<T> callable, RetryPolicy policy) {  int retries = 0;  while(true) {    try {      return callable.call();      } catch(Exception e) {      if (retries >= policy.maxRetries) {        throw e;      }      // 等待      policy.delay();      // 重试次数加1      retries++;    }  }}}// 执行请求的函数接口interface RetryCallable<T> {T call();}// 重试策略class RetryPolicy {int maxRetries;int delay;}// 使用示例RetryUtil.retry(() -> {// 接口请求return httpClient.get(url);}, policy);

这样可以提高重试相关逻辑的复用性,避免写重复代码。

2.6 使用递归结构

使用递归结构也可以实现接口请求的重试机制。

基本思路是设计一个递归函数,在函数内部发送请求,如果失败则继续递归调用自身再次重试。

示例:

public class RetryRequest {private static final int MAX_RETRIES = 3; public static Response request(int retries) {     try {    // 发送请求    Response response = HttpClient.get("http://example.com");    return response;       } catch (Exception e) {         // 处理异常         // 判断是否需要重试    if (retries < MAX_RETRIES) {      // 增加重试次数      retries++;      // 延迟1秒钟      Thread.sleep(1000);      // 递归调用自身进行重试      return request(retries);    }         // 重试失败    throw new RuntimeException("Request failed after " + MAX_RETRIES + " retries!");       }} public static void main(String[] args) {    Response response = request(0);  // 处理响应}}

主要逻辑是通过递归不断调用自身来实现重试。优点是逻辑较简单清晰,缺点是递归层次过深时可能会导致堆栈溢出。需要合理设置最大递归深度,也可以通过循环改写递归来避免深层递归。

2.7 使用Resilience4j

Resilience4j是一个很好的Java重试库,可以用它来实现接口请求的重试机制。

主要步骤:

2.7.1添加Resilience4j依赖

<dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-retry</artifactId></dependency>

2.7.2 定义重试逻辑

RetryConfig config = RetryConfig.custom().maxAttempts(3).waitDuration(Duration.ofMillis(500)).build();Retry retry = Retry.of("backend", config);

2.7.3 使用重试逻辑调用接口

String result = retry.executeSupplier(() -> {// 发送请求return backendService.callAPI();});

2.7.4 自定义重试异常predicate

RetryConfig config = RetryConfig.custom().retryOnException(e -> isRetryable(e)).build();

Resilience4j提供了线程安全的重试 decorator,可以通过配置灵活控制重试策略,很好地支持了接口请求重试。

2.8 使用网络工具重试

我们常用的一些网络工具来做重试

示例

public class RetryExample {private static final int MAX_RETRIES = 3;public static String request(String url) throws Exception {  int retries = 0;     while (true) {         try {      // 使用HttpClient发送请求      return HttpClientUtils.get(url);           } catch (Exception e) {      if (retries >= MAX_RETRIES) {        throw e;      }             // 增加重试次数      retries++;      // 延迟1秒钟      TimeUnit.SECONDS.sleep(1);    }  }}   public static void main(String[] args) throws Exception {  String result = request("http://example.com/api");  System.out.println(result);}}// 网络工具类class HttpClientUtils {public static String get(String url) throws IOException {  // 发送GET请求并返回结果}}

主要通过循环和网络工具类来实现重试逻辑,延时控制也可以用Random来实现指数退避。这种 utilities + 循环的组合可以实现灵活可复用的重试机制。

3.注意事项

图片

接口请求重试时需要注意以下几点:

3.1 幂等性接口需要是幂等的,多次调用结果相同,避免重复执行带来副作用。

3.2 资源竞争重试可能对服务端造成更大压力,需要考虑限流等措施。

3.3 超时设置合理设置重试最大次数和总超时时间,避免长时间等待。

3.4 重试条件明确哪些异常情况下需要重试,不能无脑重试所有错误。

3.5 数据一致性请求成功后要幂等更新状态,避免重复数据。

3.6 异步机制重试过程不要阻塞主业务线程。

3.7 退避策略失败后延迟一段时间再重试,可选避免集群重试。

3.8 日志记录记录重试的次数、错误原因等信息,方便排查问题。

3.9 容错机制重试失败后的降级处理,避免级联失败。

总结

接口请求重试机制对保证系统高可用非常关键,需要根据业务需求选择合适的重试策略。常用的组合策略包括带最大次数的定时/指数退避重试、故障转移重试等。重试机制需要综合设置以达到容错效果又避免产生过大的系统负载。

本文链接：//www.dmpip.com//www.dmpip.com/showinfo-26-17165-0.html聊聊接口重试机制的几种解决方案

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：提升应用性能：Go中的同步与异步处理

下一篇：如何释放React Hooks的力量

标签：

热门焦点

vivo TWS Air开箱体验：真轻臻好听

在vivo S15系列新机的发布会上，vivo的最新款真无线蓝牙耳机vivo TWS Air也一同发布，本次就这款耳机新品给大家带来一个简单的分享。外包装盒上，vivo TWS Air保持了vivo自家产
六大权益！华为8月服务日开启：手机免费贴膜、维修免人工费

8月5日消息，一年一度的华为开发者大会2023（Together）日前在松山湖拉开帷幕，与此同时，华为8月服务日也式开启，到店可享六大专属权益。华为用户可在华为商城Ap
JavaScript 混淆及反混淆代码工具

介绍在我们开始学习反混淆之前，我们首先要了解一下代码混淆。如果不了解代码是如何混淆的，我们可能无法成功对代码进行反混淆，尤其是使用自定义混淆器对其进行混淆时。什么是混
CSS单标签实现转转logo

转转品牌升级后更新了全新的Logo，今天我们用纯CSS来实现转转的新Logo，为了有一定的挑战性，这里我们只使用一个标签实现，将最大化的使用CSS能力完成Logo的绘制与动画效果。新logo
Automa-通过连接块来自动化你的浏览器

1、前言通过浏览器插件可实现自动化脚本的录制与编写，具有代表性的工具就是：Selenium IDE、Katalon Recorder，对于简单的业务来说可快速实现自动化的上手工作。Selenium IDEKat
让我们一起聊聊文件的操作

文件【1】文件是什么？文件是保存数据的地方，是数据源的一种，比如大家经常使用的word文档、txt文件、excel文件、jpg文件...都是文件。文件最主要的作用就是保存数据，它既可以保
为什么你不应该使用Div作为可点击元素

按钮是为任何网络应用程序提供交互性的最常见方式。但我们经常倾向于使用其他HTML元素，如 div span 等作为 clickable 元素。但通过这样做，我们错过了许多内置浏览器的功能。
超闭合精工铰链彻底消灭缝隙三星Galaxy Z Flip5与Galaxy Z Fold5发布

2023年7月26日，三星电子正式发布了Galaxy Z Flip5与Galaxy Z Fold5。三星新一代折叠屏手机采用超闭合精工铰链，让折叠后的缝隙不再可见。同时，配合处
英特尔Xe HPG游戏显卡：拥有512EU，单风扇版本

据10 月 30 日外媒 TheVerge 消息报道，英特尔 Xe HPG Arc Alchemist 的正面实被曝光，不仅拥有 512 EU 版显卡，还拥有 128EU 的单风扇版本。另外，这款显卡 PCB