Skip to content

Latest commit

 

History

History
113 lines (66 loc) · 4.23 KB

Dubbo底层源码学习（二）—— Dubbo的SPI机制（中）.md

File metadata and controls

113 lines (66 loc) · 4.23 KB
Raw

前言

在Dubbo的SPI机制（上）中，大致介绍了下ExtensionLoader的几个重要的成员变量，本篇文章将重点讲解下ExtensionLoader类、成员变量以及getExtension()等核心方法逻辑。

正文

1. ExtensionLoader的成员变量

  • ConcurrentMap<Class, ExtensionLoader> EXTENSION_LOADERS

    该变量主要作用是扩展带加载器缓存，key表示扩展点类的Class对象，value表示该扩展点类型的ExtensionLoader，表示为ExtensionLoader。

  • ConcurrentMap<Class<?>, Object> EXTENSION_INSTANCES

    该变量表示的是扩展点实现类对象的缓存，key表示扩展点类Class对象，value表示的是扩展点实现类对象实例。

  • Class<?> type

    该变量表示此时ExtensionLoader的类型，type就是代表的T。ExtensionLoader默认的T类型为ExtensionFactory。

  • ExtensionFactory objectFactory

    该变量表示的是扩展点加载器的扩展工厂，从ExtensionLoader的构造方法可以清楚，ExtensionLoader中的objectFactory默认为空。

  • ConcurrentMap<Class<?>, String> cachedNames

    这个变量表示的是扩展点类实现名称的缓存，key是对应的T的扩展点实现类Class，value是扩展点名称

  • Holder<Map<String, Class<?>>> cachedClasses

    这个变量表示的是扩展点实现类Class缓存 当前T的扩展点名称作为key，value是对应的扩展点实现类Class，这其中cachedNames和cahcedClasses是"KV相反关系"

  • Map<String, Object> cachedActivates

    这个变量表示的是@Activate注解的实现类缓存

  • Holder cachedAdaptiveInstance

    这个变量表示的是扩展点适配类型实例对象缓存

  • Class<?> cachedAdaptiveClass

    这个变量表示的是适配类型扩展点实现类对象的缓存

  • String cachedDefaultName

    这个变量表示的是当前扩展类加载器@SPI注解的value值，即默认的扩展名

  • LoadingStrategy[] strategies

    这个变量表示的是扩展点配置文件的加载策略

  • Set<Class<?>> cachedWrapperClasses

    这个变量表示的是包装类对象缓存

    • 在ExtensionLoader中， 依靠以上的各种缓存来实现扩展点实现类加载， 并且大量用到了双重检测，防止指令重排序的原理。

    2. ExtensionLoader的工作原理

    由于在本人的github仓库中fork了Dubbo官方源码，有一SourceCode-of-Translation分支已经标注有详细的注释，所以这里就不粘贴出来了

    在ExtensionLoader中，有三个逻辑入口，分别为getExtension、getAdaptiveExtension、getActivateExtension，分别是获取 普通扩展类、获取自适应扩展类、获取自动激活的扩展类。

    接下来的原理分析通过Dubbo源码中的test包下的代码来进行说明。（想学好开源框架，要好好利用开源框架中各种Test用例）

        @Test
    public void test_getDefaultExtension() throws Exception {
        SimpleExt ext = getExtensionLoader(SimpleExt.class).getDefaultExtension();
        assertThat(ext, instanceOf(SimpleExtImpl1.class));

        String name = getExtensionLoader(SimpleExt.class).getDefaultExtensionName();
        assertEquals("impl1", name);
    }

    分别来看下SimpleExt接口定义以及它的SPI配置文件内容。

    @SPI("impl1")
public interface SimpleExt {
    // @Adaptive example, do not specify a explicit key.
    @Adaptive
    String echo(URL url, String s);

    @Adaptive({"key1", "key2"})
    String yell(URL url, String s);

    // no @Adaptive
    String bang(URL url, int i);
}

    # Comment 1
impl1=org.apache.dubbo.common.extension.ext1.impl.SimpleExtImpl1#Hello World
impl2=org.apache.dubbo.common.extension.ext1.impl.SimpleExtImpl2  # Comment 2
   impl3=org.apache.dubbo.common.extension.ext1.impl.SimpleExtImpl3 # with head space

    首先SimpleExt接口由@SPI注解修饰，并且value值为impl1，由此可知SimpleExt的扩展点名称为impl1，扩展点实现类限定名称为org.apache.dubbo.common.extension.ext1.impl.SimpleExtImpl1

    但是程序内部是如何运行的呢？

    我用一张图来概括test_getDefaultExtension()方法的整个调用链过程。

    Dubbo-SPI-Test