ExtensionLoader解析

版本

2.5.7

ExtensionLoader机制

Dubbo 的扩展点加载从 JDK 标准的 SPI (Service Provider Interface) 扩展点发现机制加强而来。
Dubbo 改进了 JDK 标准的 SPI 的以下问题:

  1. JDK 标准的 SPI 会⼀次性实例化扩展点所有实现,如果有扩展实现初始化很耗时,但如果没用上也加载,会很浪费资源;
  2. 如果扩展点加载失败,连扩展点的名称都拿不到了。⽐如:JDK 标准的 ScriptEngine,通过getName()获取脚本类型的名称,但如果 RubyScriptEngine 因为所依赖的 jruby.jar 不存在,导致 RubyScriptEngine类加载失败,这个失败原因被吃掉了,和 ruby对应不起来,当用户执行ruby 脚本时,会报不支持ruby,而不是真正失败的原因;
  3. 增加了对扩展点 IoC 和 AOP 的支持,⼀个扩展点可以直接 setter 注⼊其它扩展点。
以上内容摘自官方文档

ExtensionLoader的作用就是加载所有打上了@SPI注解的接口,并根据配置进行实例化、封装,包括dubbo自己的服务调用、暴露等功能,也是使用这种方式实现的。

加载过程

1、实例化ExtensionLoader

构造方法:

    private ExtensionLoader(Class<?> type) {
        this.type = type;
        objectFactory = (type == ExtensionFactory.class ? null : ExtensionLoader.getExtensionLoader(ExtensionFactory.class).getAdaptiveExtension());
    }

从代码中可以看出,ExrtensionLoaderSPI是一一对应的关系,且每个封装了SPIExrtensionLoader都保存了一个objectFactory对象,而objectFactory指向的都是ExrtensionLoader的adaptive实现,即AdaptiveExtensionFactory

1.1 AdaptiveExtension实例化过程

getAdaptiveExtension的实例化使用了互斥锁,检查了是否有实例化异常 的缓存后,通过createAdaptiveExtension()方法实例化对象。
在实例化的过程中,会再次执行getExtensionClasses()方法检查是否已加载过配置文件。 以ExtensionFactory举例,因为在dubbo-common的配置文件中,已经默认配置了ExtensionFactory的两个实现,且其AdaptiveExtensionFactory上打了@Adaptive注解,所以默认情况下会返回缓存中,第一次加载配置文件时初始化的AdaptiveExtensionFactory类。
但如果缓存中没有,比如Protocol就没有在实现类类上注解@Adaptive,也没关系,ExrtensionLoader会通过createAdaptiveExtensionClass()方法生成代码,再编译成class字节码。
Protocol接口源码

package com.alibaba.dubbo.rpc;

import com.alibaba.dubbo.common.URL;
import com.alibaba.dubbo.common.extension.Adaptive;
import com.alibaba.dubbo.common.extension.SPI;

@SPI("dubbo")
public interface Protocol {
    int getDefaultPort();
    void destroy();
    @Adaptive
    <T> Exporter<T> export(Invoker<T> invoker) throws RpcException;
    @Adaptive
    <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException;
}

Protocol动态生成的实现类:

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

public class Protocol$Adaptive implements com.alibaba.dubbo.rpc.Protocol {
    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);
    }
}

可以看出,打了@Adaotive注解的方法,都会动态生成根据URL获取信息的代码,再组合成对应的实现类,并存储到ExtensionLoader的静态变量中,以后就可以通过ExtensionLoader加载对应的SPI实现,然后执行业务逻辑。

2、获取ExtensionLoader

名称 配置位置 getExtension方法实现
SpiExtensionFactory dubbo-common ExtensionLoader的静态Map中读取对象,若没有,则通过new关键字创建ExtensionLoader
SpringExtensionFactory dubbo-config/dubbo-config-spring 从Spring上下文中读取对象

ExtensionFactory也是一种SPI,所有的SPI都是通过ExtensionLoader来封装、加载的,每个被封装的对象中都由ExtensionFactory objectFactory属性持有一个ExtensionFactory的Adaptive实现AdaptiveExtensionFactory,而AdaptiveExtensionFactory又由List<ExtensionFactory> factories持有两个对象SpiExtensionFactorySpringExtensionFactory
他们的对比如下:

名称 配置位置 getExtension方法实现
SpiExtensionFactory dubbo-common ExtensionLoader的静态Map中读取对象,若没有,则通过new关键字创建ExtensionLoader
SpringExtensionFactory dubbo-config/dubbo-config-spring 从Spring上下文中读取对象

当执行AdaptiveExtensionFactorygetExtension()方法时,它会轮询二者之中有没有要返回的对象,优先SPI的方式。

总结

通过ExtensionLoader机制,dubbo封装了所有SPI实现,并能够使用@Adaptive注解指定默认的实现,或者注解在方法上,动态将不同实现类的A\B\C方法组合成新的实现类,在灵活、可配、按需加载等方面做的非常出色。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 202,802评论 5 476
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,109评论 2 379
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 149,683评论 0 335
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,458评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,452评论 5 364
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,505评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,901评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,550评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,763评论 1 296
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,556评论 2 319
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,629评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,330评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,898评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,897评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,140评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,807评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,339评论 2 342

推荐阅读更多精彩内容

  • 前面我们了解过了Java的SPI扩展机制,对于Java扩展机制的原理以及优缺点也有了大概的了解,这里继续深入一下D...
    加大装益达阅读 5,017评论 2 20
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,370评论 25 707
  • 几年前忽然迷上了游泳,成了游泳馆四季的常客,奔向大海畅游就成了时不时挥之不去的欲念。春节里曾徜徉于大东海亚龙湾,在...
    冬日之焱阅读 324评论 0 1
  • 文/夏莲 西湖堤岸的杨柳 该绿了吧 我想是抖擞的春风 悄然光顾了 那寂寞的城 香榭丽舍大道上 那灿然的梧桐 零落了...
    周小锦阅读 195评论 12 13
  • 知识是无罪的,但是一知半解却常常会制造麻烦,看看那些对着你指手画脚的门外汉们,他们根本不知道一件事情有多复杂,他们...
    雕兄_KYP阅读 1,284评论 2 11