原创不易,转发请表明出处
源码学习版本为 2.6.2-SNAPSHOT,源码注释网址为
ExtensionLoader是dubbo中核心的组件,主要的作用就是
1 根据参数值,自动注入拓展插件
2 包装拓展插件
先上一个源码中使用的例子,在解析dubbo的配置文件时,解析服务有个核心配置类,是ServiceConfig,这个后面会介绍,里面初始化Protocol类的代码如下:
// 获取协议的包装类,默认是 dubbo协议
private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
Protocol接口定义如下
@SPI("dubbo")
public interface Protocol {
int getDefaultPort();
@Adaptive
Exporter export(Invoker invoker)throws RpcException;
@Adaptive
Invoker refer(Class type, URL url)throws RpcException;
void destroy();
}
之后在下面的 doExportUrlsFor1Protocol()方法是这么用的
Exporter exporter =protocol.export(wrapperInvoker);
这个地方的入参是
调用的其实是protocol 的实现类 RegistryProtocol中的export(final Invoker originInvoker)方法
protocol的实现类有很多,程序怎么知道用哪个实现类呢,这就是ExtensionLoader的强大神奇之处,下面一一道来
万事讲源头,再贴一下刚刚开始举得例子的代码,就是 Protocol初始化的那个地方
private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
// ExtensionLoader 中的 getExtensionLoader ()方法, 已去除校验逻辑,保留核心逻辑
@SuppressWarnings("unchecked")
public static ExtensionLoader getExtensionLoader(Class type) {
// java设计模式,亨元模式,首先从缓存中获取,如果获取不到,初始化并返回
ExtensionLoader loader = (ExtensionLoader)EXTENSION_LOADERS.get(type);
if (loader ==null) {
EXTENSION_LOADERS.putIfAbsent(type, new ExtensionLoader(type));
loader = (ExtensionLoader)EXTENSION_LOADERS.get(type);
}
return loader;
}
这个地方做的事情就是根据传入接口,初始化ExtensionLoader类,并返回,看来是ExtensionLoader 的 getAdaptiveExtension() 是核心,下面看看核心!
ExtensionLoader 中的getAdaptiveExtension()方法
// 也是保留核心逻辑
instance = createAdaptiveExtension();
return (T) instance;
这个地方就是调用createAdaptiveExtension()方法,创建包装,继续顺藤摸瓜
ExtensionLoader 中的createAdaptiveExtension()方法
return injectExtension((T) getAdaptiveExtensionClass().newInstance());
这个需要分两步去看,首先是 (T) getAdaptiveExtensionClass().newInstance(),其次是 injectExtension(T instance)
首先看 ExtensionLoader 中的getAdaptiveExtensionClass()方法,这个方法是想获取T的字节码class文件,也是用到了亨元模式先从缓存取,如果没有,调用createAdaptiveExtensionClass()方法创建
private Class createAdaptiveExtensionClass() {
// 动态代理,获取Protocol的包装的代码字符串,具体内容见注1,核心中的核心
String code = createAdaptiveExtensionClassCode();
ClassLoader classLoader =findClassLoader();
com.alibaba.dubbo.common.compiler.Compiler compiler = ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.common.compiler.Compiler.class).getAdaptiveExtension();
return compiler.compile(code, classLoader);
}
其实 (T) getAdaptiveExtensionClass().newInstance()返回的是动态代理生成的类的实例,动态代理的内容是注1中的内容,动态代理生成的类的核心逻辑就是增强Protocol中的export()方法,根据 Invoker中的url的protocol决定具体的实现类,再去调用具体实现类的export()方法
再看 ExtensionLoader 中的injectExtension(T instance)()方法,保持核心逻辑的源码如下
for (Method method : instance.getClass().getMethods()) {
if (method.getName().startsWith("set")&& method.getParameterTypes().length ==1
&& Modifier.isPublic(method.getModifiers())) {
Class pt = method.getParameterTypes()[0];
try {
String property = method.getName().length() >3 ? method.getName().substring(3, 4).toLowerCase() + method.getName().substring(4) :""; // 获取属性名
Object object =objectFactory.getExtension(pt, property); // 获取属性值
if (object !=null) {
method.invoke(instance, object); // 反射设置属性值
}
}
}
代码主要的逻辑就是从 objectFactory 获取属性值,之后通过反射初始化属性,
在 注1中有个方法,也是 ExtensionLoader的核心方法,摘取自注1中的代码如下:
ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName)
ExtensionLoader类中getExtension(String name)方法,保留核心逻辑代码如下:
instance = createExtension(name);
ExtensionLoader类的 createExtension(String name)方法,这其中的核心逻辑是调用 getExtensionClasses(),之后调用
loadExtensionClasses()方法,之后核心逻辑如下:
loadDirectory(extensionClasses, DUBBO_INTERNAL_DIRECTORY);
loadDirectory(extensionClasses, DUBBO_DIRECTORY);
loadDirectory(extensionClasses, SERVICES_DIRECTORY);
会从"META-INF/services/"和"META-INF/dubbo/" 和 "META-INF/dubbo/internal/"路径下,读取配置文件,加载到ExtensionLoader的cachedClasses字段中,
Protocol接口的配置文件名字是com.alibaba.dubbo.rpc.Protocol,这个文件有可能分散在不同模块下,内容如下
filter=com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper
listener=com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper
mock=com.alibaba.dubbo.rpc.support.MockProtocol
不加载后缀是 Wrapper的
至此,总结如下
ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();其实就是动态代理获取Protocol的代理包装类,类的内容见注1,之后根据代理类的逻辑执行具体逻辑。
注1:根据createAdaptiveExtensionClassCode()方法生成的字符串类型的class文件,核心逻辑是根据传入的泛型T以及其中方法上的@Adaptive注解,创建动态代理,创建的内容如下
package com.alibaba.dubbo.rpc;
import com.alibaba.dubbo.common.extension.ExtensionLoader;
public class Protocol$Adaptive implements com.alibaba.dubbo.rpc.Protocol { // 生成的为 Protocol 的内部类 Adaptive
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.RpcException {
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 com.alibaba.dubbo.rpc.RpcException {
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);
}
}
网友评论