热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

不为人知_阿里P7大佬首次分享SpringRetry不为人知的技巧

篇首语:本文由编程笔记#小编为大家整理,主要介绍了阿里P7大佬首次分享SpringRetry不为人知的技巧相关的知识,希望对你有一定的参考价值。

篇首语:本文由编程笔记#小编为大家整理,主要介绍了阿里P7大佬首次分享Spring Retry不为人知的技巧相关的知识,希望对你有一定的参考价值。






今日分享开始啦,请大家多多指教~

外部服务对于调用者来说一般都是不可靠的,尤其是在网络环境比较差的情况下,网络抖动很容易导致请求超时等异常情况,这时候就需要使用失败重试策略重新调用 API 接口来获取。重试策略在服务治理方面也有很广泛的使用,通过定时检测,来查看服务是否存活。

作为阅读福利,小编也精心整理了一套Spring相关的学习笔记(包含:面试、脑图、手写pdf等),有Spring、SpringMVC、SpringCloud、SpringBoot等等,作为福利无条件发送给刷到此篇文章的Java程序员朋友,需要的自行点击链接自行领取

Spring全家桶+Spring学习笔记


Spring 异常重试框架 Spring Retry

Spring Retry 支持集成到 Spring 或者 Spring Boot 项目中,而它支持 AOP 的切面注入写法,所以在引入时必须引入 aspectjweaver.jar 包。


1.引入 maven 依赖


2.添加 @Retryable 和 @Recover 注解

@Retryable 注解,被注解的方法发生异常时会重试


  • value:指定发生的异常进行重试

  • include:和 value 一样,默认空,当 exclude 也为空时,所有异常都重试

  • exclude:指定异常不重试,默认空,当 include 也为空时,所有异常都重试

  • maxAttemps:重试次数,默认 3

  • backoff:重试补偿机制,默认没有

@Backoff 注解


  • delay:指定延迟后重试

  • multiplier:指定延迟的倍数,比如 delay=5000l,multiplier=2 时,第一次重试为 5 秒后,第二次为 10 秒,第三次为 20 秒

**@Recover 注解:**当重试到达指定次数时,被注解的方法将被回调,可以在该方法中进行日志处理。需要注意的是发生的异常和入参类型一致时才会回调。

image


3.启用重试功能

启动类上面添加 @EnableRetry 注解,启用重试功能,或者在使用 retry 的 service 上面添加也可以,或者 Configuration 配置类上面。建议所有的 Enable 配置加在启动类上,可以清晰地统一管理使用的功能。


4.启动服务,运行测试

image

基于 guava 的重试组件 Guava-Retryer

直接看组件作者对此组件的介绍:

This is a small extension to Google’s Guava library to allow for the creation of configurable retrying strategies for an arbitrary function call, such as something that talks to a remote service with flaky uptime.(这是对 Google 的 guava 库的一个小扩展,允许为任意函数调用创建可配置的重试策略,例如与运行时间不稳定的远程服务对话的策略。)

第一步引入 maven 坐标:


1.其主要接口及策略介绍
  • Attempt:一次执行任务;

  • AttemptTimeLimiter:单次任务执行时间限制(如果单次任务执行超时,则终止执行当前任务);

  • BlockStrategies:任务阻塞策略(通俗的讲就是当前任务执行完,下次任务还没开始这段时间做什么……- - BlockStrategies.THREAD_SLEEP_STRATEGY 也就是调用 Thread.sleep(sleepTime);

  • RetryException:重试异常;

  • RetryListener:自定义重试监听器,可以用于异步记录错误日志;

  • StopStrategy:停止重试策略,提供三种:

  • StopAfterDelayStrategy:设定一个最长允许的执行时间;比如设定最长执行 10s,无论任务执行次数,只要重试的时候超出了最长时间,则任务终止,并返回重试异常 RetryException;

  • NeverStopStrategy:不停止,用于需要一直轮训直到返回期望结果的情况;

  • StopAfterAttemptStrategy:设定最大重试次数,如果超出最大重试次数则停止重试,并返回重试异常;

  • WaitStrategy:等待时长策略(控制时间间隔),返回结果为下次执行时长:

  • FixedWaitStrategy:固定等待时长策略;

  • RandomWaitStrategy:随机等待时长策略(可以提供一个最小和最大时长,等待时长为其区间随机值)

  • IncrementingWaitStrategy:递增等待时长策略(提供一个初始值和步长,等待时间随重试次数增加而增加)

  • ExponentialWaitStrategy:指数等待时长策略;

  • FibonacciWaitStrategy :Fibonacci 等待时长策略;

  • ExceptionWaitStrategy :异常时长等待策略;

  • CompositeWaitStrategy :复合时长等待策略;


2.根据结果判断是否重试

使用场景:如果返回值决定是否要重试。重试接口:

测试:

输出:


3.根据异常判断是否重试

使用场景:根据抛出异常类型判断是否执行重试。重试接口:

测试:

输出:


4.重试策略——设定无限重试

使用场景:在有异常情况下,无限重试(默认执行策略),直到返回正常有效结果;


5.重试策略——设定最大的重试次数

使用场景:在有异常情况下,最多重试次数,如果超过次数则会抛出异常;

测试:

输出:


6.等待策略——设定重试等待固定时长策略

使用场景:设定每次重试等待间隔固定为 10s;

测试输出,可以看出调用间隔是 10S:


7.等待策略——设定重试等待时长固定增长策略

场景:设定初始等待时长值,并设定固定增长步长,但不设定最大等待时长;

测试输出,可以看出调用间隔时间递增 1 秒:


8.等待策略——设定重试等待时长按指数增长策略

使用场景:根据 multiplier 值按照指数级增长等待时长,并设定最大等待时长;

这个重试策略和入参不是很懂,好吧,查看源码:

通过源码看出 ExponentialWaitStrategy 是一个不可变的内部类,构造器中校验入参,最重要的延迟时间计算方法 computeSleepTime(),可以看出延迟时间计算方式

计算以 2 为底失败次数为指数的值

第一步的值构造器第一个入参相乘,然后四舍五入得到延迟时间(毫秒)

通过以上分析可知入参为 1000 时间隔是应该为 2,4,8s

测试输出,可以看出调用间隔时间 2×1000,4×1000,8×1000:


9.等待策略——设定重试等待时长按斐波那契数列策略

使用场景:根据 multiplier 值按照斐波那契数列增长等待时长,并设定最大等待时长,斐波那契数列:1、1、2、3、5、8、13、21、34、……

同样,看源码可知计算可知延迟时间为斐波那契数列和第一入参的乘积(毫秒)

测试输出,可看出间隔调用为 1×1000,1×1000,2×1000:


10.等待策略——组合重试等待时长策略

使用场景:当现有策略不满足使用场景时,可以对多个策略进行组合使用。

同样,看源码才能理解组合策略是什么意思:

可看出组合策略其实按照多个策略的延迟时间相加得到组合策略的延迟时间。exponentialWait 的延迟时间为 2,4,8,16,32…,fixedWait 延迟为 2,2,2,2,2…,所以总的延迟时间为 4,6,10,18,34…

测试输出:


11.监听器——RetryListener 实现重试过程细节处理

使用场景:自定义监听器,分别打印重试过程中的细节,未来可更多的用于异步日志记录,亦或是特殊处理。

测试:

输出:


总结

两种方式都是比较优雅的重试策略,Spring-retry 配置更简单,实现的功能也相对简单,Guava 本身就是谷歌推出的精品 java 类库,guava-retry 也是功能非常强大,相比较于 Spring-Retry 在是否重试的判断条件上有更多的选择性,可以作为 Spring-retry 的补充。






推荐阅读
  • Spring框架的核心组件与架构解析 ... [详细]
  • Presto:高效即席查询引擎的深度解析与应用
    本文深入解析了Presto这一高效的即席查询引擎,详细探讨了其架构设计及其优缺点。Presto通过内存到内存的数据处理方式,显著提升了查询性能,相比传统的MapReduce查询,不仅减少了数据传输的延迟,还提高了查询的准确性和效率。然而,Presto在大规模数据处理和容错机制方面仍存在一定的局限性。本文还介绍了Presto在实际应用中的多种场景,展示了其在大数据分析领域的强大潜力。 ... [详细]
  • 在Java分层设计模式中,典型的三层架构(3-tier application)将业务应用细分为表现层(UI)、业务逻辑层(BLL)和数据访问层(DAL)。这种分层结构不仅有助于提高代码的可维护性和可扩展性,还能有效分离关注点,使各层职责更加明确。通过合理的设计和实现,三层架构能够显著提升系统的整体性能和稳定性。 ... [详细]
  • 在使用SSH框架进行项目开发时,经常会遇到一些常见的问题。例如,在Spring配置文件中配置AOP事务声明后,进行单元测试时可能会出现“No Hibernate Session bound to thread”的错误。本文将详细探讨这一问题的原因,并提供有效的解决方案,帮助开发者顺利解决此类问题。 ... [详细]
  • 本文详细介绍了如何在Java Web服务器上部署音视频服务,并提供了完整的验证流程。以AnyChat为例,这是一款跨平台的音视频解决方案,广泛应用于需要实时音视频交互的项目中。通过具体的部署步骤和测试方法,确保了音视频服务的稳定性和可靠性。 ... [详细]
  • 在拉斯维加斯举行的Interop 2011大会上,Bitcurrent的Alistair Croll发表了一场主题为“如何以云计算的视角进行思考”的演讲。该演讲深入探讨了传统IT思维与云计算思维之间的差异,并提出了在云计算环境下应具备的新思维方式。Croll强调了灵活性、可扩展性和成本效益等关键要素,以及如何通过这些要素来优化企业IT架构和运营。 ... [详细]
  • 在Android应用开发中,实现与MySQL数据库的连接是一项重要的技术任务。本文详细介绍了Android连接MySQL数据库的操作流程和技术要点。首先,Android平台提供了SQLiteOpenHelper类作为数据库辅助工具,用于创建或打开数据库。开发者可以通过继承并扩展该类,实现对数据库的初始化和版本管理。此外,文章还探讨了使用第三方库如Retrofit或Volley进行网络请求,以及如何通过JSON格式交换数据,确保与MySQL服务器的高效通信。 ... [详细]
  • 如何利用Java 5 Executor框架高效构建和管理线程池
    Java 5 引入了 Executor 框架,为开发人员提供了一种高效管理和构建线程池的方法。该框架通过将任务提交与任务执行分离,简化了多线程编程的复杂性。利用 Executor 框架,开发人员可以更灵活地控制线程的创建、分配和管理,从而提高服务器端应用的性能和响应能力。此外,该框架还提供了多种线程池实现,如固定线程池、缓存线程池和单线程池,以适应不同的应用场景和需求。 ... [详细]
  • 提升 Kubernetes 集群管理效率的七大专业工具
    Kubernetes 在云原生环境中的应用日益广泛,然而集群管理的复杂性也随之增加。为了提高管理效率,本文推荐了七款专业工具,这些工具不仅能够简化日常操作,还能提升系统的稳定性和安全性。从自动化部署到监控和故障排查,这些工具覆盖了集群管理的各个方面,帮助管理员更好地应对挑战。 ... [详细]
  • 初探性能优化:入门指南与实践技巧
    在编程领域,常有“尚未精通编码便急于优化”的声音。为了从性能优化的角度提升代码质量,本文将带领读者初步探索性能优化的基本概念与实践技巧。即使程序看似运行良好,数据处理效率仍有待提高,通过系统学习性能优化,能够帮助开发者编写更加高效、稳定的代码。文章不仅介绍了性能优化的基础知识,还提供了实用的调优方法和工具,帮助读者在实际项目中应用这些技术。 ... [详细]
  • 本文探讨了资源访问的学习路径与方法,旨在帮助学习者更高效地获取和利用各类资源。通过分析不同资源的特点和应用场景,提出了多种实用的学习策略和技术手段,为学习者提供了系统的指导和建议。 ... [详细]
  • 在前文探讨了Spring如何为特定的bean选择合适的通知器后,本文将进一步深入分析Spring AOP框架中代理对象的生成机制。具体而言,我们将详细解析如何通过代理技术将通知器(Advisor)中包含的通知(Advice)应用到目标bean上,以实现切面编程的核心功能。 ... [详细]
  • 动态壁纸 LiveWallPaper:让您的桌面栩栩如生(第二篇)
    在本文中,我们将继续探讨如何开发动态壁纸 LiveWallPaper,使您的桌面更加生动有趣。作为 2010 年 Google 暑期大学生博客分享大赛 Android 篇的一部分,我们将详细介绍 Ed Burnette 的《Hello, Android》第三版中的相关内容,并分享一些实用的开发技巧和经验。通过本篇文章,您将了解到如何利用 Android SDK 创建引人入胜的动态壁纸,提升用户体验。 ... [详细]
  • Netty框架中运用Protobuf实现高效通信协议
    在Netty框架中,通过引入Protobuf来实现高效的通信协议。为了使用Protobuf,需要先准备好环境,包括下载并安装Protobuf的代码生成器`protoc`以及相应的源码包。具体资源可从官方下载页面获取,确保版本兼容性以充分发挥其性能优势。此外,配置好开发环境后,可以通过定义`.proto`文件来自动生成Java类,从而简化数据序列化和反序列化的操作,提高通信效率。 ... [详细]
  • SQLite数据库CRUD操作实例分析与应用
    本文通过分析和实例演示了SQLite数据库中的CRUD(创建、读取、更新和删除)操作,详细介绍了如何在Java环境中使用Person实体类进行数据库操作。文章首先阐述了SQLite数据库的基本概念及其在移动应用开发中的重要性,然后通过具体的代码示例,逐步展示了如何实现对Person实体类的增删改查功能。此外,还讨论了常见错误及其解决方法,为开发者提供了实用的参考和指导。 ... [详细]
author-avatar
窝窝六六柒柒巴巴
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有