前面我们已经了解了JDK SPI的原理、实现、优缺点。java
Dubbo在JDK SPI基础之上作了一些优化。app
大部分的思想都是和 SPI 是同样,只是下面两个地方有差别。ide
1. 须要在 resource 目录下配置 META-INF/dubbo 或者META-NF/dubbo/internal 或者 META-INF/services,并基于 SPI 接口去建立一个文件优化
2. 文件名称和接口名称保持一致,文件内容和 SPI 有差别,内容是 KEY 对应 Valueurl
基于上面所说我们本身来实现一个MyProtocolspa
第一步自定义一个类Protocl,而且实现com.alibaba.dubbo.rpc.Protocol。代理
package com.tian.dubbo.protocol; import com.alibaba.dubbo.common.URL; import com.alibaba.dubbo.rpc.Exporter; import com.alibaba.dubbo.rpc.Invoker; import com.alibaba.dubbo.rpc.Protocol; import com.alibaba.dubbo.rpc.RpcException; /** * 自定义协议 * (这里只是作一个演示,因此只是把端口调整了) * @Author tianweichang * @Date 2018-08-16 14:50 **/ public class MyProtocol implements Protocol{ @Override public int getDefaultPort() { //自定义协议端口为10009 return 10009; } @Override public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException { return null; } @Override public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException { return null; } @Override public void destroy() { } }
第二步:orm
而后就是配置MATE-IN/dubbo/com.alibaba.dubbo.rpc.Protocol。内容就是myProtocol做为kay,com.tian.dubbo.protocol.MyProtocol为valuexml
第三步:对象
在provider.xml中
<dubbo:protocol name="myProtocol"/>
最后启动dubbo服务
能够看出咱们自定义的协议已经生效,端口10009
1. Protocol protocol = ExtensionLoader.getExtensionLoader(Protocol.class).
getExtension("myProtocol");
2. Protocol protocol =ExtensionLoader.getExtensionLoader(Protocol.class).
getAdaptiveExtension();
通 过 一 个 Class 参 数 去 获 得 一 个ExtensionLoader 对象,有点相似一个工厂模式。
getAdaptiveExtension,去得到一个自适应的扩展点
dubbo源码
最终生成一个代理类Protocol$Adaptive.java