美文网首页
dubbo源码学习-核心组件ExtensionLoader

dubbo源码学习-核心组件ExtensionLoader

作者: 一驴绝尘 | 来源:发表于2018-08-08 10:11 被阅读0次

    原创不易,转发请表明出处

    源码学习版本为 2.6.2-SNAPSHOT,源码注释网址为 

    ExtensionLoader是dubbo中核心的组件,主要的作用就是

    1 根据参数值,自动注入拓展插件

    2 包装拓展插件

    先上一个源码中使用的例子,在解析dubbo的配置文件时,解析服务有个核心配置类,是ServiceConfig,这个后面会介绍,里面初始化Protocol类的代码如下:

    // 获取协议的包装类,默认是 dubbo协议

    private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();

    Protocol接口定义如下

    @SPI("dubbo")

    public interface Protocol {

        int getDefaultPort();

        @Adaptive

        Exporter export(Invoker invoker)throws RpcException;

        @Adaptive

        Invoker refer(Class type, URL url)throws RpcException;

        void destroy();

    }

    之后在下面的 doExportUrlsFor1Protocol()方法是这么用的

    Exporter exporter =protocol.export(wrapperInvoker);

    这个地方的入参是

    调用的其实是protocol 的实现类 RegistryProtocol中的export(final Invoker originInvoker)方法

    protocol的实现类有很多,程序怎么知道用哪个实现类呢,这就是ExtensionLoader的强大神奇之处,下面一一道来

    万事讲源头,再贴一下刚刚开始举得例子的代码,就是 Protocol初始化的那个地方

    private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();

    //  ExtensionLoader  中的 getExtensionLoader ()方法, 已去除校验逻辑,保留核心逻辑

    @SuppressWarnings("unchecked")

    public static ExtensionLoader getExtensionLoader(Class type) {

    // java设计模式,亨元模式,首先从缓存中获取,如果获取不到,初始化并返回

        ExtensionLoader loader = (ExtensionLoader)EXTENSION_LOADERS.get(type);

        if (loader ==null) {

            EXTENSION_LOADERS.putIfAbsent(type, new ExtensionLoader(type));

            loader = (ExtensionLoader)EXTENSION_LOADERS.get(type);

        }

    return loader;

    }

    这个地方做的事情就是根据传入接口,初始化ExtensionLoader类,并返回,看来是ExtensionLoader 的 getAdaptiveExtension() 是核心,下面看看核心!

    ExtensionLoader 中的getAdaptiveExtension()方法

    // 也是保留核心逻辑

    instance = createAdaptiveExtension();

    return (T) instance;

    这个地方就是调用createAdaptiveExtension()方法,创建包装,继续顺藤摸瓜

    ExtensionLoader 中的createAdaptiveExtension()方法

    return injectExtension((T) getAdaptiveExtensionClass().newInstance());

    这个需要分两步去看,首先是 (T) getAdaptiveExtensionClass().newInstance(),其次是 injectExtension(T instance)

    首先看 ExtensionLoader 中的getAdaptiveExtensionClass()方法,这个方法是想获取T的字节码class文件,也是用到了亨元模式先从缓存取,如果没有,调用createAdaptiveExtensionClass()方法创建

    private Class createAdaptiveExtensionClass() {

    // 动态代理,获取Protocol的包装的代码字符串,具体内容见注1,核心中的核心

    String code = createAdaptiveExtensionClassCode(); 

        ClassLoader classLoader =findClassLoader();

        com.alibaba.dubbo.common.compiler.Compiler compiler =      ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.common.compiler.Compiler.class).getAdaptiveExtension();

        return compiler.compile(code, classLoader);

    }

    其实 (T) getAdaptiveExtensionClass().newInstance()返回的是动态代理生成的类的实例,动态代理的内容是注1中的内容,动态代理生成的类的核心逻辑就是增强Protocol中的export()方法,根据 Invoker中的url的protocol决定具体的实现类,再去调用具体实现类的export()方法

    再看 ExtensionLoader 中的injectExtension(T instance)()方法,保持核心逻辑的源码如下

    for (Method method : instance.getClass().getMethods()) {

        if (method.getName().startsWith("set")&& method.getParameterTypes().length ==1

    && Modifier.isPublic(method.getModifiers())) {

    Class pt = method.getParameterTypes()[0];

            try {

        String property = method.getName().length() >3 ? method.getName().substring(3, 4).toLowerCase() + method.getName().substring(4) :""; // 获取属性名

                Object object =objectFactory.getExtension(pt, property);  // 获取属性值

                if (object !=null) {

                      method.invoke(instance, object); // 反射设置属性值

                }

    }

    }

    代码主要的逻辑就是从 objectFactory 获取属性值,之后通过反射初始化属性,

    在 注1中有个方法,也是 ExtensionLoader的核心方法,摘取自注1中的代码如下:

    ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName)

    ExtensionLoader类中getExtension(String name)方法,保留核心逻辑代码如下:

    instance = createExtension(name);

    ExtensionLoader类的 createExtension(String name)方法,这其中的核心逻辑是调用 getExtensionClasses(),之后调用

    loadExtensionClasses()方法,之后核心逻辑如下:

    loadDirectory(extensionClasses, DUBBO_INTERNAL_DIRECTORY);

    loadDirectory(extensionClasses, DUBBO_DIRECTORY);

    loadDirectory(extensionClasses, SERVICES_DIRECTORY);

    会从"META-INF/services/"和"META-INF/dubbo/" 和 "META-INF/dubbo/internal/"路径下,读取配置文件,加载到ExtensionLoader的cachedClasses字段中,

    Protocol接口的配置文件名字是com.alibaba.dubbo.rpc.Protocol,这个文件有可能分散在不同模块下,内容如下

    filter=com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper

    listener=com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper

    mock=com.alibaba.dubbo.rpc.support.MockProtocol

    不加载后缀是 Wrapper的

    至此,总结如下

    ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();其实就是动态代理获取Protocol的代理包装类,类的内容见注1,之后根据代理类的逻辑执行具体逻辑。

    注1:根据createAdaptiveExtensionClassCode()方法生成的字符串类型的class文件,核心逻辑是根据传入的泛型T以及其中方法上的@Adaptive注解,创建动态代理,创建的内容如下

    package com.alibaba.dubbo.rpc;

    import com.alibaba.dubbo.common.extension.ExtensionLoader;

    public class Protocol$Adaptive implements com.alibaba.dubbo.rpc.Protocol { // 生成的为 Protocol 的内部类  Adaptive

    public void destroy() {

    throw new UnsupportedOperationException("method public abstract void com.alibaba.dubbo.rpc.Protocol.destroy() of interface com.alibaba.dubbo.rpc.Protocol is not adaptive method!");

    }

    public int getDefaultPort() {

    throw new UnsupportedOperationException("method public abstract int com.alibaba.dubbo.rpc.Protocol.getDefaultPort() of interface com.alibaba.dubbo.rpc.Protocol is not adaptive method!");

    }

    // 核心方法

    public com.alibaba.dubbo.rpc.Exporter export(com.alibaba.dubbo.rpc.Invoker arg0) throws com.alibaba.dubbo.rpc.RpcException {

    if (arg0 == null) throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument == null");

    if (arg0.getUrl() == null) throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");com.alibaba.dubbo.common.URL url = arg0.getUrl();

    String extName = ( url.getProtocol() == null ? "dubbo" : url.getProtocol() ); //获取当前协议

    if(extName == null) throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.Protocol) name from url(" + url.toString() + ") use keys([protocol])");

    com.alibaba.dubbo.rpc.Protocol extension = (com.alibaba.dubbo.rpc.Protocol)ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName);  // 根据当前协议名获取实际的实现类

    return extension.export(arg0);

    }

    // 下面是引用远程服务的方法

    public com.alibaba.dubbo.rpc.Invoker refer(java.lang.Class arg0, com.alibaba.dubbo.common.URL arg1) throws com.alibaba.dubbo.rpc.RpcException {

    if (arg1 == null) throw new IllegalArgumentException("url == null");

    com.alibaba.dubbo.common.URL url = arg1;

    String extName = ( url.getProtocol() == null ? "dubbo" : url.getProtocol() );

    if(extName == null) throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.Protocol) name from url(" + url.toString() + ") use keys([protocol])");

    com.alibaba.dubbo.rpc.Protocol extension = (com.alibaba.dubbo.rpc.Protocol)ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName);

    return extension.refer(arg0, arg1);

    }

    }

    相关文章

      网友评论

          本文标题:dubbo源码学习-核心组件ExtensionLoader

          本文链接:https://www.haomeiwen.com/subject/qnrtbftx.html