Java利用配置重试策略解决超时问题

 更新时间:2022年10月14日 11:15:20   作者:指北君  
在web应用中,由于网络原因或其他不可预测的原因,应用间会出现调用失败的情形,通过配置重试策略可以有效解决外在原因导致的系统故障。本文就来详细说说如何利用配置重试策略解决超时问题

在web应用中,由于网络原因或其他不可预测的原因,应用间会出现调用失败的情形,通过配置重试策略可以有效解决外在原因导致的系统故障。

使用场景

  • 微服务间各个服务模块间的调用
  • 第三方模块远程交易调用
  • 非业务异常导致可能失败的情况

示例

构建Retryer

private Retryer retryer = RetryerBuilder.newBuilder()
        .retryIfException() // 异常时重试
        .retryIfResult(input -> input!=null && input instanceof Boolean && !Boolean.valueOf((Boolean) input)) // 返回值为false时重试
        // 对应Future获取超时时间
        .withAttemptTimeLimiter(AttemptTimeLimiters.fixedTimeLimit(4, TimeUnit.SECONDS,Executors.newFixedThreadPool(2))) //重试次数限制
        .withRetryListener(new RetryListener() { // 重试执行逻辑
            @Override
            public <V> void onRetry(Attempt<V> attempt) {
                log.info("onRetry -> 重试次数:{},距第一次重试时长:{}", attempt.getAttemptNumber(),attempt.getDelaySinceFirstAttempt());
                if(attempt.hasException()){ // 是否异常导致重试
                    Throwable exception = attempt.getExceptionCause(); // 执行的异常
                    log.info("异常:{}", exception);
                }
                if(attempt.hasResult()){ // 是否有返回
                    V result = attempt.getResult();
                    log.info("返回:{}",result);
                }
            }
        })
        // 控制每次重试间隔时间,如果AttemptTimeLimiter设置多线程
        .withWaitStrategy(WaitStrategies.fixedWait(3,TimeUnit.SECONDS)) // 等待策略
        .withBlockStrategy(BlockStrategies.threadSleepStrategy()) // 阻塞策略
        //
        .withStopStrategy(StopStrategies.stopAfterAttempt(5)) // 停止策略
        .build();

使用Retryer让业务代码拥有重试能力

前两次执行时模拟返回false,则会执行重试;当第3次时,正常执行业务代码并返回true,结束重试

@Test
public void retryWhenResult() throws ExecutionException, RetryException {
   retryer.call(() -> {
       if(counter.incrementAndGet() == 3){// 模拟前2此返回false,触发重试
           log.info(" 执行业务代码:{}次",counter.get());
           return true;
       }
       return false; 
   });
}

模拟前3次出现异常,则会执行重试;当第3次时,正常执行业务代码,结束重试

@Test
public void retryWhenException() throws ExecutionException, RetryException {
    retryer.call(() -> {
        if( counter.getAndIncrement() == 3 ){// 模拟前5此出现异常,触发重试
            return counter;
        }
        log.info(" 执行业务代码: {}次", counter.get());
         throw new RuntimeException("ERROR"); 
    });
}

模拟前5此出现异常,由于Retryer配置重试次数为5,则最终业务代码不会执行

@Test
public void retryWhenResultOnFailure() throws ExecutionException, RetryException {
    retryer.call(() -> {
        if(counter.incrementAndGet() == 8){// 模拟前7此返回false,由于配置重试5次,因此最终失败
            log.info(" 执行业务代码:{}次",counter.get());
            return true;
        }
        return false;
    });
}

执行流程

执行流程

通过RetryerBuilder构建Retryer,调用Retryer#call,封装业务代码为其回调函数

  • 开始循环执行
  • 由AttemptTimeLimiter#call执行回调函数
  • 将结果封装为Attempt,包括两种类型ResultAttempt,ExceptionAttempt。如果成功,记录执行结果、持续时长;如果失败,记录异常、持续时长
  • 执行监听RetyrListener#onRetry,可以配置多个监听
  • 执行拒绝断言Predicate,根据返回值、执行异常、返回异常类型判断是否终止重试
  • 如果满足条件,则继续重试;否则结束重试,并返回Attempt包含回调结果
  • 根据终止策略StopStrategy判断是否终止重试
  • 根据等待策略WaitStrategy获取等待时长
  • 根据阻塞策略BlockStrategy与上一步等待时长阻塞重试,如果出现异常则抛出RetryException
  • 重复执行以上逻辑

配置

构建Retryer主要通过RetryerBuilder.newBuilder()实现,其相关配置如下:

