极客时间已完结课程限时免费阅读

10 | Dubbo框架里的微服务组件

10 | Dubbo框架里的微服务组件-极客时间

10 | Dubbo框架里的微服务组件

2018-09-13 胡忠想 来自北京
《从0开始学微服务》
课程介绍

讲述：胡忠想

时长10:29大小4.80M

经过前面几期的讲解，你应该已经对微服务的架构有了初步的了解。简单回顾一下，微服务的架构主要包括服务描述、服务发现、服务调用、服务监控、服务追踪以及服务治理这几个基本组件。
那么每个基本组件从架构和代码设计上该如何实现？组件之间又是如何串联来实现一个完整的微服务架构呢？今天我就以开源微服务框架 Dubbo 为例来给你具体讲解这些组件。

服务发布与引用

专栏前面我讲过服务发布与引用的三种常用方式：RESTful API、XML 配置以及 IDL 文件，其中 Dubbo 框架主要是使用 XML 配置方式，接下来我通过具体实例，来给你讲讲 Dubbo 框架服务发布与引用是如何实现的。
首先来看服务发布的过程，下面这段代码是服务提供者的 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: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://224.5.6.7: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”开头的配置项声明了服务提供者要发布的接口，“dubbo:protocol”开头的配置项声明了服务提供者要发布的接口的协议以及端口号。
Dubbo 会把以上配置项解析成下面的 URL 格式：
dubbo://host-ip:20880/com.alibaba.dubbo.demo.DemoService
然后基于扩展点自适应机制，通过 URL 的“dubbo://”协议头识别，就会调用 DubboProtocol 的 export() 方法，打开服务端口 20880，就可以把服务 demoService 暴露到 20880 端口了。
再来看下服务引用的过程，下面这段代码是服务消费者的 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: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="consumer-of-helloworld-app" />
<!-- 使用multicast广播注册中心暴露发现服务地址 -->
<dubbo:registry address="multicast://224.5.6.7:1234" />
<!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
<dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />
</beans>
其中“dubbo:reference”开头的配置项声明了服务消费者要引用的服务，Dubbo 会把以上配置项解析成下面的 URL 格式：
dubbo://com.alibaba.dubbo.demo.DemoService
然后基于扩展点自适应机制，通过 URL 的“dubbo://”协议头识别，就会调用 DubboProtocol 的 refer() 方法，得到服务 demoService 引用，完成服务引用过程。

服务注册与发现

先来看下服务提供者注册服务的过程，继续以前面服务提供者的 XML 配置为例，其中“dubbo://registry”开头的配置项声明了注册中心的地址，Dubbo 会把以上配置项解析成下面的 URL 格式：
registry://multicast://224.5.6.7:1234/com.alibaba.dubbo.registry.RegistryService?export=URL.encode("dubbo://host-ip:20880/com.alibaba.dubbo.demo.DemoService")
然后基于扩展点自适应机制，通过 URL 的“registry://”协议头识别，就会调用 RegistryProtocol 的 export() 方法，将 export 参数中的提供者 URL，注册到注册中心。
再来看下服务消费者发现服务的过程，同样以前面服务消费者的 XML 配置为例，其中“dubbo://registry”开头的配置项声明了注册中心的地址，跟服务注册的原理类似，Dubbo 也会把以上配置项解析成下面的 URL 格式：
registry://multicast://224.5.6.7:1234/com.alibaba.dubbo.registry.RegistryService?refer=URL.encode("consummer://host-ip/com.alibaba.dubbo.demo.DemoService")
然后基于扩展点自适应机制，通过 URL 的“registry://”协议头识别，就会调用 RegistryProtocol 的 refer() 方法，基于 refer 参数中的条件，查询服务 demoService 的地址。

服务调用

