使用resilience4j实现优雅重试
样例的详细代码可以从Github上 下载
使用resilience4j实现优雅重试
子曰:小胜靠智,大胜靠德,常胜靠身体。
resilience4j是什么?
Resilience4j 是受Netflix的Hysrix项目启发,专门为Java 8 和函数式编程设计的轻量级容错框架。Resilicenes4j 仅使用了一个第三方开源库Vavr,Vavr不依赖其他库。相比较而言,Netflix Hysrix对Archaius存在编译依赖,Archaius有许多外部依赖,比如Guava和Apache Commons Configuration。Resilience4j 按模块发布,可以有选择的使用其中某些功能而无需引入全部的Resilience4j 组件。Resilience4j源码托管在Github上。
Retry包括那些组件?
- 重试配置(RetryConfig)
RetryConfig类似spring-retry中的RetryPolicy和注解@Retryable,主要对重试的最大次数,重试的条件等进行配置,RetryConfig支持的参数及含义如下:maxAttempts
最大重试次数,如果在重试次数达到maxAttempts设置的值后依然无法成功结束, 调用线程或通过异步结果对象会得到失败结果。默认重试次数为3次。intervalFunction
获取重试间隔的function,为两次重试之间的时间间隔。exceptionPredicate
计算抛出的异常是否触发重试的谓词函数。resultPredicate
计算执行结果是否触发重发重试的谓词函数。
Resilience4j 提供工具类RetryConfig.Builder
简化RetryConfig
的设置。
重试指标(Metrics)
处理与重试相关的指标,指标项包括:成功次数(未重试)、失败次数(未重试)、成功次数(经过重试)和失败次数(经过重试)。重试上下文(Context)
重试上下文,针对执行成功、执行结果、异常(Exception
)和运行时异常(RuntimeException
)执行对应的处理动作。事件机制
- Event
Resilience4j 针对重试提供四种事件:RETRY、ERROR、SUCCESS和IGNORED_ERROR; - EventPublisher
事件发布器,主要负责将RETRY、ERROR、SUCCESS和IGNORED_ERROR四种事件通知对应的事件消费者。 - EventConsumer
事件消费者,对事件发布器发布的事件订阅并执行特定的处理逻辑。消费者需要实现一个事件消费接口:void consumeEvent(T event);
- Event
RetryRegistry
创建存储Retry实例的工厂,目前Resilience4j 提供一个基于内存的实现。Retry和AsyncRetry
同步重试和异步重试,重试流程的入口。内部通过while -> true -> break逻辑实现重试。
代码示例
创建重试配置
RetryConfig config = RetryConfig.custom().maxAttempts(5).waitDuration(Duration.ofMillis(DEFAULT_WAIT_DURATION)).retryExceptions(RetryNeedException.class).ignoreExceptions(RetryNoNeedException.class).retryOnException(throwable -> throwable instanceof RuntimeException).retryOnResult(resp -> resp.toString().contains("result cause retry")).build();
上面的重试配置支持最多5次重试,重试间隔为DEFAULT_WAIT_DURATION
定义的毫秒数,RetryNeedException
类型的异常触发重试,RetryNoNeedException
异常不触发重试,如果反值包含result cause retry
字符串触发重试。异步重试和同步重试的配置一样,并无差别。
同步重试
Retry retry = Retry.of("sync retry", config);private int executeTimes = 0;public void retryOnException() {Retry.decorateRunnable(retry, new Runnable() {@Overridepublic void run() {if (executeTimes++ < 3) {throw RetryNeedException.defaultException();}}}).run();}
上面的代码实现了run()
方法执行4次的效果,前三次执行抛出的异常触发重试,但是run()
最终会执行成功。
异步重试
为了实现异步重试,需要提供线程池用于执行任务,在resilience4j使用的线程池为ScheduledExecutorService
,可以根据自己的需要对线程池的参数进行定制。实现异步重试的代码样例如下:
实际的业务逻辑
private CompletionStage<String> exceptionCauseRetry() {if (executeTimes.getAndIncrement() < 2) {throw new RetryNeedException("need retry");}return CompletableFuture.completedFuture("async retry");}
将实际的业务逻辑加入到重试框架
public Supplier<CompletionStage<String>> asyncRetryOnException() {return AsyncRetry.decorateCompletionStage(asyncRetry, executor, () -> exceptionCauseRetry());}
最后
resilience4j和spring-retry都可以实现业务逻辑的优雅重试,但是resilience4j更加轻量,而且可以针对执行结果触发重试逻辑,使用更加方便,也不用为jar冲突等问题而烦恼。以上样例的详细代码可以从Github上下载
使用resilience4j实现优雅重试相关推荐
- 优雅实现重试功能选型分析
业务场景 应用中需要实现一个功能: 需要将数据上传到远程存储服务,同时在返回处理成功情况下做其他操作.这个功能不复杂,分为两个步骤:第一步调用远程的Rest服务逻辑包装给处理方法返回处理结果:第二步拿 ...
- foxmail邮件加载失败重试_java retry(重试) spring retry, guava retrying 详解
系列说明 java retry 的一步步实现机制. java-retry 源码地址 情景导入 简单的需求 产品经理:实现一个按条件,查询用户信息的服务. 小明:好的.没问题. 代码 UserServi ...
- java retry(重试) spring retry, guava retrying 详解
转载 自 http://blog.51cto.com/9250070/2156431 系列说明 java retry 的一步步实现机制. java-retry 源码地址 情景导入 简单的需求 产品经理 ...
- Java基础学习总结(161)——Java 重试机制
重试的作用: 对于重试是有场景限制的,不是什么场景都适合重试,比如参数校验不合法.写操作等(要考虑写是否幂等)都不适合重试.远程调用超时.网络突然中断可以重试.在微服务治理框架中,通常都有自己的重试与 ...
- java中的失败重试机制总结
应用中需要实现一个功能: 需要将数据上传到远程存储服务,同时在返回处理成功情况下做其他操作.这个功能不复杂,分为两个步骤:第一步调用远程的Rest服务上传数据后对返回的结果进行处理:第二步拿到第一步结 ...
- java 超时重试机制_Java之Retry重试机制详解
应用中需要实现一个功能: 需要将 常规解决方案 try- 在包装正常上传逻辑基础上,通过判断返回结果或监听异常决定是否重试,同时为了解决立即重试的无效执行(假设异常是有外部执行不稳定导致的:网络抖动) ...
- Java之Retry重试机制详解
应用中需要实现一个功能: 需要将数据上传到远程存储服务,同时在返回处理成功情况下做其他操作. 这个功能不复杂,分为两个步骤: 第一步:调用远程的Rest服务上传数据后对返回的结果进行处理: 第二步:拿 ...
- 使用 Contour 接管 Kubernetes 的南北流量
点击蓝色"程序猿DD"关注我 回复"资源"获取独家整理的学习资料! 前言 在 Kubernetes 中运行大规模以 Web 为中心的工作负载,最关键的需求之一就 ...
- Contour 学习笔记(一):使用 Contour 接管 Kubernetes 的南北流量
原文链接:Contour 学习笔记(一):使用 Contour 接管 Kubernetes 的南北流量 在 Kubernetes 中运行大规模以 Web 为中心的工作负载,最关键的需求之一就是在 L7 ...
最新文章
- Microbiome:揩老鼠皮毛揩来高分文章——野生哺乳动物的皮肤和肠道微生物群对环境污染做出的反应
- SQL Prompt 5.1使用
- mysql 云主机名_mysql部署到云主机的笔记
- 【elasticsearch】 Elasticsearch集群规模和容量规划的底层逻辑
- 主机连接虚拟机 web服务
- 关于MVC打印问题,打印指定的内容
- VLAN专题之三:VLAN的访问链接
- python小白从哪来开始-如何从零开始学习Python【小白入门】
- 【NOIP2014】【Luogu2141】珠心算测验(枚举,合并两数组相同元素个数)
- [Unity] 在协程中等待指定的毫秒
- 《算法基础》——3.9 总结
- H5图像遮罩-遁地龙卷风
- 【更新中…】Latex语法总结
- python每天定时执行任务_Python设置定时任务
- Hark的数据结构与算法练习之归并排序
- 2013年10月22日、|充实自己|看书看到恶心看教学视频看到吐|也许旷几次课也是值得的
- 关于 YCbCr(YUV) 格式视频流的介绍
- Kali学习 | 漏洞利用:4.4 控制Meterpreter
- Linux C获取当前时间(精确到微秒)
- 硬盘主分区、扩展分区和逻辑分区
热门文章
- 《人工智能导论》第二章:智能Agent(笔记一)
- java replaceall 1_java replaceAll之$替换
- SAE(新浪云平台)容器云使用总结
- ArcGIS API for JavaScript实现加载必应地图
- 数学规划 (线性,非线性,整数)
- 涉密计算机分为几个等级,获得涉密集成资质单位关于涉密人员分为哪几个等级?...
- Sage X3 ERP如何帮助客户提高库存盘点准确率仓库为什么要多次盘点?
- Windows系统入侵排查与应急响应技术
- IT运维管理系统软件怎么选择
- ![CDATA[ ]