在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模块能够通过简单的将代码实现业务逻辑重试的功能,并且其配置中包含了重试的次数、时长控制、重试阻塞、终止策略等等, 在项目中是非常常用的一项技术。
声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。
举报投诉
-
模块
+关注
关注
7文章
2486浏览量
46567 -
函数
+关注
关注
3文章
3911浏览量
61363 -
代码
+关注
关注
30文章
4557浏览量
66858
发布评论请先 登录
相关推荐
MOS管的应用场景
mos管的应用场景,你了解么?低压MOS管可称为金属氧化物半导体场效应管,因为低压MOS管具有良好的开关特性,广泛应用在电子开关的电路中。如开关电源,电动马达、照明调光等!下面银联宝科技就跟大家一起
发表于 11-14 09:24
CP-OFMD调制波形应用场景
图1、5G的应用场景5G使用5G多载波波形来为智能手机,办公室,工厂自动化,智能电网,智慧城市,物联网,M2M,M2X等多种设备提供应用平台。5G新无线电(5G NR)根据应用场景可分为三大类服务
发表于 06-18 06:51
FPGA的应用场景
目录文章目录目录FPGAFPGA 的应用场景FPGA 的技术难点FPGA 的工作原理FPGA 的体系结构FPGA 的开发FPGA 的使用FPGA 的优缺点参考文档FPGAFPGA(Field
发表于 07-28 08:43
蓝牙模块的5大应用场景
打印机打印出符合要求的二维码以二维码的形式将蓝牙MAC地址打印出来,方便蓝牙产品对蓝牙MAC地址进行读取,能够有效提高工作效率。五、智能门锁在智能门锁的应用场景中,利用蓝牙技术可以满足不同用户和权限
发表于 12-09 09:37
labview 和 wincc 的区别 使用场景
labview 和 wincc 的区别 使用场景
都是上位机软件,都可以做监控软件
wincc的名气也比较大
对比的资料较少
写这些文章的人,从自己的从事的行业出发,带有自己的思维
使用的场景 肯定
发表于 10-27 18:01
网络音频模块有哪些应用场景?
对音频信号进行编解码、处理和转换,支持多种音频格式和协议,例如MP3、AAC、G.711等。网络音频模块可以实现单向或双向的语音通信,也可以实现多路的语音广播。 网络音频模块有哪些应用场景? 网络音频
Guava Collect常见的集合类
是Guava工具包中的一个子模块,主要对jdk中的集合操作添加了一些简易的API,同时也是对Collections工具类的扩展。当然Guava还定义了一些特定场景的数据结构以及一些针对
千兆光模块和万兆光模块的适用场景有哪些
随着网络技术的不断进步,千兆光模块和万兆光模块成为使用最为广泛的两款光模块。本文将介绍一些光模块使用场景,以便用户更加深入的了解这两款光
评论