18. SpringCloud之Hystrix源码

2022-04-29 本文已影响0人天还下着毛毛雨

image.png

1、前言

hystrix是通过对接口方法进行AOP代理的方式来达到对某一个请求进行熔断降级的功能的。

所以，我们研究hystrix的核心源码，首先是要找到这个切面在哪生成的，干了什么。

2、@EnableCircuitBreaker

我们引入hystrix的时候，除了导入依赖之外，还会在启动类上加上@EnableCircuitBreaker注解表示启用hystrix的熔断降级等组件。

@Enable****之类的注解都表示启动什么什么功能。点进源码看, 其实一般都会做一些导入类，注册的事情。

比如@EnableCircuitBreaker 点进去就会 import EnableCircuitBreakerImportSelector类。

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@Import(EnableCircuitBreakerImportSelector.class)
public @interface EnableCircuitBreaker {

}

所以我们先看这个类干了什么、

2.1、EnableCircuitBreakerImportSelector

点进源码，发现集成了 SpringFactoryImportSelector类

@Order(Ordered.LOWEST_PRECEDENCE - 100)
public class EnableCircuitBreakerImportSelector extends
      SpringFactoryImportSelector<EnableCircuitBreaker> {

   @Override
   protected boolean isEnabled() {
      return getEnvironment().getProperty(
            "spring.cloud.circuit.breaker.enabled", Boolean.class, Boolean.TRUE);
   }

}

点进 SpringFactoryImportSelector 类

可以看到实现了DeferredImportSelector接口,

DeferredImportSelector接口又继承 ImportSelector接口，实现selectImports方法。

image.png

实现ImportSelector接口的类主要就是用来导入一些类的。

那么实现ImportSelector接口的类，被实例化bean的时候,会调到selectImports，传入@Import它的那个类的元数据对象, 然后返回一个需要被注册到Spring容器中的类全限定性名数组。

2.1.1、SPI机制

而SpringFactoryImportSelector 父类实现的selectImports 则会返回META-INF/Spring.factories里配置的 key = org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker 的类的全限定性列表, 让Spring 注册这些类的实例。

image.png

2.1.2、META-INF/Spring.factories

这个文件在org.springframework.cloud:spring-cloud-netflix-core:2.0.0.RELEASE2包下

image.png

所以最终SpringFactoryImportSelector类的selectImports最终返回(导入)org.springframework.cloud.netflix.hystrix.HystrixCircuitBreakerConfiguration这个类，让Spring注册它的实例。

3、切面的注册

点进org.springframework.cloud.netflix.hystrix.HystrixCircuitBreakerConfiguration

可以看到用@Bean注册了一个切面

image.png

就是我们平时用的aop，切入点为加了@HystrixCommand的方法, 我们使用hystrix的时候用的就是这个注解。

image.png

最终会用环绕通知 @Around 来对加了@HystrixCommand的方法进行增强。那么hystrix对接口方法的熔断降级，服务隔离等功能就在这个methodsAnnotatedWithHystrixCommand方法里。

4、代理逻辑

接下来我们看下环绕通知里关于熔断降级，服务隔离的核心源码。

CommandExecutor.execute 会返回结果，最终return出去，点进去

image.png

里面分同步调用，异步调用。

image.png

异步调用的话，会调用HystrixExecutable的queue()方法，返回一个Future对象，异步执行，不等待返回结果。

image.png

同步调用在调用queue方法返回Future对象之外, 还会调用Future对象的get方法，阻塞等待返回结果，以达到同步的效果。

image.png

所以，我们看queue()方法就好了。

HystrixCommand.queue()

点进toObservable()方法

image.png

toObservable() 会创建一堆的匿名对象，我们看Hystrix主体的逻辑的那个

image.png

代码applyHystrixSemantics对象的call方法，最终调用applyHystrixSemantics(_cmd)方法

点进去。

image.png

这里就是Hystrix的核心逻辑所在。

4.1、判断是否允许接受请求

circuitBreaker.attemptExecution()是用来判断是否允许接受请求

点进HystrixCircuitBreakerImpl实现的attemptExecution()方法

image.png

4.1.1、是否强制开启断路器和是否强制关闭断路器

是否强制开启断路器和是否强制关闭断路器都是由我们的配置决定的，对应HystrixCommandProperties的这两个属性。

image.png

默认值都为false

image.png

4.1.2、滚动窗口时间的判断

回顾一下熔断机制里的滚动窗口时间的作用, 就是当熔断开启后, 拒绝请求，过了滚动窗口时间之后，熔断器状态会变成半开状态，然后下一次请求成功，则将熔断器从半开状态变为关闭状态，如果请求失败，则还是变为开启状态，拒绝请求。等再过了滚动窗口时间之后，又进行这样的机制，周而复始。

看下isAfterSleepWindow()源码对是否需要开启半开状态的判断

private boolean isAfterSleepWindow() {
    // 上一次熔断器开启的的时间
    final long circuitOpenTime = circuitOpened.get();
    // 当前时间
    final long currentTime = System.currentTimeMillis();
    // 滚动窗口的时间
    final long sleepWindowTime = properties.circuitBreakerSleepWindowInMilliseconds().get();
    // 如果当前时间 > 上一次 开启熔断器的时间 + 滚动窗口的时间，则返回ture,更新为半开状态
    return currentTime > circuitOpenTime + sleepWindowTime;
}

这里滚动窗口时间也是一个配置