Dubbo的SPI機(jī)制介紹以及Dubbo通過Wrapper實(shí)現(xiàn)AOP的方法

這篇文章主要介紹“Dubbo的SPI機(jī)制介紹以及Dubbo通過Wrapper實(shí)現(xiàn)AOP的方法”，在日常操作中，相信很多人在Dubbo的SPI機(jī)制介紹以及Dubbo通過Wrapper實(shí)現(xiàn)AOP的方法問題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”Dubbo的SPI機(jī)制介紹以及Dubbo通過Wrapper實(shí)現(xiàn)AOP的方法”的疑惑有所幫助！接下來，請(qǐng)跟著小編一起來學(xué)習(xí)吧！

1、Dubbo的通過Wrapper實(shí)現(xiàn)AOP例子

閱讀此篇文章之前,建議先學(xué)習(xí)該系列前面幾篇文章,會(huì)有一個(gè)更好的理解.

參考: Dubbo的SPI機(jī)制分析2-Adaptive詳解、Dubbo的SPI機(jī)制分析3-Dubbo的IOC依賴注入

// 在原有接口、實(shí)現(xiàn)類的基礎(chǔ)上再加一個(gè)Wrapper實(shí)現(xiàn)類
public class AdaptiveExtWrapper implements AdaptiveExt {

    private AdaptiveExt adaptiveExt;

    // 實(shí)現(xiàn)一個(gè)Wrapper類的關(guān)鍵就是提供一個(gè)帶類似參數(shù)的構(gòu)造函數(shù),后面代碼會(huì)分析
    public AdaptiveExtWrapper(AdaptiveExt adaptiveExt) {
        this.adaptiveExt = adaptiveExt;
    }

    @Override
    public String echo(String msg, URL url) {
        // do something,實(shí)現(xiàn)了AOP
        System.out.println("before");

        adaptiveExt.echo(msg, url);

        System.out.println("after");
        // do something
        return "wrapper";
    }
}

public class DubboAdaptiveExt implements AdaptiveExt {

    private AdaptiveExt adaptiveExt;

    // 此處DubboAdaptiveExt依賴注入一個(gè)AdaptiveExt 類型的實(shí)例,此處測(cè)試用例注入的是ThriftAdaptiveExt
    public void setAdaptiveExt(AdaptiveExt adaptiveExt) {
        this.adaptiveExt = adaptiveExt;
    }

    @Override
    public String echo(String msg, URL url) {
        System.out.println(this.adaptiveExt.echo(msg, url));
        return "dubbo";
    }
}

@Test
public void test1(){
    ExtensionLoader<AdaptiveExt> loader = ExtensionLoader.getExtensionLoader(AdaptiveExt.class);
    AdaptiveExt adaptiveExtension = loader.getExtension("dubbo");
    URL url = URL.valueOf("test://localhost/test");
    adaptiveExtension.echo("d", url);
}

同時(shí)記得dubbo的配置文件中要新增一行,否則dubbo框架無法掃描到Wrapper

dubbo=com.alibaba.dubbo.demo.provider.adaptive.impl.DubboAdaptiveExt
cloud=com.alibaba.dubbo.demo.provider.adaptive.impl.SpringCloudAdaptiveExt
thrift=com.alibaba.dubbo.demo.provider.adaptive.impl.ThriftAdaptiveExt
com.alibaba.dubbo.demo.provider.adaptive.impl.AdaptiveExtWrapper

運(yùn)行代碼,輸出:
before
thrift
after

2、Dubbo的通過Wrapper實(shí)現(xiàn)AOP源碼分析

可以發(fā)現(xiàn),上述代碼先后輸出before、after,中間輸出thrift,這其實(shí)可以說明adaptiveExtension = loader.getExtension("dubbo")返回的是AdaptiveExtWrapper類型的實(shí)例,有點(diǎn)像靜態(tài)代理,下面分析源代碼.