专栏前面我讲过在服务调用的过程中，通常把服务消费者叫作客户端，服务提供者叫作服务端，发起一次服务调用需要解决四个问题：
客户端和服务端如何建立网络连接？
服务端如何处理请求？
数据传输采用什么协议？
数据该如何序列化和反序列化？
其中前两个问题客户端和服务端如何建立连接和服务端如何处理请求是通信框架要解决的问题，Dubbo 支持多种通信框架，比如 Netty 4，需要在服务端和客户端的 XML 配置中添加下面的配置项。
服务端：
<dubbo:protocol server="netty4" />
客户端：
<dubbo:consumer client="netty4" />
这样基于扩展点自适应机制，客户端和服务端之间的调用会通过 Netty 4 框架来建立连接，并且服务端采用 NIO 方式来处理客户端的请求。
再来看下 Dubbo 的数据传输采用什么协议。Dubbo 不仅支持私有的 Dubbo 协议，还支持其他协议比如 Hessian、RMI、HTTP、Web Service、Thrift 等。下面这张图描述了私有 Dubbo 协议的协议头约定。
(图片来源：https://dubbo.incubator.apache.org/docs/zh-cn/dev/sources/images/dubbo_protocol_header.jpg ）
至于数据序列化和反序列方面，Dubbo 同样也支持多种序列化格式，比如 Dubbo、Hession 2.0、JSON、Java、Kryo 以及 FST 等，可以通过在 XML 配置中添加下面的配置项。
例如：
<dubbo:protocol name="dubbo" serialization="kryo"/>

服务监控

服务监控主要包括四个流程：数据采集、数据传输、数据处理和数据展示，其中服务框架的作用是进行埋点数据采集，然后上报给监控系统。
在 Dubbo 框架中，无论是服务提供者还是服务消费者，在执行服务调用的时候，都会经过 Filter 调用链拦截，来完成一些特定功能，比如监控数据埋点就是通过在 Filter 调用链上装备了 MonitorFilter 来实现的，详细的代码实现你可以参考这里。

服务治理

服务治理手段包括节点管理、负载均衡、服务路由、服务容错等，下面这张图给出了 Dubbo 框架服务治理的具体实现。
（图片来源：http://dubbo.incubator.apache.org/docs/zh-cn/user/sources/images/cluster.jpg ）
图中的 Invoker 是对服务提供者节点的抽象，Invoker 封装了服务提供者的地址以及接口信息。
节点管理：Directory 负责从注册中心获取服务节点列表，并封装成多个 Invoker，可以把它看成“List<Invoker>” ，它的值可能是动态变化的，比如注册中心推送变更时需要更新。
负载均衡：LoadBalance 负责从多个 Invoker 中选出某一个用于发起调用，选择时可以采用多种负载均衡算法，比如 Random、RoundRobin、LeastActive 等。
服务路由：Router 负责从多个 Invoker 中按路由规则选出子集，比如读写分离、机房隔离等。
服务容错：Cluster 将 Directory 中的多个 Invoker 伪装成一个 Invoker，对上层透明，伪装过程包含了容错逻辑，比如采用 Failover 策略的话，调用失败后，会选择另一个 Invoker，重试请求。

一次服务调用的流程

上面我讲的是 Dubbo 下每个基本组件的实现方式，那么 Dubbo 框架下，一次服务调用的流程是什么样的呢？下面结合这张图，我来给你详细讲解一下。
(图片来源：https://dubbo.incubator.apache.org/docs/zh-cn/dev/sources/images/dubbo-extension.jpg ）
首先我来解释微服务架构中各个组件分别对应到上面这张图中是如何实现。
服务发布与引用：对应实现是图里的 Proxy 服务代理层，Proxy 根据客户端和服务端的接口描述，生成接口对应的客户端和服务端的 Stub，使得客户端调用服务端就像本地调用一样。
服务注册与发现：对应实现是图里的 Registry 注册中心层，Registry 根据客户端和服务端的接口描述，解析成服务的 URL 格式，然后调用注册中心的 API，完成服务的注册和发现。
服务调用：对应实现是 Protocol 远程调用层，Protocol 把客户端的本地请求转换成 RPC 请求。然后通过 Transporter 层来实现通信，Codec 层来实现协议封装，Serialization 层来实现数据序列化和反序列化。
服务监控：对应实现层是 Filter 调用链层，通过在 Filter 调用链层中加入 MonitorFilter，实现对每一次调用的拦截，在调用前后进行埋点数据采集，上传给监控系统。
服务治理：对应实现层是 Cluster 层，负责服务节点管理、负载均衡、服务路由以及服务容错。
再来看下微服务架构各个组件是如何串联起来组成一个完整的微服务框架的，以 Dubbo 框架下一次服务调用的过程为例，先来看下客户端发起调用的过程。
首先根据接口定义，通过 Proxy 层封装好的透明化接口代理，发起调用。
然后在通过 Registry 层封装好的服务发现功能，获取所有可用的服务提供者节点列表。
再根据 Cluster 层的负载均衡算法从可用的服务节点列表中选取一个节点发起服务调用，如果调用失败，根据 Cluster 层提供的服务容错手段进行处理。
同时通过 Filter 层拦截调用，实现客户端的监控统计。
最后在 Protocol 层，封装成 Dubbo RPC 请求，发给服务端节点。
这样的话，客户端的请求就从一个本地调用转化成一个远程 RPC 调用，经过服务调用框架的处理，通过网络传输到达服务端。其中服务调用框架包括通信协议框架 Transporter、通信协议 Codec、序列化 Serialization 三层处理。
服务端从网络中接收到请求后的处理过程是这样的：
首先在 Protocol 层，把网络上的请求解析成 Dubbo RPC 请求。
然后通过 Filter 拦截调用，实现服务端的监控统计。
最后通过 Proxy 层的处理，把 Dubbo RPC 请求转化为接口的具体实现，执行调用。

总结

今天我给你讲述了 Dubbo 服务化框架每个基本组件的实现方式，以及一次 Dubbo 调用的流程。
对于学习微服务架构来说，最好的方式是去实际搭建一个微服务的框架，甚至去从代码入手做一些二次开发。
你可以按照 Dubbo 的官方文档去安装并搭建一个服务化框架。如果想深入了解它的实现的话，可以下载源码来阅读。

思考题

在以 Dubbo 为例，学习完服务化框架的具体实现后，你对其中的实现细节还有什么疑问吗？
欢迎你在留言区写下自己的思考，与我一起讨论。
分享给需要的人，Ta购买本课程，你将得18元
生成海报并分享

赞 15

提建议

© 版权归极客邦科技所有，未经许可不得传播售卖。 页面已增加防盗追踪，如有侵权极客邦将依法追究其法律责任。
上一篇
09 | 微服务治理的手段有哪些？
下一篇
11 | 服务发布和引用的实践
unpreview
 写留言

精选留言(25)

  • 庞小勇
    2018-09-18
    php开发者，听着一脸蒙逼
    共 4 条评论
    38
  • echo＿陈
    2018-09-13
    撸了半年的dubbo源码…… 胡老师这篇很不错，已分享给同事

    作者回复: 希望能帮你们入门了解

    17
  • eason2017
    2018-09-13
    这篇文章好哇，学习dunno 必备

    作者回复: dubbo，哈哈

    7
  • 波波安
    2018-10-13
    老师对怎么去读源码，有什么好的建议和方式吗，每次都不知道从哪看起😬
    4
  • Home
    2018-09-13
    后期会有springcloud的介绍嘛？

    作者回复: 选型对比就会提到，但不会详细讲spring cloud

    4
  • Mr.Right
    2019-10-25
    python开发者，听着一脸蒙逼
    2
  • Sam_Deep_Thinking
    2018-09-13
    没玩过，不过看起来doubo很强大哈。学习了。下篇是讲spring cloud吗？

    作者回复: 这一篇是原理篇的最后一节，spring cloud在后面选型中会提到

    3
  • fldhmily63319
    2018-09-13
    老师能评价一下Dubbo, Spring Cloud甚至是ZooKeeper的区别，优劣势吗？

    作者回复: zookeeper是配置中心，dubbo和spring cloud是服务框架，后面对比选型会细讲

    3
  • 坤
    2021-03-10
    Dubbo 服务治理相关的组件都是需要客户端自己在代码中选择使用吗？不像ServiceMesh可以独立于业务代码进行流量或服务的治理。
    2
  • 钱
    2019-05-23
    牛逼的Dubbo 牛逼的阿里 牛逼的开源 感谢😊
    共 1 条评论
    1
  • 小白
    2018-11-03
    在微服务架构中，同一个服务是不是有可能既充当服务提供者的角色又充当服务消费者的角色呢？

    作者回复: 是的，这种情况很正常

    1
  • 张龙大骗子
    2018-09-13
    neety是个好框架啊，thrift和protobuf也是

    作者回复: 是的，netty适合Java，thrift和protobuf适合跨语言

    1
  • Billylin
    2018-09-13
    胡老师，您好，如果后端服务使用dubbo框架的话，有什么组件可以充当网关这个角色呢？
    1
  • Sch0ng
    2021-09-01
    Dubbo是阿里发布的基于Java语言的开源微服务框架。理解的最佳途径是自己做实验。
  • 爱学习的大叔
    2020-04-05
    不错，对dubbo有两个一个整体上的认识。
  • lw
    2019-09-12
    学了这课，有信心去看dubbo源码了。
  • holdno
    2019-09-05
    rpc应该算是长连接吧？如果有多个服务端节点，每次都去通过负载均衡选择，那是在初始化的时候客户端需要跟所有服务端建立连接？求老师赐教
    共 1 条评论
  • Tony
    2019-02-22
    代码侵入高，相对于spring cloud 好处是可扩展性强，可定制化，性能优于http协议请求，虽然没玩过dubbo- ̗̀(๑ᵔ⌔ᵔ๑)
  • Rainbow
    2018-12-16
    我们公司用的就是这一套，开发同学可以小团队做不同的模块，作为测试同学每天 xshell 都要开 n 多个窗口跟踪日志😅，还有就是某个功能出问题以后就要去检查环境，而且有好多个模块，好多个节点，好多个实例，也挺耗费时间的。课程很棒！感谢胡老师分享，看到跟微服务相关特地来学习的，谢谢分享！
  • 小猪
    2018-11-30
    rancher可以用来做微服务框架吗？可以运行微服务系统吗？

    作者回复: 不是很了解，看了下github，是个容器管理平台，可以运行微服务系统。