Dubbo自适应拓展机制原理与实例

JDK SPI 基本原理

java.util.ServiceLoader 加载 META-INF/services 目录下名称为 SPI接口全限名 的配置文件。存在的问题：

1. 会加载所有的实现类并且实例化。但有时候你并不想用某些实现类，造成浪费
2. 获取某个实现类的方式不够灵活，只能遍历

Dubbo SPI

优点：

1. 方便获取实现类：使用k-v配置
2. IoC依赖注入功能：通过Adaptive来实现，根据参数来选择不同的实现类
3. 采用装饰器模式进行功能增强

Dubbo的拓展类(Extension)是通过SPI机制加载的：

• 对于某个SPI接口Car，加载指定目录下(META-INF/dubbo)名称为SPI接口全限名(org.apache.dubbo.common.extension.Car)的配置文件
• 对于配置文件里的每一行键值对(ferrari=org.apache.dubbo.common.extension.Ferrari)，加载SPI接口的实现类，也就是拓展类，然后创建实例

有时候我们不希望在Dubbo启动阶段就加载所有的拓展类，而是希望在用到某个拓展类时才加载，这就需要借助于自适应拓展机制。

• 对于某个SPI接口Car，生成一个自适应拓展类Car$Adaptive，并创建实例
• 调用该实例的方法时(SPI接口中包含Adaptive注解的方法)，会加载拓展类并创建拓展实例，然后调用它的方法

比如我们定义了一个SPI接口：

package org.apache.dubbo.common.extension;

import org.apache.dubbo.common.URL;

@SPI
public interface Car {
    String getBrand();
    long getWeight();
    @Adaptive
    void make(URL url, String brand, long weight);
}

Dubbo生成的自适应拓展类如下：

package org.apache.dubbo.common.extension;

import org.apache.dubbo.common.extension.ExtensionLoader;

public class Car$Adaptive implements org.apache.dubbo.common.extension.Car {
    // 自适应方法
    public void make(org.apache.dubbo.common.URL arg0, java.lang.String arg1, long arg2) {
        if (arg0 == null) throw new IllegalArgumentException("url == null");
        // 查询URL里配置的属性，属性名是接口的小写，默认值在AdaptiveClassCodeGenerator里指定
        // 比如：new AdaptiveClassCodeGenerator(Car.class, "ferrari")
        org.apache.dubbo.common.URL url = arg0;
        String extName = url.getParameter("car", "ferrari");
        if (extName == null)
            throw new IllegalStateException(
                    "Failed to get extension (org.apache.dubbo.common.extension.Car) name from url ("
                            + url.toString() + ") use keys([car])");
        // 获取拓展实例
        org.apache.dubbo.common.extension.Car extension = (org.apache.dubbo.common.extension.Car)
                ExtensionLoader.getExtensionLoader(org.apache.dubbo.common.extension.Car.class)
                        .getExtension(extName);
        // 调用拓展实例的方法
        extension.make(arg0, arg1, arg2);
    }

    // 不支持非自适应方法
    public long getWeight() {
        throw new UnsupportedOperationException(
                "The method public abstract long org.apache.dubbo.common.extension.Car.getWeight() " +
                        "of interface org.apache.dubbo.common.extension.Car is not adaptive method!");
    }

    // 不支持非自适应方法
    public java.lang.String getBrand() {
        throw new UnsupportedOperationException(
                "The method public abstract java.lang.String org.apache.dubbo.common.extension.Car.getBrand() " +
                        "of interface org.apache.dubbo.common.extension.Car is not adaptive method!");
    }
}

谢谢阅读！