Dubbo系列<10>-Dubbo SPI

前面我们已经了解了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();

  1.  通 过 一 个 Class 参 数 去 获 得 一 个ExtensionLoader 对象,有点相似一个工厂模式。

  2.  getAdaptiveExtension,去得到一个自适应的扩展点


dubbo源码

最终生成一个代理类Protocol$Adaptive.java

相关文章
相关标签/搜索