// 核心代碼,刪去一些不重要代碼
private T createExtension(String name) {
    // 這里也是通過dubbo的SPI機(jī)制去掃描dubbo的默認(rèn)目錄下的文件,去加載實(shí)現(xiàn)了AdaptiveExt的實(shí)現(xiàn)類,這里會(huì)
    // 加載4個(gè),包括AdaptiveExtWrapper,它就是下面的wrapperClasses中僅有的元素,下面先分析這個(gè)加載過程
    Class<?> clazz = getExtensionClasses().get(name);
   
    try {
        T instance = (T) EXTENSION_INSTANCES.get(clazz);
        if (instance == null) {
            EXTENSION_INSTANCES.putIfAbsent(clazz, clazz.newInstance());
            instance = (T) EXTENSION_INSTANCES.get(clazz);
        }
        // 依賴注入,這里注入的就是ThriftAdaptiveExt類型的實(shí)例對(duì)象
        injectExtension(instance);
        
        // 所以這里面cachedWrapperClasses包含了AdaptiveExtWrapper類
        Set<Class<?>> wrapperClasses = cachedWrapperClasses;
        if (wrapperClasses != null && !wrapperClasses.isEmpty()) {
            for (Class<?> wrapperClass : wrapperClasses) {
                // 先分析僅有一個(gè)Wrapper類的情況,將原有的instance作為參數(shù)傳入AdaptiveExtWrapper
                // 生成一個(gè)AdaptiveExtWrapper類型的instance,并為該instance依賴注入,這里的instance
                // 沒有什么好注入的
                instance = injectExtension((T) wrapperClass.getConstructor(type).newInstance(instance));
            }
        }
        return instance;
    } 
}

private void loadClass(Map<String, Class<?>> extensionClasses, 
              java.net.URL resourceURL, Class<?> clazz, String name) throws NoSuchMethodException {
    // 刪去無關(guān)代碼
    // 判斷是否是Wrapper類型
    else if (isWrapperClass(clazz)) {
        Set<Class<?>> wrappers = cachedWrapperClasses;
        if (wrappers == null) {
            cachedWrapperClasses = new ConcurrentHashSet<Class<?>>();
            wrappers = cachedWrapperClasses;
        }
        // 是的話,會(huì)用HashSet記錄下它,這說明wrapper類可以配置多個(gè),后面分析多個(gè)的情況
        wrappers.add(clazz);
    }
}

 // 這里判斷是Wrapper類的邏輯很簡(jiǎn)單,如果該clazz里面有type類型的構(gòu)造參數(shù),那么它就是,否則會(huì)拋出異常,返回false
 private boolean isWrapperClass(Class<?> clazz) {
    try {
        clazz.getConstructor(type);
        return true;
    } catch (NoSuchMethodException e) {
        return false;
    }
}

觀看下圖可以發(fā)現(xiàn),最后生成的instance是AdaptiveExtWrapper類型的,它里面有一個(gè)DubboAdaptiveExt類型變量,adaptiveExt里面有一個(gè)ThriftAdaptiveExt類型的變量,所以最后調(diào)用adaptiveExtension.echo("d", url)時(shí)的adaptiveExtension是AdaptiveExtWrapper類型的,所以輸出結(jié)果如上,有了AOP的效果.

剛剛分析的只有一個(gè)Wrapper類的情況,現(xiàn)在分析有兩個(gè)的情況,它的Debug結(jié)果如下圖,清晰易懂

輸出結(jié)果是:
before
before2
thrift
after2
after

更新后的配置文件:
dubbo=com.alibaba.dubbo.demo.provider.adaptive.impl.DubboAdaptiveExt
cloud=com.alibaba.dubbo.demo.provider.adaptive.impl.SpringCloudAdaptiveExt
thrift=com.alibaba.dubbo.demo.provider.adaptive.impl.ThriftAdaptiveExt
com.alibaba.dubbo.demo.provider.adaptive.impl.AdaptiveExtWrapper
com.alibaba.dubbo.demo.provider.adaptive.impl.AdaptiveExtWrapper2

public class AdaptiveExtWrapper2 implements AdaptiveExt {

    private AdaptiveExt adaptiveExt;

    public AdaptiveExtWrapper2(AdaptiveExt adaptiveExt) {
        this.adaptiveExt = adaptiveExt;
    }

    @Override
    public String echo(String msg, URL url) {
        // do something,實(shí)現(xiàn)了AOP
        System.out.println("before2");

        adaptiveExt.echo(msg, url);

        System.out.println("after2");
        // do something
        return "wrapper";
    }
}

到此，關(guān)于“Dubbo的SPI機(jī)制介紹以及Dubbo通過Wrapper實(shí)現(xiàn)AOP的方法”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！