Dubbo和Spring的融合

Dubbo和Spring的融合

通常,我们使用Dubbo的时候会创建如下的配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        http://dubbo.apache.org/schema/dubbo        http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
 
    <!-- 提供方应用信息,用于计算依赖关系 -->
    <dubbo:application name="hello-world-app"  />
 
    <!-- 使用multicast广播注册中心暴露服务地址 -->
    <dubbo:registry address="multicast://127.0.0.1:1234" />
 
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
 
    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />
 
    <!-- 和本地bean一样实现服务 -->
    <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />
</beans>

像dubbo:service这样的标签是如何添加到spring并且被识别的呢?

答案是它使用了Spring的xsd schema文档定义语言来实现的,首先我们自定义一套schema来熟悉一下Spring的可扩展Schema。

分为五个步骤

1.设计配置属性和Bean

2.编写xsd文件

3.使用NamespaceHandler和BeanDefinitionHandler来完成解析工作

4.配置spring.handlers和spring.schemas串联这些类

5.在spring中使用这个bean

(1)定义一个User类:

@Data
public class User {

    String id;

    private String name;

    private String email;

    private int age;
}

(2)编写xsd文件

文件名称为spring-test.xsd,名称可以自定义

<?xml version="1.0" encoding="UTF-8"?>
<schema xmlns="http://www.w3.org/2001/XMLSchema" targetNamespace="http://www.fanfte.com/schema/user"
        xmlns:tns="http://www.fanfte.com/schema/user" elementFormDefault="qualified">
    <element name="user">
        <complexType>
            <attribute name="id" type="string"/>
            <attribute name="age" type="int" />
            <attribute name="name" type="string" />
            <attribute name="email" type="string" />
        </complexType>
    </element>
</schema>

(3)使用NamespaceHandler和BeanDefinitionHandler来完成解析工作

首先编写bean解析器

public class UserBeanDefinitionParser extends AbstractSimpleBeanDefinitionParser {

    @Override
    protected Class<?> getBeanClass(Element element) {
        return User.class;
    }

    @Override
    protected void doParse(Element element, BeanDefinitionBuilder builder) {
        String id = element.getAttribute("id");
        String name = element.getAttribute("name");
        String email = element.getAttribute("email");
        Integer age = Integer.parseInt(element.getAttribute("age"));
        if(StringUtils.hasText(id)) {
            builder.addPropertyValue("id", id);
        }
        if(StringUtils.hasText(name)) {
            builder.addPropertyValue("name", name);
        }
        if(StringUtils.hasText(email)) {
            builder.addPropertyValue("email", email);
        }
        if(age != null) {
            builder.addPropertyValue("age", age);
        }
    }
}

再编写命名空间处理器:

public class UserNameSpaceHandler extends NamespaceHandlerSupport {
    @Override
    public void init() {
        registerBeanDefinitionParser("user", new UserBeanDefinitionParser());
    }
}

(4)配置spring.handlers和spring.schemas串联这些类

再项目的classpath下的META-INF下配置两个文件:

spring.handlers

http\://www.fanfte.com/schema/user=com.fanfte.rpc.spring.UserNameSpaceHandler

spring.schemas

http\://www.fanfte.com/schema/user.xsd=META-INF/spring-text.xsd

这里的路径对应了第二步xsd文件中的路径,类名对应了命名空间解析器的全路径名com.fanfte.rpc.spring.UserNameSpaceHandler

(5)配置和加载bean到spring容器

classpath下新建一个application-tag.xml文件,内容如下:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:userTag="http://www.fanfte.com/schema/user" 
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.fanfte.com/schema/user http://www.fanfte.com/schema/user.xsd">

    <userTag:user id="userTag" name="userBean" email="fanfte@163.com" age="18"/>
    <!--<fanfteRPC:reference id="demoService" interface="com.fanfte.rpc.service.DemoService"></fanfteRPC:reference>-->
</beans>

xml中使用配置了的bean ,标签名称为userTag,对应了文件中的第四行的xmlns:userTag

最后,在main方法中使用这个bean

public class UserTagTest {

    @Autowired
    private DemoService demoService;

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:META-INF/application-tag.xml");
        User user = (User) context.getBean("userTag");
        System.out.println(user.getAge() + " " + user.getEmail() + " " + user.getName());
    }
}

这样就使用了自定义的xsd来配置使用我们自定义的标签。dubbo也有一套自己的自定义标签。

Dubbo融合Spring

<1>首先我们看到DubboNamespaceHandler这个类内部

public class DubboNamespaceHandler extends NamespaceHandlerSupport {

    static {
        Version.checkDuplicate(DubboNamespaceHandler.class);
    }

    @Override
    public void init() {
        registerBeanDefinitionParser("application", new DubboBeanDefinitionParser(ApplicationConfig.class, true));
        registerBeanDefinitionParser("module", new DubboBeanDefinitionParser(ModuleConfig.class, true));
        registerBeanDefinitionParser("registry", new DubboBeanDefinitionParser(RegistryConfig.class, true));
        registerBeanDefinitionParser("monitor", new DubboBeanDefinitionParser(MonitorConfig.class, true));
        registerBeanDefinitionParser("provider", new DubboBeanDefinitionParser(ProviderConfig.class, true));
        registerBeanDefinitionParser("consumer", new DubboBeanDefinitionParser(ConsumerConfig.class, true));
        registerBeanDefinitionParser("protocol", new DubboBeanDefinitionParser(ProtocolConfig.class, true));
        registerBeanDefinitionParser("service", new DubboBeanDefinitionParser(ServiceBean.class, true));
        registerBeanDefinitionParser("reference", new DubboBeanDefinitionParser(ReferenceBean.class, false));
        registerBeanDefinitionParser("annotation", new AnnotationBeanDefinitionParser());
    }

}

这个类就是Dubbo的命名空间处理器,可以看到有10种的命名空间,而定义的配置属性也定义在了xxxConfig和xxxBean里面,而解析器则使用了DubboBeanDefinitionParser和AnnotationBeanDefinitionParser两种。

从这个类可以看到已经完成了dubbo自定义schema完成了上面的第(1)和(3)步工作

<2>第二部我们可以在dubbo.xsd文件种发现

<xsd:element name="service" type="serviceType">
    <xsd:annotation>
        <xsd:documentation><![CDATA[ Export service config ]]></xsd:documentation>
        <xsd:appinfo>
            <tool:annotation>
                <tool:exports type="org.apache.dubbo.config.ServiceConfig"/>
            </tool:annotation>
        </xsd:appinfo>
    </xsd:annotation>
</xsd:element>

<xsd:element name="reference" type="referenceType">
    <xsd:annotation>
        <xsd:documentation><![CDATA[ Reference service config ]]></xsd:documentation>
        <xsd:appinfo>
            <tool:annotation>
                <tool:exports type="org.apache.dubbo.config.ReferenceConfig"/>
            </tool:annotation>
        </xsd:appinfo>
    </xsd:annotation>
</xsd:element>

这里贴出来部分代码,做了多种的xsd元素标签配置。

<3>spring.handlers

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

<4>spring.schemas

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

这两个文件串联了Dubbo的整个csd的解析

最后,在applicationContext这类xml文件中我们使用dubbo的标签让spring管理我们定义的ServiceBean。

<dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />

总结:

1.通过上述5个步骤,我们实现了自定义的标签

2.通过观察Dubbo源码中的逻辑和配置,发现Dubbo从原理上也是这么实现它的自定义标签的,对于Spring的融合能够完美支持。其实也就是利用了Spring的特性。

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

推荐阅读更多精彩内容