配置策略名称描述
AttemptTimeLimiters 任务执行时长限制 
 NoAttemptTimeLimit无时长限制 
 FixedAttemptTimeLimit固定时长限制 
WaitStrategies 重试等待策略 
 ExponentialWaitStrategy指数等待策略按指数增加重试间隔时长,比如第一次2^1100、2^2100、2^3*100...最多300000
 FibonacciWaitStrategy斐波那契等待策略1100、1100、2100、3100、5*100...
 FixedWaitStrategy固定时长等待策略按配置的固定间隔时间
 RandomWaitStrategy随机时长等待策略随机间隔时间,可以设置随机值范围
 IncrementingWaitStrategy递增等待策略根据配置的初始值与增量进行累加时间
 ExceptionWaitStrategy异常等待策略根据异常类型指定等待时间
 CompositeWaitStrategy复合等待策略可配置多个策略进行组合
BlockStrategies 阻塞策略根据WaitStrategies获取阻塞时长
 ThreadSleepStrategy线程等等策略通过Thread.sleet()实现
StopStrategies 重试停止策略 
 NeverStopStrategy无限制策略 
 StopAfterAttemptStrategy限定次数策略 
 StopAfterDelayStrategy限定时长策略 
 NoAttemptTimeLimit限定次数 

注意

AttemptTimeLimiter中的FixedAttemptTimeLimit依赖于guava中的SimpleTimeLimiter,但是在guava高版本中该类已经成了私有类

总结

Guava Retrying模块能够通过简单的将代码实现业务逻辑重试的功能,并且其配置中包含了重试的次数、时长控制、重试阻塞、终止策略等等, 在项目中是非常常用的一项技术。

到此这篇关于Java利用配置重试策略解决超时问题的文章就介绍到这了,更多相关Java配置重试策略解决超时内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java Apollo环境搭建以及集成SpringBoot案例详解

    Java Apollo环境搭建以及集成SpringBoot案例详解

    这篇文章主要介绍了Java Apollo环境搭建以及集成SpringBoot案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • java实现菜单树的示例代码

    java实现菜单树的示例代码

    这篇文章主要为大家详细介绍了java实现菜单树的相关知识,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以跟随小编一起学习一下
    2023-12-12
  • Java中一维二维数组的静态和动态初始化

    Java中一维二维数组的静态和动态初始化

    今天通过本文给大家分享Java中的数组,包括一维数组和二维数组的静态初始化和动态初始化问题,感兴趣的朋友一起看看吧
    2017-10-10
  • Spring boot跨域设置实例详解

    Spring boot跨域设置实例详解

    这篇文章主要介绍了Spring boot跨域设置实例详解,简单介绍了跨域的定义,原因,使用场景及解决方案,具有一定参考价值,需要的朋友可以了解下。
    2017-11-11
  • Spring通过三级缓存解决循环依赖问题的过程详解

    Spring通过三级缓存解决循环依赖问题的过程详解

    循环依赖指的是在对象之间存在相互依赖关系,形成一个闭环,导致无法准确地完成对象的创建和初始化,本文主要介绍了Spring通过三级缓存解决循环依赖的方法,需要的可以参考下
    2023-10-10
  • Java Swagger技术使用指南

    Java Swagger技术使用指南

    Swagger 是一个规范和完整的框架,用于生成、描述、调用和可视化 RESTful 风格的 Web 服务。总体目标是使客户端和文件系统作为服务器以同样的速度来更新。文件的方法,参数和模型紧密集成到服务器端的代码,允许API来始终保持同步
    2021-09-09
  • java针对电话号码正则匹配实例

    java针对电话号码正则匹配实例

    这篇文章主要介绍了java针对电话号码正则匹配的方法,涉及java正则匹配与字符串操作的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-07-07
  • 在Spring Boot中实现HTTP缓存的方法

    在Spring Boot中实现HTTP缓存的方法

    缓存是HTTP协议的一个强大功能,但由于某些原因,它主要用于静态资源,如图像,CSS样式表或JavaScript文件。本文重点给大家介绍在Spring Boot中实现HTTP缓存的方法,感兴趣的朋友跟随小编一起看看吧
    2018-10-10
  • JSP页面无法识别EL表达式问题解决方案

    JSP页面无法识别EL表达式问题解决方案

    这篇文章主要介绍了JSP页面无法识别EL表达式问题解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07
  • java实现mp3合并的方法

    java实现mp3合并的方法

    这篇文章主要介绍了java实现mp3合并的方法,是Java操作多媒体文件的一个典型应用,非常具有参考借鉴价值,需要的朋友可以参考下
    2014-10-10

最新评论