資訊專欄INFORMATION COLUMN
摘要：如前所說(shuō)，的目的是獲取一個(gè)指定實(shí)現(xiàn)類(lèi)的對(duì)象。接下來(lái)從子模塊下的包的開(kāi)始分析先來(lái)看這里繼承自類(lèi)。如沒(méi)有擴(kuò)展點(diǎn)，在擴(kuò)展點(diǎn)實(shí)現(xiàn)調(diào)用該方法，并返回結(jié)果。前面已經(jīng)分析過(guò)，就是使用讀取文件并緩存的反轉(zhuǎn)控制，就是從和里面提取對(duì)象賦值。
如前所說(shuō)，Dubbo SPI的目的是獲取一個(gè)指定實(shí)現(xiàn)類(lèi)的對(duì)象。那么Dubbo是通過(guò)什么方式獲取的呢？其實(shí)是調(diào)用ExtensionLoader.getExtension(String name)實(shí)現(xiàn)。
具體實(shí)現(xiàn)途徑有三種：
①getExtensionLoader(Class
②getAdaptiveExtension() 獲取一個(gè)擴(kuò)展裝飾類(lèi)的對(duì)象，這個(gè)類(lèi)有一個(gè)規(guī)則，如果它沒(méi)有@Adaptive注解，就動(dòng)態(tài)創(chuàng)建一個(gè)裝飾類(lèi)，例如Protocol$Adaptive對(duì)象。
③getExtension(String name) 獲取一個(gè)指定對(duì)象。
（1）分析ExtensionLoader.getExtensionLoader(Class
Dubbo的第一行代碼在哪里？
idea導(dǎo)入Dubbo源碼，在子模塊dubbo-demo-provider/src/test下有DemoProvider.java
package com.alibaba.dubbo.demo.provider;
public class DemoProvider {
public static void main(String[] args) {
com.alibaba.dubbo.container.Main.main(args);
}
}
這里便是代碼的入口。
這里調(diào)到com.alibaba.dubbo.container.Main.java
package com.alibaba.dubbo.container;
import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.ExtensionLoader;
import com.alibaba.dubbo.common.logger.Logger;
import com.alibaba.dubbo.common.logger.LoggerFactory;
import com.alibaba.dubbo.common.utils.ConfigUtils;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
/**
* Main. (API, Static, ThreadSafe)
*
* @author william.liangf
*/
public class Main {
public static final String CONTAINER_KEY = "dubbo.container";
public static final String SHUTDOWN_HOOK_KEY = "dubbo.shutdown.hook";
private static final Logger logger = LoggerFactory.getLogger(Main.class);
private static final ExtensionLoader loader = ExtensionLoader.getExtensionLoader(Container.class);
private static volatile boolean running = true;
public static void main(String[] args) {
try {
if (args == null || args.length == 0) {
String config = ConfigUtils.getProperty(CONTAINER_KEY, loader.getDefaultExtensionName());
args = Constants.COMMA_SPLIT_PATTERN.split(config);
}
final List containers = new ArrayList();
for (int i = 0; i < args.length; i++) {
containers.add(loader.getExtension(args[i]));
}
logger.info("Use container type(" + Arrays.toString(args) + ") to run dubbo serivce.");
if ("true".equals(System.getProperty(SHUTDOWN_HOOK_KEY))) {
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
for (Container container : containers) {
try {
container.stop();
logger.info("Dubbo " + container.getClass().getSimpleName() + " stopped!");
} catch (Throwable t) {
logger.error(t.getMessage(), t);
}
synchronized (Main.class) {
running = false;
Main.class.notify();
}
}
}
});
}
for (Container container : containers) {
container.start();
logger.info("Dubbo " + container.getClass().getSimpleName() + " started!");
}
System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date()) + " Dubbo service server started!");
} catch (RuntimeException e) {
e.printStackTrace();
logger.error(e.getMessage(), e);
System.exit(1);
}
synchronized (Main.class) {
while (running) {
try {
Main.class.wait();
} catch (Throwable e) {
}
}
}
}
}
可以看到，Main類(lèi)中定義了一系列的靜態(tài)成員變量，其中：
private static final ExtensionLoaderloader = ExtensionLoader.getExtensionLoader(Container.class);
在Main類(lèi)初始化階段調(diào)用了上述第①條方式為Container創(chuàng)建擴(kuò)展點(diǎn)。
通過(guò)斷點(diǎn)跟進(jìn)getExtensionLoader方法，會(huì)進(jìn)行new ExtensionLoader
private ExtensionLoader(Class type) {
this.type = type;
objectFactory = (type == ExtensionFactory.class ? null : ExtensionLoader.getExtensionLoader(ExtensionFactory.class).getAdaptiveExtension());
}
可以看到，這里會(huì)進(jìn)一步調(diào)用getExtensionLoader方法，只是這次傳入的是ExtensionFactory.class。通過(guò)上面的代碼知道，等價(jià)于如下：
this.type = type; objectFactory = null;
執(zhí)行以上代碼完成了2個(gè)屬性的初始化：
1.每個(gè)ExtensionLoader都包含了2個(gè)值： type 和 objectFactory
Class type；//構(gòu)造器初始化時(shí)要得到的接口名
ExtensionFactory objectFactory//構(gòu)造器初始化時(shí)設(shè)置為AdaptiveExtensionFactory，Dubbo內(nèi)部默認(rèn)的實(shí)現(xiàn)是SpiExtensionFactory和SpringExtensionFactory。
2.new 一個(gè)ExtensionLoader 存儲(chǔ)在ConcurrentMap
關(guān)于objectFactory
1.objectFactory就是ExtensionFactory，它也是通過(guò)ExtensionLoader.getExtensionLoader(ExtensionFactory.class)來(lái)實(shí)現(xiàn)的，但是它的objectFactory=null
2.objectFactory作用，它就是為dubbo的IOC提供所有對(duì)象。
（2）分析getAdaptiveExtension()
為什么要設(shè)計(jì)Adaptive？
Adaptive注解在類(lèi)和方法上有什么區(qū)別？
①注解在類(lèi)上，代表人工實(shí)現(xiàn)編碼，即實(shí)現(xiàn)了一個(gè)裝飾類(lèi)，如ExtensionFactory。
②注解在方法上，代表自動(dòng)生成和編譯一個(gè)動(dòng)態(tài)的adaptive類(lèi)，如Protocol$Adaptive。
接下來(lái)從子模塊dubbo-config-spring下的schema包的DubboNamespaceHandler開(kāi)始分析：
package com.alibaba.dubbo.config.spring.schema;
import com.alibaba.dubbo.common.Version;
import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ConsumerConfig;
import com.alibaba.dubbo.config.ModuleConfig;
import com.alibaba.dubbo.config.MonitorConfig;
import com.alibaba.dubbo.config.ProtocolConfig;
import com.alibaba.dubbo.config.ProviderConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.spring.AnnotationBean;
import com.alibaba.dubbo.config.spring.ReferenceBean;
import com.alibaba.dubbo.config.spring.ServiceBean;
import org.springframework.beans.factory.xml.NamespaceHandlerSupport;
/**
* DubboNamespaceHandler
*
* @author william.liangf
* @export
*/
public class DubboNamespaceHandler extends NamespaceHandlerSupport {
static {
Version.checkDuplicate(DubboNamespaceHandler.class);
}
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));
}
}
先來(lái)看
registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
這里ServiceBean繼承自ServiceConfig類(lèi)。
public class ServiceConfigextends 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(); .... }
在這里通過(guò)getAdaptiveExtension()獲取protocol。
-->getAdaptiveExtension()//為cachedAdaptiveInstance賦值
-->createAdaptiveExtension()
-->getAdaptiveExtensionClass()//該方法看出，如果是預(yù)定義的類(lèi)就直接返回，不然動(dòng)態(tài)生成適配類(lèi)
-->getExtensionClasses()//為cachedClasses 賦值
-->loadExtensionClasses()
-->loadFile(..)
-->createAdaptiveExtensionClass()//自動(dòng)生成和編譯一個(gè)動(dòng)態(tài)的adpative類(lèi)，這個(gè)類(lèi)是一個(gè)代理類(lèi)
-->ExtensionLoader.getExtensionLoader
(com.alibaba.dubbo.common.compiler.Compiler.class).getAdaptiveExtension()
-->compiler.compile(code, classLoader)
-->injectExtension()//作用：進(jìn)入IOC的反轉(zhuǎn)控制模式，實(shí)現(xiàn)了動(dòng)態(tài)注入
loadFile(..)方法的作用：把SPI配置文件（如META-INF/dubbo/internal/com.alibaba.dubbo.rpc.Protocol）的內(nèi)容，存儲(chǔ)在緩存變量里。使用了四個(gè)緩存變量。
①緩存包含Adaptive注解的類(lèi)
cachedAdaptiveClass 如果這個(gè)Class含有adaptive注解就賦值進(jìn)去，如ExtensionFactory有，而Protocol沒(méi)有。
②緩存無(wú)Adaptive注解的封裝類(lèi)
cachedWrapperClasses 只有當(dāng)該class無(wú)adaptive注解，并且構(gòu)造方法參數(shù)為目標(biāo)接口(type，如Protocol)類(lèi)型，如Protocol里的SPI就只有ProtocolFilterWrapper和ProtocolListenerWrapper能命中，如下例：
public class ProtocolFilterWrapper implements Protocol {
private final Protocol protocol;
public ProtocolFilterWrapper(Protocol protocol) {
if (protocol == null) {
throw new IllegalArgumentException("protocol == null");
}
this.protocol = protocol;
}
。。。
}
③cachedActivates 剩下的包含Activate注解的類(lèi)
④cachedName 剩下的類(lèi)存儲(chǔ)在該map中
在loadExtensionClasses()方法中，有三處loadFile()加載SPI文件：
