系统整理下Java SPI,Dubbo SPI,Spring SPI。
Java SPI
简述
有点类似于策略设计模式,定义好接口,在文件中写实现类的全路径名。调用ServiceLoader.load
的时候返回一个迭代器,他内部是一个懒加载,当调用hasNext
的时候才会根据全路径名读取文件,调用next
的时候才会实例化。
本质上就是,获取接口全路径名,安规范去该路径下按行读取文件,然后用同一个类加载器加载类,返回。(源码很简单,就不多说了,使用方法看图)
优点
类似于模板方法,定义好接口,实现可以完全由第三方来写,按照规范就行。
缺点
人家自己也说了,一个简单的服务提供者的加载工具。人家源码开发者就没想写的多好用,就是写个demo秀操作呢。
Dubbo SPI
简介
官网:dubbo.apache.org/zh/docs/v2.…
优点
- JDK 标准的 SPI 会一次性实例化扩展点所有实现,如果有扩展实现初始化很耗时,但如果没用上也加载,会很浪费资源。
- 如果扩展点加载失败,连扩展点的名称都拿不到了。比如:JDK 标准的 ScriptEngine,通过 getName() 获取脚本类型的名称,但如果 RubyScriptEngine 因为所依赖的 jruby.jar 不存在,导致 RubyScriptEngine 类加载失败,这个失败原因被吃掉了,和 ruby 对应不起来,当用户执行 ruby 脚本时,会报不支持 ruby,而不是真正失败的原因。
- 增加了对扩展点 IoC 和 AOP 的支持,一个扩展点可以直接 setter 注入其它扩展点。
但是我跟了源码,不是一次性加载所有,是调用的时候创建(java 版本1.8.0_211)
分析
- 既然是加强,那其实本质上也是差不多的,就是获取到自定义实现类。我先看了下目录下的文件,是key,value的形式,那么猜测就是根据加强点应该就是根据key获取到指定的实现类。看了下源码,调用
com.alibaba.dubbo.common.extension.ExtensionLoader#getAdaptiveExtension
的时候,就会进行解析对应的文件,结果如下
- adaptive
但是里面没有自适应的,比如ExtensionFactory
获取的时候,解析到adaptive
标签,会缓存到cachedAdaptiveClass
如果没有获取到他会拼接字符串+编译的方式生成一个,代码如下
package com.alibaba.dubbo.rpc;
import com.alibaba.dubbo.common.extension.ExtensionLoader;
public class Protocol$Adpative implements com.alibaba.dubbo.rpc.Protocol {
public com.alibaba.dubbo.rpc.Exporter export(com.alibaba.dubbo.rpc.Invoker arg0) throws com.alibaba.dubbo.rpc.Invoker {
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);
}
public com.alibaba.dubbo.rpc.Invoker refer(java.lang.Class arg0, com.alibaba.dubbo.common.URL arg1) throws java.lang.Class {
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 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!");
}
}
复制代码
然后就是根据url中的协议,去找到对应实现,对应的这一行
(com.alibaba.dubbo.rpc.Protocol)ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName);
后面就没啥好说的了,调用对应的refer。
Spring SPI
上一篇分析了,这里就不多赘述了,整体思路差不多,框架定义接口,第三方jar包自定义实现,按照规范在指定位置定义key,value
© 版权声明
文章版权归作者所有,未经允许请勿转载。
THE END