Dubbo 扩展点加载机制：从 Java SPI 到 Dubbo SPI
程序员文章站
2022-07-02 10:54:18
SPI 全称为 Service Provider Interface，是一种服务发现机制。当程序运行调用接口时，会根据配置文件或默认规则信息加载对应的实现类。所以在程序中并没有直接指定使用接口的哪个实现，而是在外部进行装配。 ......
spi 全称为 service provider interface，是一种服务发现机制。当程序运行调用接口时，会根据配置文件或默认规则信息加载对应的实现类。所以在程序中并没有直接指定使用接口的哪个实现，而是在外部进行装配。
要想了解 dubbo 的设计与实现，其中 dubbo spi 加载机制是必须了解的，在 dubbo 中有大量功能的实现都是基于 dubbo spi 实现解耦，同时也使得 dubbo 获得如此好的可扩展性。
java spi
通过完成一个 java spi 的操作来了解它的机制。
- 创建一个 animalservice 接口及 category 方法
- 创建一个实现类 cat
- 创建 meta-inf/services 目录，并在该目录下创建一个文件，文件名为 animalservice 的全限定名作为文件名
- 在文件中添加实现类 cat 的全限定名
animal 接口
public interface animalservice {
void category();
}
cat 实现类
public class cat implements animalservice {
@override
public void category() {
system.out.println("cat: meow ~");
}
}
在 meta-inf/services 目录下的 top.ytao.demo.spi.animalservice 文件中添加：
top.ytao.demo.spi.cat
加载 spi 的实现：
public class javaspitest {
@test
public void javaspi() throws exception {
serviceloader<animalservice> serviceloader = serviceloader.load(animalservice.class);
// 遍历在配置文件中已配置的 animalservice 的所有实现类
for (animalservice animalservice : serviceloader) {
animalservice.category();
}
}
}
执行结果：
就这样，一个 java spi 就实现完成了，通过 serviceloader.load 获取加载所有接口已配置的接口实现类，然后可以遍历找出需要的实现。
dubbo spi
本文 dubbo 版本为2.7.5
dubbo spi 相较于 java spi 更为强大，并且都是由自己实现的一套 spi 机制。其中主要的改进和优化：
- 相对于 java spi 一次性加载所有实现，dubbo spi 是按需加载，只加载需要使用的实现类。同时带有缓存支持。
- 更为详细的扩展加载失败信息。
- 增加了对扩展 ioc 和 aop的支持。
dubbo spi 示例
dubbo spi 的配置文件放在 meta-inf/dubbo 下面，并且实现类的配置方式采用 k-v 的方式，key 为实例化对象传入的参数，value 为扩展点实现类全限定名。例如 cat 的配置文件内容：
cat = top.ytao.demo.spi.cat
dubbo spi 加载过程中，对 java spi 的目录也是可以被兼容的。
同时需要在接口上增加 @spi 注解，@spi 中可以指定 key 值，加载 spi 如下：
public class dubbospitest {
@test
public void dubbospi(){
extensionloader<animalservice> extensionloader = extensionloader.getextensionloader(animalservice.class);
// 获取扩展类实现
animalservice cat = extensionloader.getextension("cat");
system.out.println("dubbo spi");
cat.category();
}
}
执行结果如下：
获取 extensionloader 实例
获取 extensionloader 实例是通过上面 getextensionloader 方法，具体实现代码：
public static <t> extensionloader<t> getextensionloader(class<t> type) {
if (type == null) {
throw new illegalargumentexception("extension type == null");
}
// 检查 type 必须为接口
if (!type.isinterface()) {
throw new illegalargumentexception("extension type (" + type + ") is not an interface!");
}
// 检查接口是否有 spi 注解
if (!withextensionannotation(type)) {
throw new illegalargumentexception("extension type (" + type +
") is not an extension, because it is not annotated with @" + spi.class.getsimplename() + "!");
}
// 缓存中获取 extensionloader 实例
extensionloader<t> loader = (extensionloader<t>) extension_loaders.get(type);
if (loader == null) {
// 加载 extensionloader 实例到缓存中
extension_loaders.putifabsent(type, new extensionloader<t>(type));
loader = (extensionloader<t>) extension_loaders.get(type);
}
return loader;
}
上面获取扩展类加载器过程主要是检查传入的 type 是否合法，以及从扩展类加载器缓存中是否存在当前类型的接口，如果不存在则添加当前接口至缓存中。concurrentmap<class<?>, extensionloader<?>> extension_loaders 是扩展类加载器的缓存，它是以接口作为 key， 扩展类加载器作为 value 进行缓存。
获取扩展类对象
获取扩展类对象的方法extensionloader#getextension，在这里完成扩展对象的缓存及创建工作：
public t getextension(string name) {
if (stringutils.isempty(name)) {
throw new illegalargumentexception("extension name == null");
}
// 如果传入的参数为 true ，则获取默认扩展类对象操作
if ("true".equals(name)) {
return getdefaultextension();
}
// 获取扩展对象，holder 里的 value 属性保存着扩展对象实例
final holder<object> holder = getorcreateholder(name);
object instance = holder.get();
// 使用双重检查锁
if (instance == null) {
synchronized (holder) {
instance = holder.get();
if (instance == null) {
// 创建扩展对象
instance = createextension(name);
holder.set(instance);
}
}
}
return (t) instance;
}
获取 holder 对象是从缓存concurrentmap<string, holder<object>> cachedinstances中获取，如果不存在，则以扩展名 key，创建一个 holder 对象作为 value，设置到扩展对象缓存。
如果是新创建的扩展对象实例，那么 holder.get() 一定是 null ，扩展对象为空时，经过双重检查锁，创建扩展对象。
创建扩展对象
创建扩展对象过程：
private t createextension(string name) {
// 从全部扩展类中，获取当前扩展名对应的扩展类
class<?> clazz = getextensionclasses().get(name);
if (clazz == null) {
throw findexception(name);
}
try {
// 从缓存中获取扩展实例，及设置扩展实例缓存
t instance = (t) extension_instances.get(clazz);
if (instance == null) {
extension_instances.putifabsent(clazz, clazz.newinstance());
instance = (t) extension_instances.get(clazz);
}
// 向当前实例注入依赖
injectextension(instance);
// 获取包装扩展类缓存
set<class<?>> wrapperclasses = cachedwrapperclasses;
if (collectionutils.isnotempty(wrapperclasses)) {
for (class<?> wrapperclass : wrapperclasses) {
// 创建包装扩展类实例，并向其注入依赖
instance = injectextension((t) wrapperclass.getconstructor(type).newinstance(instance));
}
}
// 初始化扩展对象
initextension(instance);
return instance;
} catch (throwable t) {
throw new illegalstateexception("extension instance (name: " + name + ", class: " +
type + ") couldn't be instantiated: " + t.getmessage(), t);
}
}
上面创建扩展过程中，里面有个 wrapper 类，这里使用到装饰器模式，该类是没有具体的实现，而是把通用逻辑进行抽象。
创建这个过程是从所有扩展类中获取当前扩展名对应映射关系的扩展类，以及向当前扩展对象注入依赖。
获取所有扩展类：
private map<string, class<?>> getextensionclasses() {
// 获取普通扩展类缓存
map<string, class<?>> classes = cachedclasses.get();
// 如果缓存中没有，通过双重检查锁后进行加载
if (classes == null) {
synchronized (cachedclasses) {
classes = cachedclasses.get();
if (classes == null) {
// 加载全部扩展类
classes = loadextensionclasses();
cachedclasses.set(classes);
}
}
}
return classes;
}
检查普通扩展类缓存是否为空，如果不为空则重新加载，真正加载扩展类在loadextensionclasses中：
private static final string services_directory = "meta-inf/services/";
private static final string dubbo_directory = "meta-inf/dubbo/";
private static final string dubbo_internal_directory = dubbo_directory + "internal/";
private map<string, class<?>> loadextensionclasses() {
// 获取 @spi 上的默认扩展名
cachedefaultextensionname();
map<string, class<?>> extensionclasses = new hashmap<>();
// 先加载 dubbo 内部的扩展类， 通过 boolean 值控制
loaddirectory(extensionclasses, dubbo_internal_directory, type.getname(), true);
// 由于 dubbo 迁到 apache ，所以包名有变化，会替换之前的 alibaba 为 apache
loaddirectory(extensionclasses, dubbo_internal_directory, type.getname().replace("org.apache", "com.alibaba"), true);
loaddirectory(extensionclasses, dubbo_directory, type.getname());
loaddirectory(extensionclasses, dubbo_directory, type.getname().replace("org.apache", "com.alibaba"));
loaddirectory(extensionclasses, services_directory, type.getname());
loaddirectory(extensionclasses, services_directory, type.getname().replace("org.apache", "com.alibaba"));
return extensionclasses;
}
上面获取 @spi 扩展名，以及指定要加载的文件。从上面静态常量中，我们可以看到，dubbo spi 也是支持加载 java spi 的目录，同时还加载 meta-inf/dubbo/internal (该目录为 dubbo 的内部扩展类目录)，在 loaddirectory 加载目录配置文件。
private void loaddirectory(map<string, class<?>> extensionclasses, string dir, string type, boolean extensionloaderclassloaderfirst) {
// 获取文件在项目中的路径，如：meta-inf/dubbo/top.ytao.demo.spi.animalservice
string filename = dir + type;
try {
enumeration<java.net.url> urls = null;
classloader classloader = findclassloader();
// 加载内部扩展类
if (extensionloaderclassloaderfirst) {
classloader extensionloaderclassloader = extensionloader.class.getclassloader();
if (classloader.getsystemclassloader() != extensionloaderclassloader) {
urls = extensionloaderclassloader.getresources(filename);
}
}
// 加载当前 filename 文件
if(urls == null || !urls.hasmoreelements()) {
if (classloader != null) {
urls = classloader.getresources(filename);
} else {
urls = classloader.getsystemresources(filename);
}
}
if (urls != null) {
// 迭代加载同名文件的内容
while (urls.hasmoreelements()) {
java.net.url resourceurl = urls.nextelement();
// 加载文件内容
loadresource(extensionclasses, classloader, resourceurl);
}
}
} catch (throwable t) {
logger.error("exception occurred when loading extension class (interface: " +
type + ", description file: " + filename + ").", t);
}
}
这里获取文件名后加载所有同名文件，然后迭代各个文件，逐个加载文件内容。
private void loadresource(map<string, class<?>> extensionclasses, classloader classloader, java.net.url resourceurl) {
try {
try (bufferedreader reader = new bufferedreader(new inputstreamreader(resourceurl.openstream(), standardcharsets.utf_8))) {
string line;
// 整行读取文件内容
while ((line = reader.readline()) != null) {
// 获取当前行中第一个 "#" 的位置索引
final int ci = line.indexof('#');
// 如果当前行存在 "#",则去除 "#" 后的内容
if (ci >= 0) {
line = line.substring(0, ci);
}
line = line.trim();
if (line.length() > 0) {
try {
string name = null;
// 获取当前行 "=" 的索引
int i = line.indexof('=');
// 如果当前行存在 "="，将 "=" 左右的值分开复制给 name 和 line
if (i > 0) {
name = line.substring(0, i).trim();
line = line.substring(i + 1).trim();
}
if (line.length() > 0) {
// 加载扩展类
loadclass(extensionclasses, resourceurl, class.forname(line, true, classloader), name);
}
} catch (throwable t) {
illegalstateexception e = new illegalstateexception("failed to load extension class (interface: " + type + ", class line: " + line + ") in " + resourceurl + ", cause: " + t.getmessage(), t);
exceptions.put(line, e);
}
}
}
}
} catch (throwable t) {
logger.error("exception occurred when loading extension class (interface: " +
type + ", class file: " + resourceurl + ") in " + resourceurl, t);
}
}
上面代码完成文件内容加载和解析，接下来通过 loadclass 加载扩展类。
private void loadclass(map<string, class<?>> extensionclasses, java.net.url resourceurl, class<?> clazz, string name) throws nosuchmethodexception {
// 检查当前实现类是否实现了 type 接口
if (!type.isassignablefrom(clazz)) {
throw new illegalstateexception("error occurred when loading extension class (interface: " +
type + ", class line: " + clazz.getname() + "), class "
+ clazz.getname() + " is not subtype of interface.");
}
// 当前实现类是否有 adaptive 注解
if (clazz.isannotationpresent(adaptive.class)) {
cacheadaptiveclass(clazz);
// 当前类是否为 wrapper 包装扩展类
} else if (iswrapperclass(clazz)) {
cachewrapperclass(clazz);
} else {
// 尝试当前类是否有无参构造方法
clazz.getconstructor();
if (stringutils.isempty(name)) {
// 如果 name 为空，则获取 clazz 的 @extension 注解的值，如果注解值也没有，则使用小写类名
name = findannotationname(clazz);
if (name.length() == 0) {
throw new illegalstateexception("no such extension name for the class " + clazz.getname() + " in the config " + resourceurl);
}
}
string[] names = name_separator.split(name);
if (arrayutils.isnotempty(names)) {
// 缓存 扩展名和@activate的缓存
cacheactivateclass(clazz, names[0]);
for (string n : names) {
// 缓存 扩展类和扩展名的缓存
cachename(clazz, n);
// 将 扩展类和扩展名 保存到extensionclasses 扩展名->扩展类 关系映射中
saveinextensionclass(extensionclasses, clazz, n);
}
}
}
}
至此，getextensionclasses() 加载扩展类方法分析完成，接下分析注入依赖 injectextension() 方法。
private t injectextension(t instance) {
//
if (objectfactory == null) {
return instance;
}
try {
for (method method : instance.getclass().getmethods()) {
// 遍历当前扩展类的全部方法，如果当前方法不属于 setter 方法，
// 即不是以 'set'开头的方法名，参数不是一个的，该方法访问级别不是 public 的，则不往下执行
if (!issetter(method)) {
continue;
}
// 当前方法是否添加了不要注入依赖的注解
if (method.getannotation(disableinject.class) != null) {
continue;
}
class<?> pt = method.getparametertypes()[0];
// 判断当前参数是否属于 八个基本类型或void
if (reflectutils.isprimitives(pt)) {
continue;
}
try {
// 通过属性 setter 方法获取属性名
string property = getsetterproperty(method);
// 获取依赖对象
object object = objectfactory.getextension(pt, property);
if (object != null) {
// 设置依赖
method.invoke(instance, object);
}
} catch (exception e) {
logger.error("failed to inject via method " + method.getname()
+ " of interface " + type.getname() + ": " + e.getmessage(), e);
}
}
} catch (exception e) {
logger.error(e.getmessage(), e);
}
return instance;
}
通过遍历扩展类所有方法，找到相对应的依赖，然后使用反射调用 settter 方法来进行设置依赖。
objectfactory 对象如图：
其中找到相应依赖是在 spiextensionfactory 或 springextensionfactory 中，同时，这两个 factory 保存在 adaptiveextensionfactory 中进行维护。
@adaptive
public class adaptiveextensionfactory implements extensionfactory {
private final list<extensionfactory> factories;
public adaptiveextensionfactory() {
// ......
}
@override
public <t> t getextension(class<t> type, string name) {
// 通过遍历匹配到 type->name 的映射
for (extensionfactory factory : factories) {
t extension = factory.getextension(type, name);
if (extension != null) {
return extension;
}
}
return null;
}
}
以上是对 dubbo spi 扩展类简单加载过程分析完成。
自适应加载机制
为 dubbo 更加灵活的使一个接口不通过硬编码加载扩展机制，而是通过使用过程中进行加载，dubbo 的另一加载机制——自适应加载。
自适应加载机制使用 @adaptive 标注：
@documented
@retention(retentionpolicy.runtime)
@target({elementtype.type, elementtype.method})
public @interface adaptive {
string[] value() default {};
}
adaptive 的值是一个数组，可以配置多个 key。初始化时，遍历所有 key 进行匹配，如果没有则匹配 @spi 的值。
当 adaptive 注解标注在类上时，则简单对应该实现。如果注解标注在接口方法上时，则会根据参数动态生成代码来获取扩展点的实现。
类上注解处理还是比较好理解，方法上的注解加载相对比较有研读性。通过调用extensionloader#getadaptiveextension来进行获取扩展实现。
public t getadaptiveextension() {
// 获取实例化对象缓存
object instance = cachedadaptiveinstance.get();
if (instance == null) {
if (createadaptiveinstanceerror != null) {
throw new illegalstateexception("failed to create adaptive instance: " +
createadaptiveinstanceerror.tostring(),
createadaptiveinstanceerror);
}
// 双重检查锁后创建自适应扩展
synchronized (cachedadaptiveinstance) {
instance = cachedadaptiveinstance.get();
if (instance == null) {
try {
// 创建自适应扩展
instance = createadaptiveextension();
cachedadaptiveinstance.set(instance);
} catch (throwable t) {
createadaptiveinstanceerror = t;
throw new illegalstateexception("failed to create adaptive instance: " + t.tostring(), t);
}
}
}
}
return (t) instance;
}
private t createadaptiveextension() {
try {
// 获取自适应扩展后，注入依赖
return injectextension((t) getadaptiveextensionclass().newinstance());
} catch (exception e) {
throw new illegalstateexception("can't create adaptive extension " + type + ", cause: " + e.getmessage(), e);
}
}
上面代码完成了扩展类对象是否存在缓存中，如果不存在，则通过创建自适应扩展，并将实例注入依赖后，设置在实例化后的自适应扩展对象中。
其中getadaptiveextensionclass是比较核心的流程。
private class<?> getadaptiveextensionclass() {
// 加载全部扩展类
getextensionclasses();
// 加载全部扩展类后，如果有 @adaptive 标注的类，cachedadaptiveclass 则一定不会为空
if (cachedadaptiveclass != null) {
return cachedadaptiveclass;
}
// 创建自适应扩展类
return cachedadaptiveclass = createadaptiveextensionclass();
}
private class<?> createadaptiveextensionclass() {
// 生成自适应扩展代码
string code = new adaptiveclasscodegenerator(type, cacheddefaultname).generate();
// 获取扩展类加载器
classloader classloader = findclassloader();
// 获取编译器类型的实现类
org.apache.dubbo.common.compiler.compiler compiler = extensionloader.getextensionloader(org.apache.dubbo.common.compiler.compiler.class).getadaptiveextension();
// 编译代码，返回该对象
return compiler.compile(code, classloader);
}
这里完成的工作主要是，加载全部扩展类，代表所有扩展接口类的实现类，在其加载过程中，如果有 @adaptive 标注的类，会保存到 cachedadaptiveclass 中。通过自动生成自适应扩展代码，并被编译后，获取扩展类实例化对象。
上面编译器类型是可以指定的，通过 compiler 进行指定，例如：<dubbo:application name="taomall-provider" compiler="jdk" />，该编译器默认使用 javassist 编译器。
在 generate 方法中动态生成代码：
public string generate() {
// 检查当前扩展接口的方法上是否有 adaptive 注解
if (!hasadaptivemethod()) {
throw new illegalstateexception("no adaptive method exist on extension " + type.getname() + ", refuse to create the adaptive class!");
}
// 生成代码
stringbuilder code = new stringbuilder();
// 生成类的包名
code.append(generatepackageinfo());
// 生成类的依赖类
code.append(generateimports());
// 生成类的声明信息
code.append(generateclassdeclaration());
// 生成方法
method[] methods = type.getmethods();
for (method method : methods) {
code.append(generatemethod(method));
}
code.append("}");
if (logger.isdebugenabled()) {
logger.debug(code.tostring());
}
return code.tostring();
}
上面是生成类信息的方法，生成设计原理是按照已设置好的模板，进行替换操作，生成类。具体信息不代码很多，但阅读还是比较简单。
自适应加载机制，已简单分析完，咋一眼看，非常复杂，但是了解整体结构和流程，再去细研的话，相对还是好理解。
总结
从 dubbo 设计来看，其良好的扩展性，比较重要的一点是得益于 dubbo spi 加载机制。在学习它的设计理念，对可扩展性方面的编码思考也有一定的启发。
个人博客：
关注公众号 【ytao】，更多原创好文