版本

2.5.7

ExtensionLoader機(jī)制

Dubbo 的擴(kuò)展點(diǎn)加載從 JDK 標(biāo)準(zhǔn)的 SPI (Service Provider Interface) 擴(kuò)展點(diǎn)發(fā)現(xiàn)機(jī)制加強(qiáng)而來(lái)。
Dubbo 改進(jìn)了 JDK 標(biāo)準(zhǔn)的 SPI 的以下問(wèn)題：

1. JDK 標(biāo)準(zhǔn)的 SPI 會(huì)?次性實(shí)例化擴(kuò)展點(diǎn)所有實(shí)現(xiàn)，如果有擴(kuò)展實(shí)現(xiàn)初始化很耗時(shí)，但如果沒(méi)用上也加載，會(huì)很浪費(fèi)資源；
2. 如果擴(kuò)展點(diǎn)加載失敗，連擴(kuò)展點(diǎn)的名稱(chēng)都拿不到了。?如：JDK 標(biāo)準(zhǔn)的 ScriptEngine，通過(guò)getName()獲取腳本類(lèi)型的名稱(chēng)，但如果 RubyScriptEngine 因?yàn)樗蕾?lài)的 jruby.jar 不存在，導(dǎo)致 RubyScriptEngine類(lèi)加載失敗，這個(gè)失敗原因被吃掉了，和 ruby對(duì)應(yīng)不起來(lái)，當(dāng)用戶(hù)執(zhí)行ruby 腳本時(shí)，會(huì)報(bào)不支持ruby，而不是真正失敗的原因；
3. 增加了對(duì)擴(kuò)展點(diǎn) IoC 和 AOP 的支持，?個(gè)擴(kuò)展點(diǎn)可以直接 setter 注?其它擴(kuò)展點(diǎn)。

以上內(nèi)容摘自官方文檔

ExtensionLoader的作用就是加載所有打上了@SPI注解的接口，并根據(jù)配置進(jìn)行實(shí)例化、封裝，包括dubbo自己的服務(wù)調(diào)用、暴露等功能,也是使用這種方式實(shí)現(xiàn)的。

加載過(guò)程

1、實(shí)例化ExtensionLoader

構(gòu)造方法：

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

從代碼中可以看出，ExrtensionLoader與SPI是一一對(duì)應(yīng)的關(guān)系，且每個(gè)封裝了SPI的ExrtensionLoader都保存了一個(gè)objectFactory對(duì)象，而objectFactory指向的都是ExrtensionLoader的adaptive實(shí)現(xiàn)，即AdaptiveExtensionFactory。

1.1 AdaptiveExtension實(shí)例化過(guò)程

getAdaptiveExtension的實(shí)例化使用了互斥鎖，檢查了是否有實(shí)例化異常 的緩存后，通過(guò)createAdaptiveExtension()方法實(shí)例化對(duì)象。
在實(shí)例化的過(guò)程中，會(huì)再次執(zhí)行getExtensionClasses()方法檢查是否已加載過(guò)配置文件。 以ExtensionFactory舉例，因?yàn)樵?code>dubbo-common的配置文件中，已經(jīng)默認(rèn)配置了ExtensionFactory的兩個(gè)實(shí)現(xiàn)，且其AdaptiveExtensionFactory上打了@Adaptive注解，所以默認(rèn)情況下會(huì)返回緩存中，第一次加載配置文件時(shí)初始化的AdaptiveExtensionFactory類(lèi)。
但如果緩存中沒(méi)有，比如Protocol就沒(méi)有在實(shí)現(xiàn)類(lèi)類(lèi)上注解@Adaptive，也沒(méi)關(guān)系，ExrtensionLoader會(huì)通過(guò)createAdaptiveExtensionClass()方法生成代碼，再編譯成class字節(jié)碼。
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動(dòng)態(tài)生成的實(shí)現(xiàn)類(lèi)：

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注解的方法，都會(huì)動(dòng)態(tài)生成根據(jù)URL獲取信息的代碼，再組合成對(duì)應(yīng)的實(shí)現(xiàn)類(lèi)，并存儲(chǔ)到ExtensionLoader的靜態(tài)變量中，以后就可以通過(guò)ExtensionLoader加載對(duì)應(yīng)的SPI實(shí)現(xiàn)，然后執(zhí)行業(yè)務(wù)邏輯。

2、獲取ExtensionLoader

ExtensionFactory也是一種SPI，所有的SPI都是通過(guò)ExtensionLoader來(lái)封裝、加載的，每個(gè)被封裝的對(duì)象中都由ExtensionFactory objectFactory屬性持有一個(gè)ExtensionFactory的Adaptive實(shí)現(xiàn)AdaptiveExtensionFactory,而AdaptiveExtensionFactory又由List<ExtensionFactory> factories持有兩個(gè)對(duì)象SpiExtensionFactory及SpringExtensionFactory。
他們的對(duì)比如下：

當(dāng)執(zhí)行AdaptiveExtensionFactory的getExtension()方法時(shí)，它會(huì)輪詢(xún)二者之中有沒(méi)有要返回的對(duì)象，優(yōu)先SPI的方式。

總結(jié)

通過(guò)ExtensionLoader機(jī)制，dubbo封裝了所有SPI實(shí)現(xiàn)，并能夠使用@Adaptive注解指定默認(rèn)的實(shí)現(xiàn)，或者注解在方法上，動(dòng)態(tài)將不同實(shí)現(xiàn)類(lèi)的A\B\C方法組合成新的實(shí)現(xiàn)類(lèi)，在靈活、可配、按需加載等方面做的非常出色。