Spring?cloud?Hystrix注解初始化源碼過程解讀

更新時(shí)間：2023年12月21日 14:34:53 作者：福

這篇文章主要為大家介紹了Hystrix初始化部分，我們從源碼的角度分析一下@EnableCircuitBreaker以及@HystrixCommand注解的初始化過程,有需要的朋友可以借鑒參考下,希望能夠有所幫助

從@EnableCircuitBreaker入手

我們是通過在啟動(dòng)類添加@EnableCircuitBreaker注解啟用Hystrix的，所以，源碼解析也要從這個(gè)注解入手。

該注解已經(jīng)被標(biāo)了@Deprecated了，不過，擋不住......

Spring關(guān)于@Enablexxxx注解的套路：通過@Import注解引入了EnableCircuitBreakerImportSelector.class：

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

}

跟蹤EnableCircuitBreakerImportSelector，繼承自SpringFactoryImportSelector<EnableCircuitBreaker>，注意SpringFactoryImportSelector類的泛型類型為EnableCircuitBreaker：

@Order(Ordered.LOWEST_PRECEDENCE - 100)
public class EnableCircuitBreakerImportSelector extends SpringFactoryImportSelector&lt;EnableCircuitBreaker&gt; {

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

}

看一下類圖：

屬性annotationClass通過GenericTypeResolver.resolveTypeArgument方法獲取當(dāng)前對(duì)象的泛型參數(shù)的具體類型，現(xiàn)在我們知道是EnableCircuitBreaker（在org.springframework.cloud.client.circuitbreaker包下）。

public abstract class SpringFactoryImportSelector<T>
        implements DeferredImportSelector, BeanClassLoaderAware, EnvironmentAware {
    private final Log log = LogFactory.getLog(SpringFactoryImportSelector.class);
    private ClassLoader beanClassLoader;
    private Class<T> annotationClass;
    private Environment environment;
    @SuppressWarnings("unchecked")
    protected SpringFactoryImportSelector() {
        this.annotationClass = (Class<T>) GenericTypeResolver.resolveTypeArgument(this.getClass(),
                SpringFactoryImportSelector.class);
    }

@Import注解我們前面做過詳細(xì)分析了，實(shí)現(xiàn)了DeferredImportSelector接口表示延遲加載全限定名稱為selectImports方法返回的類。看selectImports方法：

@Override
    public String[] selectImports(AnnotationMetadata metadata) {
        //Enable參數(shù)沒有打開的話就不加載
        if (!isEnabled()) {
            return new String[0];
        }
        AnnotationAttributes attributes = AnnotationAttributes
                .fromMap(metadata.getAnnotationAttributes(this.annotationClass.getName(), true));
        Assert.notNull(attributes, "No " + getSimpleName() + " attributes found. Is " + metadata.getClassName()
                + " annotated with @" + getSimpleName() + "?");
        // Find all possible auto configuration classes, filtering duplicates
        //SPI機(jī)制調(diào)用spring.factories文件下的EnableCircuitBreaker
        List<String> factories = new ArrayList<>(new LinkedHashSet<>(
                SpringFactoriesLoader.loadFactoryNames(this.annotationClass, this.beanClassLoader)));
        if (factories.isEmpty() && !hasDefaultFactory()) {
            throw new IllegalStateException("Annotation @" + getSimpleName()
                    + " found, but there are no implementations. Did you forget to include a starter?");
        }
        if (factories.size() > 1) {
            // there should only ever be one DiscoveryClient, but there might be more than
            // one factory
            this.log.warn("More than one implementation " + "of @" + getSimpleName()
                    + " (now relying on @Conditionals to pick one): " + factories);
        }
        return factories.toArray(new String[factories.size()]);
    }

selectImports方法的主要功能就是調(diào)用SpringFactoriesLoader.loadFactoryNames方法，該方法的目的是通過SPI機(jī)制讀取spring.factories文件中的org.springframework.cloud.client.circuitbreaker相關(guān)配置，返回。

返回的信息是類全限定名，從selectImports方法作用可知，這些類會(huì)加載到Spring Ioc容器中。

org.springframework.cloud.client.circuitbreaker在spring-cloud-netflix-hystrix-2.2.10.RELEASE包下：

所以該配置下的org.springframework.cloud.netflix.hystrix.HystrixCircuitBreakerConfiguration會(huì)被調(diào)用并加載到Spring IoC容器中。

HystrixCircuitBreakerConfiguration

跟蹤配置類HystrixCircuitBreakerConfiguration：

/**
 * @author Spencer Gibb
 * @author Christian Dupuis
 * @author Venil Noronha
 */
@Configuration(proxyBeanMethods = false)
public class HystrixCircuitBreakerConfiguration {
    @Bean
    public HystrixCommandAspect hystrixCommandAspect() {
        return new HystrixCommandAspect();
    }
    @Bean
    public HystrixShutdownHook hystrixShutdownHook() {
        return new HystrixShutdownHook();
    }

注入了一個(gè)叫HystrixCommandAspect 的bean，從名字上看，應(yīng)該是關(guān)于HystrixCommand的切面，用到了AOP。其實(shí)也容易理解，加了@HystrixCommand注解的方法的執(zhí)行邏輯發(fā)生了變化：方法增強(qiáng)了執(zhí)行時(shí)長(zhǎng)是否超時(shí)、執(zhí)行是否成功（是否返回異常）、超時(shí)或異常的情況下調(diào)用fallback......方法功能的增強(qiáng)正是AOP的強(qiáng)項(xiàng)。

繼續(xù)跟蹤HystrixCommandAspect 類。

HystrixCommandAspect

打開代碼，首先是非常熟悉的@Aspect注解：

@Aspect
public class HystrixCommandAspect {

表明當(dāng)前類是AOP的切面。

繼續(xù)看代碼：

@Pointcut("@annotation(com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand)")
    public void hystrixCommandAnnotationPointcut() {
    }
    @Pointcut("@annotation(com.netflix.hystrix.contrib.javanica.annotation.HystrixCollapser)")
    public void hystrixCollapserAnnotationPointcut() {
    }
    @Around("hystrixCommandAnnotationPointcut() || hystrixCollapserAnnotationPointcut()")
    public Object methodsAnnotatedWithHystrixCommand(final ProceedingJoinPoint joinPoint) throws Throwable {

添加了針對(duì)注解HystrixCommand的切點(diǎn)，以及針對(duì)該切點(diǎn)的環(huán)繞增強(qiáng)方法methodsAnnotatedWithHystrixCommand。

最終的熔斷、限流、服務(wù)降級(jí)功能，都是在這個(gè)methodsAnnotatedWithHystrixCommand方法里實(shí)現(xiàn)的，繼續(xù)向下研究這個(gè)方法的代碼邏輯，需要RxJava背景知識(shí)做支撐。

以上就是Spring cloud Hystrix注解初始化源碼過程解讀的詳細(xì)內(nèi)容，更多關(guān)于Spring cloud Hystrix注解初始化的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: