Dubbo源码(一)(深度剖析dubbo源码)

  本篇文章为你整理了Dubbo源码(一)(深度剖析dubbo源码)的详细内容,包含有dubbo源码解析20pdf 深度剖析dubbo源码 dubbo spi源码 dubbo示例代码 Dubbo源码(一),希望能帮助你了解 Dubbo源码(一)。

  为什么学SPI

  Dubbo 的可扩展性是基于 SPI 去实现的,而且Dubbo所有的组件都是通过 SPI 机制加载。

  什么是SPI

  SPI 全称为 (Service Provider Interface) ,是一种服务提供发现机制。可以将服务接口与服务实现分离以达到解耦可拔插、大大提升了程序可扩展性。

  说人话:

  一个接口有多个实现类,具体使用哪个实现类,通过SPI机制让用户来决定。也就是,定好规范,实现允许百花齐放。

  举栗子:

  以JDBC为例,Java提供了JDBC API用来连接 Java 编程语言和广泛的数据库。可是数据库种类这么多,无法一个个地去适配,怎么办?定好规范(Driver等一系列接口),实现类交由别人实现。

  那么,实现类也有了,JDBC怎么知道该使用什么实现类(毕竟命名可以千奇百怪)?通过SPI

  Java SPI

  简单体验下,Dubbo SPI才是重点

  
SPI配置文件

  在META-INF/services/目录下创建配置文件,文件名格式为接口的全限定名

  配置文件的内容为实现类的全限定的类名

  

com.javaedit.javaspi.RedColor

 

  com.javaedit.javaspi.BlueColor

  

 

  
