基于Dubbo的分布式系统实现

体系架构

Dubbo是一个非常轻量级的分布式RPC框架,它使用Spring进行配置,而非注入式的编程方式,深受大家的喜爱。粗浅的研究了一下其应用,并使用Web容器(Jetty)实现了一个基于Dubbo的分布式系统,提供多种服务,并可以在多个服务源中进行切换。这个Demo系统的参与者包括

  • 服务的消费者(Consumer)可以是多种形式,这里采用war包的方式放到Jetty服务器中。后台由Spring容器进行管理,以获得服务的句柄;前台为了简便,使用最基本的Servlet来展现获取的服务内容;
  • 服务的提供者(Provider)同样可以采用多种形式,这里也同样采用war包方式放到Jetty服务器中,并由Spring容器进行管理。系统可以有多个Provider,这就需要多个Jetty环境,并在注册中心注册;
  • 服务注册中心(Registry)用于管理所有的服务,Consumer和Provider都需要在配置中指明注册中心地址。Registry可以使用Redis和Zookeeper实现,本Demo使用后者。
  • Dubbo实现的监控中心(Monitor)和服务治理程序(Admin)用于监控系统的使用情况和性能,同时在多个提供者的情况下,提供服务治理功能,例如权重,生效/失效设置等。

下图描述了整个体系架构。

绘图1.jpg

API的定义

API是Java接口定义的约定Consumer和Provider都可以使用的函数列表。Consumer通过API了解Service能够提供的服务;Provider提供服务的实现。其中

  • Service.java只是一个空接口,所有的服务都继承自这个接口。
    public interface Service { }
  • DateService.java提供一个关于日期的服务,调用后返回一个当前的日期。
    public interface DateService extends Service { public DateServiceResult getCurrentDate(); }
  • MathService.java提供一个关于数字的服务,调用后返回一个排序的数组(相对于参数)。
    public interface MathService extends Service { public NumberServiceResult sort(int[] numbers); }
  • StringService.java提供一个关于字符串的服务,调用后返回一个翻转的字符串(相对于参数)。
    public interface StringService extends Service { public StringServiceResult reverse(String str); }

API作为一个独立的,纯的Java的jar包发布给Consumer使用。

服务的消费者

为了简单起见,这里只将服务的Consumer作为基本的Servlet来处理。如果Servlet可以走通,应用到JSP,或是JSF环境中都水到渠成。Consumer中最重要的是获取服务的句柄,因为由于有API的存在,在静态编程中,是很简单的,且没有技术难度。获取句柄的代码在init方法中,如下所示

@Override public void init() throws ServletException { super.init(); ServletContext servletContext = this.getServletContext(); WebApplicationContext ctx = WebApplicationContextUtils .getWebApplicationContext(servletContext); dateService = (DateService) ctx.getBean("dateService"); }

显而易见,我们通过Spring容器获得真实的对象(由Provider实现),并从对象的调用结果中获取我们需要的内容。

服务的提供者

服务的Provider是比较简单的,只需要实现API所定义的方法即可,这里就不列举了。但为了将这个实现加载到Dubbo的系统中,也需要Spring容器,并打成War包发布到Jetty中。

Spring容器的配置

web.xml

web.xml的配置对于Consumer和Provider都是一样的,即定义Spring容器,如下所示
<listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <context-param> <param-name>contextConfigLocation</param-name> <param-value>/WEB-INF/classes/applicationContext*.xml</param-value> </context-param>

作为Consumer,还要定义Servlet的映射,不再赘述。

Consumer

<dubbo:application name="dubbo-evaluation-consumer" /> <dubbo:registry address="zookeeper://10.16.2.46:2181" /> <dubbo:monitor protocol="registry" /> <dubbo:reference id="stringService" interface="com.synnex.dubboevaluation.service.StringService" /> <dubbo:reference id="mathService" interface="com.synnex.dubboevaluation.service.MathService" /> <dubbo:reference id="dateService" interface="com.synnex.dubboevaluation.service.DateService" />
对于Consumer,比较重要的是

  • 使用 dubbo:registry 声明注册中心;
  • 使用 dubbo:reference 声明接口。
Provider

<dubbo:application name="dubbo-evaluation-provider" /> <dubbo:registry address="zookeeper://10.16.2.46:2181" /> <dubbo:protocol name="dubbo" port="20880" /> <dubbo:monitor protocol="registry"/> <dubbo:service interface="com.synnex.dubboevaluation.service.StringService" ref="stringService" /> <bean id="stringService" class="com.synnex.dubboevaluation.service.StringServiceImpl" /> <dubbo:service interface="com.synnex.dubboevaluation.service.MathService" ref="mathService" /> <bean id="mathService" class="com.synnex.dubboevaluation.service.MathServiceImpl" /> <dubbo:service interface="com.synnex.dubboevaluation.service.DateService" ref="dateService" /> <bean id="dateService" class="com.synnex.dubboevaluation.service.DateServiceImpl" />
对于Provider,比较重要的是

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

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,598评论 18 139
  • Dubbo是什么 Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式...
    Coselding阅读 17,167评论 3 196
  • 0 准备 安装注册中心:Zookeeper、Dubbox自带的dubbo-registry-simple;安装Du...
    七寸知架构阅读 13,970评论 0 88
  • 我把日子过成了单调的循环 连走路也成了千篇一律的模仿 听过几个领导的发言 各种各样的音色吐出同样干瘪的文字 连稀稀...
    何毕ne阅读 256评论 0 0
  • iOS中什么是国际化? 根据系统不同的语言环境显示相应的语言内容。 iOS中如何为工程添加国际化功能 comman...
    RogerHXJ阅读 274评论 0 0