乐趣区

dubbo之SPI自适应扩展机制

1、背景
在 Dubbo 中,很多拓展都是通过 SPI 机制进行加载的,比如 Protocol、Cluster、LoadBalance 等。有时,有些拓展并不想在框架启动阶段被加载,而是希望在拓展方法被调用时,根据运行时参数进行加载。这听起来有些矛盾。拓展未被加载,那么拓展方法就无法被调用(静态方法除外)。拓展方法未被调用,拓展就无法被加载。对于这个矛盾的问题,Dubbo 通过自适应拓展机制很好的解决了。自适应拓展机制的实现逻辑比较复杂,首先 Dubbo 会为拓展接口生成具有代理功能的代码。然后通过 javassist 或 jdk 编译这段代码,得到 Class 类。最后再通过反射创建代理类,整个过程比较复杂。
2、原理
为了很好的理解,下面结合实例进行分析,在 Dubbbo 暴露服务中,ServiceConfig 类中 doExportUrlsFor1Protocol 方法中有如下这样一条语句:
Exporter<?> exporter = protocol.export(wrapperInvoker);
接下来咱们就根据这条语句进行深入分析 Dubbo SPI 自适应扩展机制。
根据源码查询得知,protocol 对象是通过以下语句创建:
private static final Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
根据上篇文章,咱们得知 getExtensionLoader 只是获取 ExtensionLoader 对象,所以自适应扩展的核心在 getAdaptiveExtension() 方法中:
public T getAdaptiveExtension() {
// 缓存获取实例对象
Object instance = cachedAdaptiveInstance.get();
// 双重检测
if (instance == null) {
if (createAdaptiveInstanceError == null) {
synchronized (cachedAdaptiveInstance) {
instance = cachedAdaptiveInstance.get();
if (instance == null) {
try {
// 创建实例对象
instance = createAdaptiveExtension();
cachedAdaptiveInstance.set(instance);
} catch (Throwable t) {
createAdaptiveInstanceError = t;
throw new IllegalStateException(“fail to create adaptive instance: ” + t.toString(), t);
}
}
}
} else {
throw new IllegalStateException(“fail to create adaptive instance: ” + createAdaptiveInstanceError.toString(), createAdaptiveInstanceError);
}
}

return (T) instance;
}
在 getAdaptiveExtension 方法中先从缓存中获取,缓存中不存在在创建实例,并存入缓存中,逻辑比较简单,咱们在来分析 createAdaptiveExtension 方法:
private T createAdaptiveExtension() {
try {
return injectExtension((T) getAdaptiveExtensionClass().newInstance());
} catch (Exception e) {
throw new IllegalStateException(“Can not create adaptive extension ” + type + “, cause: ” + e.getMessage(), e);
}
}

退出移动版