資訊專欄INFORMATION COLUMN
摘要：如前所說，的目的是獲取一個指定實現類的對象。接下來從子模塊下的包的開始分析先來看這里繼承自類。如沒有擴展點，在擴展點實現調用該方法，并返回結果。前面已經分析過，就是使用讀取文件并緩存的反轉控制，就是從和里面提取對象賦值。
如前所說，Dubbo SPI的目的是獲取一個指定實現類的對象。那么Dubbo是通過什么方式獲取的呢？其實是調用ExtensionLoader.getExtension(String name)實現。
具體實現途徑有三種：
①getExtensionLoader(Class
②getAdaptiveExtension() 獲取一個擴展裝飾類的對象，這個類有一個規則，如果它沒有@Adaptive注解，就動態創建一個裝飾類，例如Protocol$Adaptive對象。
③getExtension(String name) 獲取一個指定對象。
（1）分析ExtensionLoader.getExtensionLoader(Class
Dubbo的第一行代碼在哪里？
idea導入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);
}
}
這里便是代碼的入口。
這里調到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類中定義了一系列的靜態成員變量，其中：
private static final ExtensionLoaderloader = ExtensionLoader.getExtensionLoader(Container.class);
在Main類初始化階段調用了上述第①條方式為Container創建擴展點。
通過斷點跟進getExtensionLoader方法，會進行new ExtensionLoader
private ExtensionLoader(Class type) {
this.type = type;
objectFactory = (type == ExtensionFactory.class ? null : ExtensionLoader.getExtensionLoader(ExtensionFactory.class).getAdaptiveExtension());
}
可以看到，這里會進一步調用getExtensionLoader方法，只是這次傳入的是ExtensionFactory.class。通過上面的代碼知道，等價于如下：
this.type = type; objectFactory = null;
執行以上代碼完成了2個屬性的初始化：
1.每個ExtensionLoader都包含了2個值： type 和 objectFactory
Class type；//構造器初始化時要得到的接口名
ExtensionFactory objectFactory//構造器初始化時設置為AdaptiveExtensionFactory，Dubbo內部默認的實現是SpiExtensionFactory和SpringExtensionFactory。
2.new 一個ExtensionLoader 存儲在ConcurrentMap
關于objectFactory
1.objectFactory就是ExtensionFactory，它也是通過ExtensionLoader.getExtensionLoader(ExtensionFactory.class)來實現的，但是它的objectFactory=null
2.objectFactory作用，它就是為dubbo的IOC提供所有對象。
（2）分析getAdaptiveExtension()
為什么要設計Adaptive？
Adaptive注解在類和方法上有什么區別？
①注解在類上，代表人工實現編碼，即實現了一個裝飾類，如ExtensionFactory。
②注解在方法上，代表自動生成和編譯一個動態的adaptive類，如Protocol$Adaptive。
接下來從子模塊dubbo-config-spring下的schema包的DubboNamespaceHandler開始分析：
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));
}
}
先來看
registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
這里ServiceBean繼承自ServiceConfig類。
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(); .... }
在這里通過getAdaptiveExtension()獲取protocol。
-->getAdaptiveExtension()//為cachedAdaptiveInstance賦值
-->createAdaptiveExtension()
-->getAdaptiveExtensionClass()//該方法看出，如果是預定義的類就直接返回，不然動態生成適配類
-->getExtensionClasses()//為cachedClasses 賦值
-->loadExtensionClasses()
-->loadFile(..)
-->createAdaptiveExtensionClass()//自動生成和編譯一個動態的adpative類，這個類是一個代理類
-->ExtensionLoader.getExtensionLoader
(com.alibaba.dubbo.common.compiler.Compiler.class).getAdaptiveExtension()
-->compiler.compile(code, classLoader)
-->injectExtension()//作用：進入IOC的反轉控制模式，實現了動態注入
loadFile(..)方法的作用：把SPI配置文件（如META-INF/dubbo/internal/com.alibaba.dubbo.rpc.Protocol）的內容，存儲在緩存變量里。使用了四個緩存變量。
①緩存包含Adaptive注解的類
cachedAdaptiveClass 如果這個Class含有adaptive注解就賦值進去，如ExtensionFactory有，而Protocol沒有。
②緩存無Adaptive注解的封裝類
cachedWrapperClasses 只有當該class無adaptive注解，并且構造方法參數為目標接口(type，如Protocol)類型，如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注解的類
④cachedName 剩下的類存儲在該map中
在loadExtensionClasses()方法中，有三處loadFile()加載SPI文件：
