Spring-Retry实现及原理

这篇具有很好参考价值的文章主要介绍了Spring-Retry实现及原理。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

前言

重试,其实我们其实很多时候都需要的,为了保证容错性,可用性,一致性等。一般用来应对外部系统的一些不可预料的返回、异常等,特别是网络延迟,中断等情况。还有在现在流行的微服务治理框架中,通常都有自己的重试与超时配置,比如dubbo可以设置retries=1,timeout=500调用失败只重试1次,超过500ms调用仍未返回则调用失败。如果我们要做重试,要为特定的某个操作做重试功能,则要硬编码,大概逻辑基本都是写个循环,根据返回或异常,计数失败次数,然后设定退出条件。这样做,且不说每个操作都要写这种类似的代码,而且重试逻辑和业务逻辑混在一起,给维护和扩展带来了麻烦。从面向对象的角度来看,我们应该把重试的代码独立出来。
 

痛点

请看大屏幕

Spring-Retry实现及原理

一、代码实现


①maven引入依赖

<dependency>

    <groupId>org.springframework.retry</groupId>

    <artifactId>spring-retry</artifactId>

</dependency>

②启动类

proxyTargetClass :指定动态代理使用JDK还是CGLIB

@EnableRetry(proxyTargetClass = true)

③重试方法(需要重试的方法)

核心注解:@Retryable

@Retryable(value = Exception.class, maxAttempts = 3, backoff = @Backoff(delay = 2000, multiplier = 1.5))

@Override

public int retry(int code) throws Exception {

    System.out.println("retry方法被调用,时间:" + LocalTime.now());

    if (0 == 0) {

        throw new Exception("调用异常了");

    }

    System.out.println("retry方法正常调用");

    return 200;

}

④回调方法(重试失败之后的兜底操作)

核心注解:@Recover

@Recover

public int recover(Exception e, int code) {

    System.out.println("执行回调方法!!!!" + code);

    //记日志到数据库 或者调用其余的方法

    return 400;

}

踩坑:

踩坑

1、异常处理方法返回参数必须与retry方法保持一致
2、该方法必须与retry方法在同一个类中

以上就对一个方法完成了一个简单的重试功能。


 

二、首先了解一些关键内容

①重试策略:看一下Spring Retry自带的一些重试策略,主要是用来判断当方法调用异常时是否需要重试

Spring-Retry实现及原理

  • SimpleRetryPolicy 默认最多重试3次
  • TimeoutRetryPolicy 默认在1秒内失败都会重试
  • ExpressionRetryPolicy 符合表达式就会重试
  • CircuitBreakerRetryPolicy 增加了熔断的机制,如果不在熔断状态,则允许重试
  • CompositeRetryPolicy 可以组合多个重试策略
  • NeverRetryPolicy 从不重试(也是一种重试策略哈)
  • AlwaysRetryPolicy 总是重试

②退避策略:退避是指怎么去做下一次的重试,在这里其实就是等待多长时间

Spring-Retry实现及原理

  • FixedBackOffPolicy 默认固定延迟1秒后执行下一次重试
  • ExponentialBackOffPolicy 指数递增延迟执行重试,默认初始0.1秒,系数是2,那么下次延迟0.2秒,再下次就是延迟0.4秒,如此类推,最大30秒。
  • ExponentialRandomBackOffPolicy 在上面那个策略上增加随机性
  • UniformRandomBackOffPolicy 这个跟上面的区别就是,上面的延迟会不停递增,这个只会在固定的区间随机
  • StatelessBackOffPolicy 这个说明是无状态的,所谓无状态就是对上次的退避无感知,从它下面的子类也能看出来

三、引出问题,Spring是如何实现的

①入口注解:@EnableRetry

Spring-Retry实现及原理  

核心注解

1、开启AOP:@EnableAspectJAutoProxy(proxyTargetClass = false)

2、注入RetryConfiguration:@Import(RetryConfiguration.class)  (核心)

②一起看看RetryConfiguration是干什么的
继承AbstractPointcutAdvisor,实现IntroductionAdvisor, BeanFactoryAware Spring-Retry实现及原理

上面断处是我们AOP中熟悉的切面和增强

③核心拦截器:AnnotationAwareRetryOperationsInterceptor

Spring-Retry实现及原理

Spring-Retry实现及原理

核心实现: Spring-Retry实现及原理

 这里主要是看我们有没有自定义拦截器,如果有的话,默认优先使用自定义的拦截器。


简单实现:getStatelessInterceptor
Spring-Retry实现及原理

④核心拦截器:RetryOperationsInterceptor
Spring源码中一般出现了execute(),一般就是真正开始干活了,这里也一样

Spring-Retry实现及原理

⑤具体实现

1、第一个标注点:判断是否可以重试

2、第二个标注点:执行重试

Spring-Retry实现及原理

 Spring-Retry实现及原理

⑥三种实现

 Spring-Retry实现及原理

 这三个类都是Java中的线程休眠工具类,但它们的作用略有不同:

  1. ObjectWaitSleeper:该类是通过调用对象的wait()方法来使线程休眠的。当一个线程调用对象的wait()方法时,它会释放该对象的锁,并进入等待状态,直到其他线程调用该对象的notify()或notifyAll()方法来唤醒它。

  2. StealingSleeper:该类是通过调用Thread.yield()方法来使线程休眠的。当一个线程调用Thread.yield()方法时,它会暂停当前线程的执行,让其他线程有机会运行。

  3. ThreadWaitSleeper:该类是通过调用Thread.sleep()方法来使线程休眠的。当一个线程调用Thread.sleep()方法时,它会暂停当前线程的执行,让其他线程有机会运行,但不会释放任何锁。

⑦ThreadWaitSleeper

Spring-Retry实现及原理文章来源地址https://www.toymoban.com/news/detail-471529.html

到了这里,关于Spring-Retry实现及原理的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 如果你需要使用重试机制,请使用Spring官方的Spring Retry

    Spring Retry 是 Spring Framework 中的一个模块,提供了一种简单的方式来在应用程序中实现重试机制。 在应用程序中,如果遇到了一些不可避免的错误,比如网络连接失败、数据库连接失败等,我们通常需要对这些错误进行重试,以尝试解决这些问题。 Spring Retry 提供了一个可插拔

    2024年02月13日
    浏览(39)
  • rabbitmq:retry重试机制和延迟消息的实现

    rabbitmq:retry重试机制和延迟消息的实现 在消费者消费消息的时候可能会因为网络等外部原因导致消息处理失败,这个时候如果将消息直接丢弃会导致正常的业务丢失,但是如果是一条本身就有问题的消息,那么这个时候又必须丢弃掉,如果选择用channel.basicNack 或 channel.basi

    2024年02月13日
    浏览(42)
  • axios-retry插件-axios请求失败自动重试

    axios-retry 对外导出 axiosRetry() 方法: 通过对 axios 单例添加“拦截器”,来扩展实现自动重试网络请求功能。 备注:  除非  shouldResetTimeout 被设置, 这个插件 将请求超时解释为全局值, 不是针对每一个请求,二是全局的设置 Name Type Default Description retries Number 3 The number of times t

    2024年02月10日
    浏览(77)
  • 分布式重试服务平台 Easy-Retry

      在介绍这款开源产品前先给大家介绍一个开源组织:aizuda–爱组搭   可以看到Easy-Retry就是爱组搭的开源项目之一。   在分布式系统大行其道的当前,系统数据的准确性和正确性是重大的挑战,基于CAP理论,采用柔性事务,保障系统可用性以及数据的最终一致性成为

    2024年02月09日
    浏览(39)
  • 高效处理消息:使用Spring Boot实现消息重试机制

    当涉及到消息发送和接收的可靠性,Spring Boot提供了一些机制来确保消息的可靠传递。其中包括消息确认机制和重试机制。下面是一个示例代码,演示如何在Spring Boot中实现可靠的消息发送和接收。 首先,我们需要配置RabbitMQ的连接信息和相关属性。在 application.properties 文件中

    2024年02月11日
    浏览(48)
  • Spring Retry

    工作中,经常遇到需要重试的场景,最简单的方式可以用try...catch...加while循环来实现。那么,有没有统一的、优雅一点儿的处理方式呢?有的,Spring Retry就可以帮我们搞定重试问题。 关于重试,我们可以关注以下以下几个方面: 什么情况下去触发重试机制 重试多少次,重试

    2024年02月05日
    浏览(49)
  • spring retry 配置及使用

    依赖 开始使用 代码示例 业务注解 代码示例 注意 两个方法的返回值要一样,否则是不起作用的 NullPointerException 必须要将异常类型当作参数传入 如果不这样的话无法进行回调,当然不配置 @Recever 也可以,那就不会有回调处理了 写一个action 调用一下方法 输出结果 以上最简单

    2024年01月19日
    浏览(38)
  • Spring retry(一)-使用指南

    spring boot 2.7.14 spring retry 从2.0.2版本之后,从spring batch里剥离出来成为一个单独的工程,因此我们引入spring retry最新版本可以直接如下引入 启动类上打上注解@EnableRetry Spring retry作为重试组件,可以直接使用@Retryable注解;废话不多说,直接上代码 执行效果如下 retryFor指定异常

    2024年02月10日
    浏览(43)
  • 我是如何使用Spring Retry减少1000 行代码

    本文翻译自国外论坛 medium,原文地址:https://levelup.gitconnected.com/how-i-deleted-more-than-1000-lines-of-code-using-spring-retry-9118de29060 使用 Spring Retry 重构代码的综合指南。 在我的日常工作中,我主要负责开发一个庞大的金融应用程序。当客户发送请求时,我们使用他们的用户 ID 从第三方

    2024年02月12日
    浏览(31)
  • Spring retry(二)- 源码解析-启动装配篇 @EnableRetry

    上一篇文章,我们快速介绍了下spring-retry的使用技巧,本篇我们将会剖析源码去学习 英文翻译我就不再解释了,上面说的很清楚;这里重点提一下@Import(RetryConfiguration.class)这个注解,表明了@EnableRetry注解的启动配置类是RetryConfiguration, 通过@Import注解来注入对应的配置类,这

    2024年02月10日
    浏览(39)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包