经过前面几期的讲解,你应该已经对微服务的架构有了初步的了解。简单回顾一下,微服务的架构主要包括服务描述、服务发现、服务调用、服务监控、服务追踪以及服务治理这几个基本组件。

那么每个基本组件从架构和代码设计上该如何实现?组件之间又是如何串联来实现一个完整的微服务架构呢?今天我就以开源微服务框架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封装了服务提供者的地址以及接口信息。

一次服务调用的流程

上面我讲的是Dubbo下每个基本组件的实现方式,那么Dubbo框架下,一次服务调用的流程是什么样的呢?下面结合这张图,我来给你详细讲解一下。


(图片来源:https://dubbo.incubator.apache.org/docs/zh-cn/dev/sources/images/dubbo-extension.jpg

首先我来解释微服务架构中各个组件分别对应到上面这张图中是如何实现。

再来看下微服务架构各个组件是如何串联起来组成一个完整的微服务框架的,以Dubbo框架下一次服务调用的过程为例,先来看下客户端发起调用的过程。

这样的话,客户端的请求就从一个本地调用转化成一个远程RPC调用,经过服务调用框架的处理,通过网络传输到达服务端。其中服务调用框架包括通信协议框架Transporter、通信协议Codec、序列化Serialization三层处理。

服务端从网络中接收到请求后的处理过程是这样的:

总结

今天我给你讲述了Dubbo服务化框架每个基本组件的实现方式,以及一次Dubbo调用的流程。

对于学习微服务架构来说,最好的方式是去实际搭建一个微服务的框架,甚至去从代码入手做一些二次开发

你可以按照Dubbo的官方文档去安装并搭建一个服务化框架。如果想深入了解它的实现的话,可以下载源码来阅读。

思考题

在以Dubbo为例,学习完服务化框架的具体实现后,你对其中的实现细节还有什么疑问吗?

欢迎你在留言区写下自己的思考,与我一起讨论。

评论