前言
本系列的文章纯属自己看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实现了这么多的spring的接口，
InitializingBean：初始化时的回调 afterPropertiesSet
DisposableBean：销毁时的回调 destroy()
ApplicationContextAware：通过 setApplicationContext（）可以获取spring容器ApplicationContext
ApplicationListener：spring的监听器接口，可以实现bean与bean之间的通信，不熟悉用法的可以看 https://blog.csdn.net/sinat_33625560/article/details/78605367，
ContextRefreshedEvent:容器初始化完成后所触发的事件
https://www.xttblog.com/?p=2053
BeanNameAware ：获取该bean的name的接口。不熟悉的可以看看https://www.jianshu.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,配置的协议Protocol被解析成ProtocolConfig,但是Protocol和Registry这些类是如何被加载的呢?答案是ServiceBean里引用了ProtocolConfig,在初始化ServiceBean的时候,会先动态创建一个Protocol$Adpative类注入到ServiceBean中.当ServiceBean具体调用的时候,会再次创建一个具体的实现类在执行具体的方法.具体看下面
6 看Protocol$Adpative的作用
从下面代码可以看出Protocol$Adpative的作用是 根据url得到 具体实现类来实现接下来的 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的具体加载过程
不重复造轮子,请参考:https://www.jianshu.com/p/7d13b2998f77
这里记录下需要注意的点
- 1@SPI
被此注解标记的接口，就表示是一个可扩展的接口。具体的实现类可能都罗列在spi文件中.@SPI中有默认的value属性,类似与下面
/**
* Protocol. (API/SPI, Singleton, ThreadSafe)
*/
@SPI("dubbo")
public interface Protocol {...
表示Protocol$Adpative接受的url要是没有指定Protocol具体的实现,则采用此value的值,即dubbo是默认的Protocol实现.
- 2 @Adaptive注解在方法上和类上到底有区别呢?
@Adaptive注解在接口的方法上,就代表了,此接口方法会被一段动态生成的模板代码实现
@Adaptive注解在类上.目前只有2个类使用了这个注解,AdaptiveCompiler和AdaptiveExtensionFactory.表示该类以及是Adaptive的类了,无需再动态生成模板代码并编译了.这样做是为什么呢?
因为Compiler和ExtensionFactory是2个非常基础和通用的类.必须保证他们在其他所有类加载之前就必须存在这2个类.举个例子,Protocol类会动态生成模板代码并被Compiler类编译加载到内存,如果Compiler类还不存在,则会先去动态生成编译和加载Compiler类,而编译Compiler类又需要Compiler存在,Compiler还是不存在,...就会陷入死循环. - 3 dubbo的spi和java的spi相比较,有几大不同点
--1 dubbo的spi不需要加载所有的实现类
--2 dubbo的spi带有依赖注入功能.假设Protocol类里有属性A,A也是被SPI标注的类.那么在加载Protocol类的同时A也会被创建成A$Adaptive类注入到Protocol.如果A没有被SPI注解,则无法注入
