我是靠谱客的博主 勤劳金针菇,最近开发中收集的这篇文章主要介绍1. SPI应用场景之 DUBBO SPI一、DUBBO SPI使用场景二、dubbo spi 扩展点,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

一、DUBBO SPI使用场景

动态根据配置加载对应实现类,SPI扩展的类有非常多:
(./images/1565427462864.png)]

二、dubbo spi 扩展点

①dubbo SPI基础:

根据META-INF文件下的key获取类名,再获取类的实例
对应方法为,getExtension(),举例:

 		LoadBalance loadBalance = 
            ExtensionLoader.getExtensionLoader(LoadBalance.class).getExtension("random");
        //获取到RadomLoadBalance类实例
        System.out.println(loadBalance);

②DUBBO SPI增强,自适应扩展机制:

对应方法为,getAdaptiveExtension(),举例:

	//此处获取到的并不是具体的协议实现类,而是获取到一个自适应的Adaptive类
        Protocol protocol = 
                ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
        //通过Adaptive类调用远程服务,可根据url的协议自适应到:具体协议实现类,完成远程协议调用
        protocol.refer(type, url);
				

什么叫自适应,引用官网的解释

有时,有些拓展并不想在框架启动阶段被加载,而是希望在拓展方法被调用时,根据运行时参数进行加载。这听起来有些矛盾。拓展未被加载,那么拓展方法就无法被调用(静态方法除外)。拓展方法未被调用,拓展就无法被加载。对于这个矛盾的问题,Dubbo 通过自适应拓展机制很好的解决了。自适应拓展机制的实现逻辑比较复杂,首先 Dubbo 会为拓展接口生成具有代理功能的代码。然后通过 javassist 或 jdk 编译这段代码,得到 Class 类。最后再通过反射创建代理类,整个过程比较复杂。

我们再举个例子解释下,例如:dubbo提供了很多协议:dubbo、rmi、http、webservice等。但实际我们用的时候,可能只会选择一种协议,假设我们选择使用rmi协议,则dubbo会在运行的时候才去加载RMI的协议实现类(并在加载一次后缓存起来),其他http、webservice等协议实现类没有用到就不会加载。这就是自适应加载。dubbo里面的Adaptive类就是做这个加载动作的。

Adaptive类有2种加载方式:

① 静态

静态Adaptive类,即Adaptive类在项目中是存在的,不需要去动态生成的
当通过getAdaptiveExtension()获取自适应扩展点时,将去查找META-INF下所有类中,有@Adaptive注解的类。

举例:
Compiler的Adaptive类是:AdaptiveCompiler

META-INF/dubbo/internal/com.alibaba.dubbo.common.compiler.Compiler文件如下:

adaptive=com.alibaba.dubbo.common.compiler.support.AdaptiveCompiler
jdk=com.alibaba.dubbo.common.compiler.support.JdkCompiler
javassist=com.alibaba.dubbo.common.compiler.support.JavassistCompiler

当执行以下代码时,会直接返回@Adaptive标注的AdaptiveCompiler类的实例:

Compiler compiler = 
                ExtensionLoader.getExtensionLoader(Compiler.class).getAdaptiveExtension();

② 动态

动态Adaptive类是在调用的时候,字节码是在运行的时候实时生成的,再通过动态反射创建类。

举例:获取Protocol接口的Adaptive类

首先在META-INF下的,com.alibaba.dubbo.rpc.Protocol中,所有的类都没有@Adaptive注解,这个时候会通过代码去生成Adaptive的字节码

filter=com.alibaba.dubbo.rpc.protocol.ProtocolFilterWrapper
listener=com.alibaba.dubbo.rpc.protocol.ProtocolListenerWrapper
mock=com.alibaba.dubbo.rpc.support.MockProtocol
injvm=com.alibaba.dubbo.rpc.protocol.injvm.InjvmProtocol
....... 等等

生成Adaptive类字节码的方法详细可参考:ExtensionLoader.createAdaptiveExtensionClassCode()

在这里插入图片描述

可以看到生成的类名为 接口名称$Adapative,并且会重写@Adaptive注解的方法
在这个Adaptive类里面,我们可以大胆的猜测,实际就是根据一个关键字获取对应的实现类。那这个关键字从哪里取呢,我们知道dubbo就是通过URL调用的,新增了timeout参数、调用的协议都会在URL中以参数形式存在的… 没错,就是在URL中取…

我们来看下生成之后的代码:
在这里插入图片描述

我们将代码拷贝出来,格式化下:

package com.alibaba.dubbo.rpc;

import com.alibaba.dubbo.common.extension.ExtensionLoader;

public class Protocol$Adpative implements com.alibaba.dubbo.rpc.Protocol {
	public void destroy() {
		throw new UnsupportedOperationException("method public abstract void com.alibaba.dubbo.rpc.Protocol.destroy() of interface com.alibaba.dubbo.rpc.Protocol is not adaptive method!");
	}

	public int getDefaultPort() {
		throw new UnsupportedOperationException("method public abstract int com.alibaba.dubbo.rpc.Protocol.getDefaultPort() of interface com.alibaba.dubbo.rpc.Protocol is not adaptive method!");
	}

	public com.alibaba.dubbo.rpc.Invoker refer(java.lang.Class arg0, com.alibaba.dubbo.common.URL arg1)
			throws com.alibaba.dubbo.rpc.RpcException {
		if (arg1 == null)
			throw new IllegalArgumentException("url == null");
		com.alibaba.dubbo.common.URL url = arg1;
		String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());
		if (extName == null)
			throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.Protocol) name from url(" + url.toString() + ") use keys([protocol])");
		com.alibaba.dubbo.rpc.Protocol extension = (com.alibaba.dubbo.rpc.Protocol) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName);
		return extension.refer(arg0, arg1);
	}

	public com.alibaba.dubbo.rpc.Exporter export(
			com.alibaba.dubbo.rpc.Invoker arg0)
			throws com.alibaba.dubbo.rpc.RpcException {
		if (arg0 == null)
			throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument == null");
		if (arg0.getUrl() == null)
			throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");
		com.alibaba.dubbo.common.URL url = arg0.getUrl();
		String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());
		if (extName == null)
			throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.rpc.Protocol) name from url(" + url.toString() + ") use keys([protocol])");
		com.alibaba.dubbo.rpc.Protocol extension = (com.alibaba.dubbo.rpc.Protocol) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName);
		return extension.export(arg0);
	}
}

Protocol类有两个@Adaptive方法,export()-》服务暴露; refer()-》服务调用;
通过这两个方法也能很明显的看出就是从url中获取到协议,然后根据协议名称,获取具体的实现类
在这里插入图片描述

最后,再用一张思维导图总结下:
在这里插入图片描述

最后

以上就是勤劳金针菇为你收集整理的1. SPI应用场景之 DUBBO SPI一、DUBBO SPI使用场景二、dubbo spi 扩展点的全部内容,希望文章能够帮你解决1. SPI应用场景之 DUBBO SPI一、DUBBO SPI使用场景二、dubbo spi 扩展点所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(58)

评论列表共有 0 条评论

立即
投稿
返回
顶部