专栏首页Java识堂图解Dubbo和ZooKeeper是如何协同工作的?

图解Dubbo和ZooKeeper是如何协同工作的?

介绍

微服务是最近比较火的概念,而微服务框架目前主流的有Dubbo和Spring Cloud,两者都是为了解决微服务遇到的各种问题而产生的,即遇到的问题是一样的,但是解决的策略却有所不同,所以这2个框架经常拿来比较。没用过Dubbo的小伙伴也不用担心,其实Dubbo还是比较简单的,看完本文你也能掌握一个大概,重要的不是代码,而是思想。

Dubbo实现服务调用是通过RPC的方式,即客户端和服务端共用一个接口(将接口打成一个jar包,在客户端和服务端引入这个jar包),客户端面向接口写调用,服务端面向接口写实现,中间的网络通信交给框架去实现,想深入了解的看推荐阅读。原文链接有代码GitHub地址

使用入门

服务提供者

定义服务接口

public interface DemoService {
    String sayHello(String name);
}

在服务提供方实现接口

public class DemoServiceImpl implements DemoService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

用 Spring 配置声明暴露服务

provider.xml(省略了beans标签的各种属性)

<?xml version="1.0" encoding="UTF-8"?>
<beans>

    <!-- 当前项目在整个分布式架构里面的唯一名称,用于计算依赖关系 -->
    <dubbo:application name="helloworld-app"  />

    <!--dubbo这个服务所要暴露的服务地址所对应的注册中心,N/A为不使用注册中心-->
    <dubbo:registry address="N/A"/>

    <!--当前服务发布所依赖的协议;webserovice、Thrift、Hessain、http-->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!--服务发布的配置,需要暴露的服务接口-->
    <dubbo:service interface="com.st.DemoService"
                   ref="demoService"/>

    <!--bean的定义-->
    <bean id="demoService" class="com.st.DemoServiceImpl"/>

</beans>

加载 Spring 配置

public class Provider {

    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");
        context.start();
        System.in.read(); // 按任意键退出
    }
}

服务消费者

consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans>

    <!-- 消费方应用名,用于计算依赖关系,不是匹配条件,不要与提供方一样 -->
    <dubbo:application name="consumer-of-helloworld-app"/>

    <dubbo:registry address="N/A"/>

    <!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
    <dubbo:reference id="demoService" interface="com.st.DemoService"
                     url="dubbo://localhost:20880/com.st.DemoService"/>

</beans>

加载Spring配置,并调用远程服务

public class Consumer {

    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");
        context.start();
        // 获取远程服务代理
        DemoService demoService = (DemoService)context.getBean("demoService");
        // 执行远程方法
        String hello = demoService.sayHello("world");
        // Hello world
        System.out.println( hello );
    }
}

这就是典型的点对点的服务调用。当然我们为了高可用,可以在consumer.xml中配置多个服务提供者,并配置响应的负载均衡策略

配置多个服务调用者在comsumer.xml的<dubbo:reference>标签的url属性中加入多个地址,中间用分号隔开即可

配置负载均衡策略在comsumer.xml的<dubbo:reference>标签中增加loadbalance属性即可,值可以为如下四种类型

  1. RoundRobin LoadBalance,随机,按权重设置随机概率。
  2. RoundRobin LoadBalance,轮询,按公约后的权重设置轮询比率。
  3. LeastActive LoadBalance,最少活跃调用数,相同活跃数的随机,活跃数指调用前后计数差。
  4. ConsistentHash LoadBalance,一致性 Hash,相同参数的请求总是发到同一提供者。
<dubbo:reference id="demoService" interface="com.st.DemoService"
                 url="dubbo://192.168.11.1:20880/com.st.DemoService;
                 dubbo://192.168.11.2:20880/com.st.DemoService;
                 dubbo://192.168.11.3:20880/com.st.DemoService"
                 loadbalance="roundrobin"/>

现在整体架构是如下图(假设服务消费者为订单服务,服务提供者为用户服务):

这样会有什么问题呢?

  1. 当服务提供者增加节点时,需要修改配置文件
  2. 当其中一个服务提供者宕机时,服务消费者不能及时感知到,还会往宕机的服务发送请求

这个时候就得引入注册中心了

注册中心

Dubbo目前支持4种注册中心,(multicast zookeeper redis simple) 推荐使用Zookeeper注册中心,本文就讲一下用zookeeper实现服务注册和发现(敲黑板,又一种zookeeper的用处),大致流程如下

现在我们来看Dubbo官网对Dubbo的介绍图,有没有和我们上面画的很相似

节点角色说明

节点

角色说明

Provider

