0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

Guava Retrying模块使用场景

科技绿洲 来源:Java技术指北 作者:Java技术指北 2023-10-08 09:55 次阅读

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

使用场景

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

示例

构建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,封装业务代码为其回调函数

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

配置

构建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限定次数

注意

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

总结

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

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • 模块
    +关注

    关注

    7

    文章

    2695

    浏览量

    47433
  • 函数
    +关注

    关注

    3

    文章

    4327

    浏览量

    62573
  • 代码
    +关注

    关注

    30

    文章

    4779

    浏览量

    68527
收藏 人收藏

    评论

    相关推荐

    模块化仪器的技术原理和应用场景

    模块化仪器是插拔式的计算机板卡,功能类似于传统的台式仪器,其技术原理和应用场景可以归纳如下:一、技术原理 模块化设计:模块化仪器使用一个框架,可以将不同类型或不同数量的功能卡插入其中,
    发表于 11-28 15:09

    =>的使用场景有哪些

    使用场景
    发表于 10-27 13:25

    ARM的技术特征是什么?应用场景有哪些?

    ARM的技术特征是什么?应用场景有哪些?
    发表于 11-05 07:32

    蓝牙模块的5大应用场景

    打印机打印出符合要求的二维码以二维码的形式将蓝牙MAC地址打印出来,方便蓝牙产品对蓝牙MAC地址进行读取,能够有效提高工作效率。五、智能门锁在智能门锁的应用场景中,利用蓝牙技术可以满足不同用户和权限
    发表于 12-09 09:37

    MS9331的应用场景是什么?

    MS9331的应用场景是什么?
    发表于 02-11 06:41

    labview 和 wincc 的区别 使用场景

    labview 和 wincc 的区别 使用场景 都是上位机软件,都可以做监控软件 wincc的名气也比较大 对比的资料较少 写这些文章的人,从自己的从事的行业出发,带有自己的思维 使用的场景 肯定
    发表于 10-27 18:01

    一文深度了解串口WiFi模块作用,串口WiFi模块的应用场景

    串口WiFi模块作用,串口WiFi模块的应用场景
    发表于 03-01 14:25 28次下载

    无线模块的十大应用场景

    无线模块的十大应用场景
    发表于 05-08 10:17 18次下载

    网络音频模块有哪些应用场景

    对音频信号进行编解码、处理和转换,支持多种音频格式和协议,例如MP3、AAC、G.711等。网络音频模块可以实现单向或双向的语音通信,也可以实现多路的语音广播。 网络音频模块有哪些应用场景? 网络音频
    的头像 发表于 05-16 10:24 687次阅读
    网络音频<b class='flag-5'>模块</b>有哪些应<b class='flag-5'>用场景</b>?

    LoRa模块的应用场景

    LoRa远程无线传输技术拥有传输距离远、功耗低、性能高、无线组网,远程定位等一系列特点,使用终端与LoRa基站组件低功耗数据传输网络成为了物联网大规模推广应用的理想选择之一。那么LoRa模块可以使用在哪些应用场景呢?思为无线就来为您解答。
    的头像 发表于 04-18 15:10 889次阅读
    LoRa<b class='flag-5'>模块</b>的应<b class='flag-5'>用场景</b>

    DC电源模块不同的尺寸可以适应实际应用场景

    DC电源模块是现代电子设备的必备部件之一,其可提供稳定的直流电源,保证电子设备正常运行。DC电源模块尺寸的选择直接影响到其适应的应用场景及其性能表现。本文将从尺寸方面分析DC电源模块
    的头像 发表于 08-29 10:32 558次阅读

    Guava Collect常见的集合类

    Guava工具包中的一个子模块,主要对jdk中的集合操作添加了一些简易的API,同时也是对Collections工具类的扩展。当然Guava还定义了一些特定场景的数据结构以及一些针对
    的头像 发表于 10-08 11:35 458次阅读

    千兆光模块和万兆光模块的适用场景有哪些

    随着网络技术的不断进步,千兆光模块和万兆光模块成为使用最为广泛的两款光模块。本文将介绍一些光模块使用场景,以便用户更加深入的了解这两款光
    的头像 发表于 10-16 12:06 905次阅读

    DC电源模块和AC电源模块都有各自的优点和适用场景

    BOSHIDA DC电源模块和AC电源模块都有各自的优点和适用场景 DC电源模块和AC电源模块都有各自的优点和适
    的头像 发表于 12-29 14:39 953次阅读
    DC电源<b class='flag-5'>模块</b>和AC电源<b class='flag-5'>模块</b>都有各自的优点和适<b class='flag-5'>用场景</b>

    800G光模块的应用场景

    随着科技发展,数据中心对光模块需求大增。800G光模块作为一种高速光传输技术,应用场景扩展并引起广泛关注。主要应用于数据中心、云计算和网络通信等领域,满足现代社会对高带宽、快速数据传输的需求。
    的头像 发表于 03-11 15:30 672次阅读