Dubbo自定义标签和扩展点

       Alibaba   Dubbo是开源的分布式服务治理框架,提供了服务注册,服务发现,动态配置和路由的功能。

Spring自定义标签

通过自定义标签,跟Spring无缝结合,自定义标签需要两个部分:在项目的resource/META-INF包里面配置2个文件spring.handlers和spring.schemas

spring.handlers 的内容:

http\://code.alibabatech.com/schema/dubbo=com.alibaba.dubbo.config.spring.schema.DubboNamespaceHandler

定义了解析标签的类com.alibaba.dubbo.config.spring.schema.DubboNamespaceHandler

spring.schemas的内容:

http\://code.alibabatech.com/schema/dubbo/dubbo.xsd=META-INF/dubbo.xsd

用一个url来映射我们配置好的文件

dubbo.xsd的内容:

DubboNamespaceHandler继承了Spring的NamespaceHandlerSupport接口 init方法注册了各个标签的解析器 ,根据解析生成对应的BeanDefinition,这样就可以在Spring中使用自定义的标签

扩展点

JDK的ServiceLoader

JDK提供给我们一套扩展点机制,通过ServiceLoader遍历所有jar查找META-INF/services目录下实现某个接口的实现类,现在以Spark中的一个例子说明

       这里就用ServiceLoader加载所有的DataSourceRegister然后判断每个对象的shortName()是否给定的值,这样我们可以实现自己的数据源。

Dubbo的ExtensionLoader

我们一般用ExtensionLoader.getExtensionLoader(***.class)开始获取扩展点。

type 必须不为空且为接口还得有SPI注解,先从缓存中有该接口对应的ExtensionLoader,如果没有的话new一个 ,然后放进缓存中。返回这个ExtensionLoader。

看一下实例化的过程:

会用到ExtensionFactory接口的Adaptive实现 看一下getAdaptiveExtension方法

先判断是否已经存在,然后加锁再判断,如果依旧不存在,调用createAdaptiveExtension方法生成一个并缓存。

cachedClasses定义:

如果还没有设置则调用loadExtensionClasses方法加载

先判断SPI注释中参数不能大于1,赋值给成员变量cachedDefaultName,作为缺省的实现

loadFile方法中三个常数如下:

看一下loadFile:

先读取文件中的内容


根据配置反射得出clazz

clazz必须是type的实现类,如果有Adaptive注解则判断cachedAdaptiveCalss是否为空,如果为空,赋值给cachedAdaptiveCalss,否则系统中会有两个cachedAdaptiveCalss,抛出异常提示。

这里根据type接口作为参数找到一个包装类,如果有则加入wrapper这个Set中,这里的ConcurrentHashSet是Dubbo自己根据JDK的ConcurrentHashMap实现的

如果不是包装类

这里主要是给cachedActivities加入有Activite注解的类,并且映射class和name以及name和class。

返回前面getAdaptiveExtensionClass方法,如果我们前面缓存了cachedAdaptiveClass就直接返回cachedAdaptiveClass。调用injectExtension方法进行注入:

通过反射给set调用set方法赋值。

如果没有cachedAdaptiveClass则通过字节码生成器生成

需要至少有一个方法有Adaptive注解

实现的思想是根据方法的参数URL,Invocation等不同加载对同的扩展点

比如:Protocol生成以下:

class Protocol$Adpative implements Protocol{  

    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.Invokerargument == null");   

        }  

        if (arg0.getUrl() == null) {   

            throw new IllegalArgumentException("com.alibaba.dubbo.rpc.Invoker argument getUrl() == null");   

        }  

com.alibaba.dubbo.common.URLurl = arg0.getUrl();  

StringextName = ( 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.Protocolextension = (com.alibaba.dubbo.rpc.Protocol)com.alibaba.dubbo.common.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 com.alibaba.dubbo.rpc.RpcException{  

if (arg1 == null)  {   

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

        }  

com.alibaba.dubbo.common.URLurl = arg1;  

StringextName = ( 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.Protocolextension = (com.alibaba.dubbo.rpc.Protocol)com.alibaba.dubbo.common.ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.rpc.Protocol.class).getExtension(extName);  

        return extension.refer(arg0, arg1);  

    }

看一下getExtension

如果缓存有则返回,没有则调用createExtension生成一个在缓存

先对该name的扩展点实例化,然后判断时候有Wrapper的包装类,如果有,则一层层包装,最后返回一个包装类,而不是name的扩展点实例,这里我们可以实现自己的逻辑。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,236评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,867评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,715评论 0 340
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,899评论 1 278
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,895评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,733评论 1 283
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,085评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,722评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,025评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,696评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,816评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,447评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,057评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,009评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,254评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,204评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,561评论 2 343

推荐阅读更多精彩内容

  • 总结:Protocolrefprotocol = ExtensionLoader.getExtensionLoad...
    Ngcc阅读 703评论 0 2
  • 前面我们了解过了Java的SPI扩展机制,对于Java扩展机制的原理以及优缺点也有了大概的了解,这里继续深入一下D...
    加大装益达阅读 5,030评论 2 20
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,598评论 18 139
  • 早上七点就要把孩子送进学校了。女儿自上中学,我也一改往日作息习惯。过去晚间,生活上按排略为闲适些----检查...
    帕客阅读 376评论 0 1
  • Test test
    mx乐乐阅读 152评论 0 0