public static void main(String[] args) {

   ServiceLoader Color colors = ServiceLoader.load(Color.class);

   for (Color color : colors) {

   System.out.println(color.getName());

  

 

 

  效果输出:

  red
 

  blue

  
配置文件

  在指定目录下创建配置文件,文件名格式为接口的全限定名(此处为com.javaedit.spi.Robot)

  指定目录有3个,分别为:

  META-INF/dubbo/internal

  META-INF/dubbo

  META-INF/services

  文件内容为:

  

norRobot = com.javaedit.spi.RobotImpl

 

  

 

  


public static void main(String[] args) {

 

   ExtensionLoader Robot extensionLoader = ExtensionLoader.getExtensionLoader(Robot.class);

   // 这里的name需要和配置文件中的key保持一致

   String name = "norRobot";

   Robot robot = extensionLoader.getExtension(name);

   robot.sayHello(null);

  

 

  
@SPI注解有value参数,可以配置默认实现类的key,例如:

  

// 接口的注解添加默认值

 

  @SPI("norRobot")

  // 获取实现类时将getExtension替换一下

  // Robot robot = extensionLoader.getExtension("norRobot");

  Robot robot = extensionLoader.getDefaultExtension();

  

 

  Dubbo SPI提供了类似装饰器模式的实现

  
在基本使用的代码基础上,增加包装类

  

public class RobotWrapper implements Robot {

 

   private Robot robot;

   // 带Robot参数的构造方法,这是包装类的重点

   public RobotWrapper(Robot robot) {

   this.robot = robot;

   @Override

   public void sayHello(URL url) {

   System.out.println("wrapper before...");

   this.robot.sayHello(url);

   System.out.println("wrapper after...");

  

 

  
碎碎念:

  原理就是RobotWrapper只要有构造方法是有且只有一个参数,且这个参数是Robot类型,就认为其实包装类,会自动将Robot通过构造方法注入。

  所以getExtension("norRobot")实际返回的是RobotWrapper

  自适应扩展

  有些拓展并不想在框架启动阶段被加载,而是希望在拓展方法被调用时,根据运行时参数进行加载。这就是Dubbo SPI自适应扩展的作用。

  @Adaptive:此注解用于自适应扩展,可标注在类或者方法上。

  类的自适应扩展

  
public void sayHello(URL url) {

   System.out.println("标注在类上的自适应代理类,类名:" + this.getClass().getSimpleName());

  

 

 

  


public static void main(String[] args) {

 

   ExtensionLoader Robot extensionLoader = ExtensionLoader.getExtensionLoader(Robot.class);

   // 不用再指定key

   Robot robot = extensionLoader.getAdaptiveExtension();

   robot.sayHello(null); // 此时的robot是AdaptiveRobot

  

 

  
当@Adaptive标注在类上时,无需通过key指定需要获取的实现类,通过getAdaptiveExtension方法即可获取自适应扩展类。同一个接口,有且只能有一个实现类允许使用@Adaptive标注

  方法的自适应扩展

  注意:@Adaptive标注在类上和标注在方法上是冲突的,将上一步的AdaptiveRobot删除,或者把AdaptiveRobot类的Adaptive注解注释掉

  
修改Robot接口,给sayHello方法添加@Adaptive注解。注意,是接口,不是实现类。

  

@SPI

 

  public interface Robot {

   @Adaptive("robotAda") // robotAda是名字,随意

   void sayHello(URL url);

  

 

  


public static void main(String[] args) {

 

   ExtensionLoader Robot extensionLoader = ExtensionLoader.getExtensionLoader(Robot.class);

   Map String, String map = new HashMap ();

   map.put("robotAda", "norRobot");

   URL url = new URL("", "", 1, map);

   Robot robot = extensionLoader.getAdaptiveExtension();

   robot.sayHello(url); // 此时的robot是Robot$Adaptive,但是实际调用的是RobotImpl的sayHello

  

 

  当@Adaptive标注在方法上时,getAdaptiveExtension获取的是动态生成的自适应扩展类,固定类名是 接口名$Adaptive,下面我们来看看自动生成的Robot$Adaptive长什么样

  
Robot$Adaptive,此类是动态生成的

  

public class Robot$Adaptive implements com.javaedit.spi.Robot {

 

   public void sayHello(com.alibaba.dubbo.common.URL arg0) {

   if (arg0 == null) throw new IllegalArgumentException("url == null");

   com.alibaba.dubbo.common.URL url = arg0;

   // 从url中获取robotAda参数,也就是extName = "norRobot"

   String extName = url.getParameter("robotAda");

   if (extName == null)

   throw new IllegalStateException("Fail to get extension(com.javaedit.spi.Robot) name from url(" + url.toString() + ") use keys([robot])");

   // 获取norRobot,也就是RobotImpl类

   com.javaedit.spi.Robot extension = (com.javaedit.spi.Robot) ExtensionLoader.getExtensionLoader(com.javaedit.spi.Robot.class).getExtension(extName);

   // 调用norRobot的sayHello方法

   extension.sayHello(arg0);

  

 

  Robot$Adaptive的sayHello会动态从URL参数中获取实际要调用的Robot实现类,这样就实现了根据运行时参数进行加载的功能。

  
碎碎念:

  动态选择实现类,是需要通过URL来传递参数的。也就是方法参数中需要包含URL对象或者方法参数中有getUrl()方法来提供URL对象。

  Dubbo SPI也支持类似spring自动注入的功能,来看看怎么用。

  
// 只要带set开头的方法,都会被判断是否需要自动注入

   public void setRobot(Robot robot) {

   this.robot = robot;

   @Override

   public void sayHello(URL url) {

   System.out.println("ioc start");

   robot.sayHello(url);

  

 

 

  setRobot方法注入的robot是通过自适应扩展方法getAdaptiveExtension获取的

  


public static void main(String[] args) {

 

   ExtensionLoader Robot extensionLoader = ExtensionLoader.getExtensionLoader(Robot.class);

   Map String, String map = new HashMap ();

   map.put("robot", "norRobot");

   URL url = new URL("", "", 1, map);

   Robot robot = extensionLoader.getExtension("iocRobot");

   robot.sayHello(url);

  

 

  输出结果:

  ioc start
 

  大家好,我是普通机器人...

  由输出结果看到,setRobot注入的是norRobot,而norRobot自适应扩展从URL中获取的。

  以上就是Dubbo源码(一)(深度剖析dubbo源码)的详细内容,想要了解更多 Dubbo源码(一)的内容,请持续关注盛行IT软件开发工作室。

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: