您现在的位置是:首页 >其他 >Spring-Retry实现及原理网站首页其他

Spring-Retry实现及原理

pyd950812 2024-07-21 06:01:03
简介Spring-Retry实现及原理

前言

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

痛点

请看大屏幕

一、代码实现


①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自带的一些重试策略,主要是用来判断当方法调用异常时是否需要重试

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

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

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

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

①入口注解:@EnableRetry

  

核心注解

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

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

②一起看看RetryConfiguration是干什么的
继承AbstractPointcutAdvisor,实现IntroductionAdvisor, BeanFactoryAware 

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

③核心拦截器:AnnotationAwareRetryOperationsInterceptor

核心实现: 

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


简单实现:getStatelessInterceptor

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

⑤具体实现

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

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

 

⑥三种实现

 

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

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

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

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

⑦ThreadWaitSleeper

风语者!平时喜欢研究各种技术,目前在从事后端开发工作,热爱生活、热爱工作。