Dubbo源码阅读-可扩展机制

乐云一
  • Dubbo
  • Dubbo
About 1288 wordsAbout 4 min

Dubbo源码阅读-可扩展机制

Dubbo在高性能的同时,依靠其特殊的SPI、自适应、包装、激活机制,提供了可扩展的机制。

Dubbo SPI

在原理上,和JDK的一致。但是为了改善原生的种种特点就有了以下几种特性。

指定实例

META-INF/services的配置文件中:

red = xyz.leyuna.laboratory.core.spi.RedCar
yellow = xyz.leyuna.laboratory.core.spi.YellowCar

key-value的形式配置实例类。

然后在使用中,通过ExtensionLoader提供方法指定需要的实例

        ExtensionLoader<CarInterface> extensionLoader =   ExtensionLoader.getExtensionLoader(CarInterface.class);
        CarInterface red = extensionLoader.getExtension("red");
        red.didi();

getExtension方法中,如果当入参为 “true”时,会直接返回根据接口上 @SPI设置的默认值的实例

@SPI(value = "red")
public interface CarInterface 

如果有自定义入参,则通过入参值获取实例:

  1. 在本地缓存中查询有无该入参对应实例
  2. loadExtensionClasses方法中 根据 DUBBO_INTERNAL_DIRECTORY、DUBBO_DIRECTORY,和SERVICES_DIRECTORY ... /META-INF/services 、/META-INF/dubbo 、 ....等等函数,读取配置文件中的key-value对值,并且将其存储在本地Map中;由于使用Map存储,但有多个文件路径,所以存在优先级问题,/META-INF/services为最高优先级,其中的值不会被覆盖。
  3. loadDirectory 方法 是在步骤二中完成的,原理和JDK的类型,通过路径+接口全类名的形式,读取配置文件的同时,返回其实例
  4. 在上述步骤中,会将读取到的所有实例、与实例名,通过key-value的形式本地缓存,extensionLoader.getExtension("red");直接在map中取出。

AOP

Dubbo的AOP机制,通过读取配置文件时,如果读取到了装饰接口方法的装饰类时,则会走到AOP的思路。

  1. 装饰类定义

    public class CarAOP implements CarInterface{
    
        private CarInterface carInterface;
    
        public CarAOP(CarInterface carInterface){
            this.carInterface = carInterface;
        }
    
        @Override
        public void didi(URL url) {
            System.out.println("aop加强");
            carInterface.didi(url);
            System.out.println("aop加强完成");
        }
    }
    

    实现接口、并且在定义接口属性的同时,一定要实现一个接口入参为第一个的构造函数。

  2. 添加配置文件属性

    red = xyz.leyuna.laboratory.core.spi.RedCar
    yellow = xyz.leyuna.laboratory.core.spi.YellowCar
    xyz.leyuna.laboratory.core.spi.CarAOP
    

这样在通过 CarInterface red = extensionLoader.getExtension("red"); 得到的实例,则会被自动加强,那么原理如何呢?

  1. 读取配置文件,读取到包装类时,判断该类是否为装饰类;判断原理,通过是否实现接口以及构造方法的第一个入参是否为接口类型。
  2. 如果是装饰类,则将其缓存到包装类缓存中。
  3. 如果包装类缓存不为空,则说明有对象需要被AOP加强,进入到AOP逻辑中
  4. 解析包装类@Wrapper注解
  5. 通过 instance = injectExtension((T) wrapperClass.getConstructor(type).newInstance(instance)); 循环包装,实例化出装饰类,并且将当前实例入参,覆盖掉原先的实例对象。
  6. 加入到本地缓存,返回实例。

以上的所有步骤都是在 **createExtension()**方法中完成,需要注意的是 createExtension方法除了name入参key外,还有一个布尔类型wrap值用来控制是否需要包装当前实例。

需要不需要返回AOP加强的实例,只需要

extensionLoader.getExtension("red",false);

IOC

Dubbo的IOC注入,依靠的是Set方法注入。由于没有Spring的IOC容器,所以判断是否存在依赖注入,为判断读取配置文件时,当前类中有无@Adaptive修饰类的set方法。

所以在源码中,通过 injectExtension方法操作:

  1. 当前类是否有Set相关方法,如果没有则说明不涉及IOC
  2. 如果当前类被@DisableInject注释说明,说明不需要过度解析,不涉及IOC
  3. 找到当前类的set方法中第一参数为对象的方法,解析这个方法名,如果方法名为setCarInterface,则返回set后面CarInterface字符串。
  4. 获得这个字符串以及class组合的CarInterface$Adaptive Dubbo自定义对象。
  5. 调用方法,赋值完成IOC注入, CarInterface$Adaptive 则是通过 this.objectFactory.getExtension 解析出来的方法入参。

不难发现,IOC的注入方式在Spring中多用于依赖注入,而Dubbo则规范与Set注入形式。并且通过AdaptiveExtensionFactory和ExtensionFatocry 工厂,在注入的同时还可以兼容Spring容器使用。

@Adaptive

自适应扩展点,在前文有提到过这个注释。

在IOC注入的时候,由于多扩展的场景,所以Dubbo提供注释,可以根据Dubbo中的URL对象中的parameters属性。

key-value的形式指定被该注释修饰的方法或类的实例,具体用户如下:

接口

public interface CarInterface {

    @Adaptive("carType")
    void didi(URL url);
}

注入接口的实例类

public class My implements PersonInterface{

    private CarInterface carInterface;

    public void setCarInterface(CarInterface carInterface){
        this.carInterface = carInterface;
    }

    @Override
    public void driveCar(URL url) {
        System.out.println("警告,我开车来了");
        carInterface.didi(url);
    }
}

测试方法:

        ExtensionLoader<PersonInterface> extensionLoader = ExtensionLoader.getExtensionLoader(PersonInterface.class);
        PersonInterface my = extensionLoader.getExtension("my");
        Map<String,String> map = new HashMap<>();
        map.put("carType","yellow");
        URL url = new URL("","",0,map);
        my.driveCar(url);
Last update:
Contributors: leyunone
Comments
  • Latest
  • Oldest
  • Hottest
Powered by Waline v2.14.7