共计 1617 个字符，预计需要花费 5 分钟才能阅读完成。
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);
}
}