暴露服务的服务提供方

Consumer

调用远程服务的服务消费方

Registry

服务注册与发现的注册中心

Monitor

统计服务的调用次数和调用时间的监控中心

Container

服务运行容器

调用关系说明

  1. 服务容器负责启动(上面例子为Spring容器),加载,运行服务提供者。
  2. 服务提供者在启动时,向注册中心注册自己提供的服务。
  3. 服务消费者在启动时,向注册中心订阅自己所需的服务。
  4. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
  5. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
  6. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

要使用注册中心,只需要将provider.xml和consumer.xml更改为如下

<!--<dubbo:registry address="N/A"/>-->
<dubbo:registry protocol="zookeeper" address="192.168.11.129:2181"/>

如果zookeeper是一个集群,则多个地址之间用逗号分隔即可

<dubbo:registry protocol="zookeeper" address="192.168.11.129:2181,192.168.11.137:2181,192.168.11.138:2181"/>

把consumer.xml中配置的直连的方式去掉

<!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
<!--<dubbo:reference id="demoService" interface="com.st.DemoService"-->
                 <!--url="dubbo://localhost:20880/com.st.DemoService"/>-->


<dubbo:reference id="demoService" interface="com.st.DemoService"/>

注册信息在zookeeper中如何保存?

启动上面服务后,我们观察zookeeper的根节点多了一个dubbo节点及其他,图示如下

最后一个节点中192.168.1.104是小编的内网地址,你可以任务和上面配置的localhost一个效果,大家可以想一下我为什么把最后一个节点标成绿色的。没错,最后一个节点是临时节点,而其他节点是持久节点,这样,当服务宕机时,这个节点就会自动消失,不再提供服务,服务消费者也不会再请求。如果部署多个DemoService,则providers下面会有好几个节点,一个节点保存一个DemoService的服务地址

其实一个zookeeper集群能被多个应用公用,如小编Storm集群和Dubbo配置的就是一个zookeeper集群,为什么呢?因为不同的框架会在zookeeper上建不同的节点,互不影响。如dubbo会创建一个/dubbo节点,storm会创建一个/storm节点,如图

本文分享自微信公众号 - Java识堂(erlieStar),作者:李立敏

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2018-12-08

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 如何在分布式场景下生成全局唯一 ID ?

    在分布式系统中,有一些场景需要使用全局唯一 ID ,可以和业务场景有关,比如支付流水号,也可以和业务场景无关,比如分库分表后需要有一个全局唯一 ID,或者用作事...

    Java识堂
  • 女朋友都能看懂,Spring如何解决循环依赖?

    先说一下什么是循环依赖,Spring在初始化A的时候需要注入B,而初始化B的时候需要注入A,在Spring启动后这2个Bean都要被初始化完成

    Java识堂
  • 宝贝,来,讲讲spring事务有哪些坑?

    今天,我们接上文《面试官:谈谈你对mysql事务的认识》的内容,来讲spring中和事务有关的考题! 因为事务这块,面试的出现几率很高。而大家工作中CRUD的比...

    Java识堂
  • 快手Java开发面经(2技术面)

    如果你要做一件事,请不要炫耀,也不要宣扬,只管安安静静的去做。因为那是你自己的事,别人不知道你的情况,也不可能帮你去实现。千万不要因为虚荣心而炫耀。也不要因为别...

    牛客网
  • 『互联网架构』软件架构-解密电商系统-秒杀前言(76)

    1.老铁啊,老铁,压测其实很有必要,jmeter分分钟就压测了接口。 2.压测可以让自己不被坑,压测还可以发现bug。 3.压测可以让你的代码更健壮。 4.压测...

    IT故事会
  • Dubbo入门-搭建一个最简单的Demo框架

    1. 单一应用框架(ORM) 当网站流量很小时,只需一个应用,将所有功能如下单支付等都部署在一起,以减少部署节点和成本。 缺点:单一的系统架构,使得在开发过...

    用户1093975
  • 作为UX设计师应当知道的22件事

    这篇大实话文章,我非常喜欢,因为几乎大部分观点和内容在我带新人,或是讲课过程中,都有提及过。与其说这是一篇写给新设计师的职场准则,我更愿意说是写个所有设计师的,...

    宇相
  • 【干货下载】谷歌、亚马逊等十大公司精选微服务案例

    Rainbond开源
  • XXE 打怪升级之路

    其实 xxe 也是一类注入漏洞,英文全名即 Xml External Entity Injection, 即我们所说的 xml 外部实体注入攻击。

    信安之路
  • 给公司部门设计的SOA架构

    蘑菇先生

扫码关注云+社区

领取腾讯云代金券