前言
本系列的文章純屬自己看dubbo源碼的心得
入口尋找：
dubbo作為一個框架，我們使用的時候罢维，首先會去引包，然后再spring的配置文件里配置dubbo的自定義標簽匀借，可能還需要引入dubbo的schema文件平窘。所以入口是從dubbo的schema文件入手。
1 先熟悉下 spring自定義文件的方法
2 尋找dubbo的schema文件
http://code.alibabatech.com/schema/dubbo 是位于名為spring.handlers文件中蓬坡，
http\://code.alibabatech.com/schema/dubbo=com.alibaba.dubbo.config.spring.schema.DubboNamespaceHandler
=左邊是key磅叛，右邊是解析dubbo自定義標簽的handler類
http://code.alibabatech.com/schema/dubbo/dubbo.xsd 是位于spring.schemas文件中，
http\://code.alibabatech.com/schema/dubbo/dubbo.xsd=META-INF/dubbo.xsd
左邊是key 右邊是 dubbo自定義標簽的定義文件是dubbo.xsd
3 看DubboNamespaceHandler類
public void init() {
registerBeanDefinitionParser("application", new DubboBeanDefinitionParser(ApplicationConfig.class, true));
registerBeanDefinitionParser("module", new DubboBeanDefinitionParser(ModuleConfig.class, true));
registerBeanDefinitionParser("registry", new DubboBeanDefinitionParser(RegistryConfig.class, true));
registerBeanDefinitionParser("monitor", new DubboBeanDefinitionParser(MonitorConfig.class, true));
registerBeanDefinitionParser("provider", new DubboBeanDefinitionParser(ProviderConfig.class, true));
registerBeanDefinitionParser("consumer", new DubboBeanDefinitionParser(ConsumerConfig.class, true));
registerBeanDefinitionParser("protocol", new DubboBeanDefinitionParser(ProtocolConfig.class, true));
registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
registerBeanDefinitionParser("reference", new DubboBeanDefinitionParser(ReferenceBean.class, false));
registerBeanDefinitionParser("annotation", new DubboBeanDefinitionParser(AnnotationBean.class, true));
}
會看到<dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" /> 這個標簽最終被解析成ServiceBean.class
4 看ServiceBean.class
會看到
public class ServiceBean<T> extends ServiceConfig<T>
implements InitializingBean,
DisposableBean,
ApplicationContextAware,
ApplicationListener,
BeanNameAware
可以看到ServiceBean實現(xiàn)了這么多的spring的接口，
InitializingBean：初始化時的回調 afterPropertiesSet
DisposableBean：銷毀時的回調 destroy()
ApplicationContextAware：通過 setApplicationContext（）可以獲取spring容器ApplicationContext
ApplicationListener：spring的監(jiān)聽器接口紫皇，可以實現(xiàn)bean與bean之間的通信腋寨，不熟悉用法的可以看 https://blog.csdn.net/sinat_33625560/article/details/78605367，
ContextRefreshedEvent:容器初始化完成后所觸發(fā)的事件
https://www.xttblog.com/?p=2053
BeanNameAware ：獲取該bean的name的接口萄窜。不熟悉的可以看看http://www.reibang.com/writer#/notebooks/28099010/notes/32861542/preview
5 看ServiceConfig
ServiceBean繼承了ServiceConfig
就可以找到spi的入口了.
public class ServiceConfig<T> extends AbstractServiceConfig {
private static final long serialVersionUID = 3033787999037024738L;
private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
private static final ProxyFactory proxyFactory = ExtensionLoader.getExtensionLoader(ProxyFactory.class).getAdaptiveExtension();
在這里啰嗦下
我們除了在spring中的配置demoService的bean會被解析成ServiceBean,我們也會配置注冊中心被解析成RegistryConfig,配置的協(xié)議Protocol被解析成ProtocolConfig,但是Protocol和Registry這些類是如何被加載的呢?答案是ServiceBean里引用了ProtocolConfig,在初始化ServiceBean的時候,會先動態(tài)創(chuàng)建一個Protocol$Adpative類注入到ServiceBean中.當ServiceBean具體調用的時候,會再次創(chuàng)建一個具體的實現(xiàn)類在執(zhí)行具體的方法.具體看下面
6 看Protocol$Adpative的作用
從下面代碼可以看出Protocol$Adpative的作用是 根據url得到 具體實現(xiàn)類來實現(xiàn)接下來的 export和refer
package com.alibaba.dubbo.rpc;
import com.alibaba.dubbo.common.extension.ExtensionLoader;
public class Protocol$Adpative 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.Invoker {
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 java.lang.Class {
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);
}
}
7 看SPI的具體加載過程
不重復造輪子,請參考:http://www.reibang.com/p/7d13b2998f77
這里記錄下需要注意的點
- 1@SPI
被此注解標記的接口，就表示是一個可擴展的接口穗泵。具體的實現(xiàn)類可能都羅列在spi文件中.@SPI中有默認的value屬性,類似與下面
/**
* Protocol. (API/SPI, Singleton, ThreadSafe)
*/
@SPI("dubbo")
public interface Protocol {...
表示Protocol$Adpative接受的url要是沒有指定Protocol具體的實現(xiàn),則采用此value的值,即dubbo是默認的Protocol實現(xiàn).
- 2 @Adaptive注解在方法上和類上到底有區(qū)別呢?
@Adaptive注解在接口的方法上,就代表了,此接口方法會被一段動態(tài)生成的模板代碼實現(xiàn)
@Adaptive注解在類上.目前只有2個類使用了這個注解,AdaptiveCompiler和AdaptiveExtensionFactory.表示該類以及是Adaptive的類了,無需再動態(tài)生成模板代碼并編譯了.這樣做是為什么呢?
因為Compiler和ExtensionFactory是2個非车柩樱基礎和通用的類.必須保證他們在其他所有類加載之前就必須存在這2個類.舉個例子,Protocol類會動態(tài)生成模板代碼并被Compiler類編譯加載到內存,如果Compiler類還不存在,則會先去動態(tài)生成編譯和加載Compiler類,而編譯Compiler類又需要Compiler存在,Compiler還是不存在,...就會陷入死循環(huán). - 3 dubbo的spi和java的spi相比較,有幾大不同點
--1 dubbo的spi不需要加載所有的實現(xiàn)類
--2 dubbo的spi帶有依賴注入功能.假設Protocol類里有屬性A,A也是被SPI標注的類.那么在加載Protocol類的同時A也會被創(chuàng)建成A$Adaptive類注入到Protocol.如果A沒有被SPI注解,則無法注入
