目录

1、RPC和分布式

1.1 什么是 RPC

1.2 RPC原理是什么 

1.3 什么是分布式

1.4 为什么要分布式

2、什么是 Dubbo

2.1 Dubbo核心特性

3、为什么要用 Dubbo

4、Dubbo的架构

4.1 Dubbo的架构图解

4.2 Dubbo 工作原理(整体架构图)

5、Dubbo 的负载均衡策略

5.1 什么是负载均衡

5.2 Dubbo 提供的负载均衡策略

5.3 配置方式

6、Zookeeper宕机与Dubbo直连的情况

6.1 Dubbo的健壮性表现

6.2 xml配置方式

6.3 注解方式

1、RPC和分布式

1.1 什么是 RPC

RPC(Remote Procedure Call)远程过程调用,它是一种通过网络从远程计算机程序上请求服务, 而不需要了解底层网络技术的协议。比如两个不同的服务A、B 部署在两台不同的机器上,那么服务 A 如果想要调用服务 B 中的某个方法该怎么办呢?使用 HTTP请求当然可以,但是可能会比较麻烦。 RPC 的出现就是为了让你调用远程方法像调用本地方法一样简单。

1.2 RPC原理是什么 

RPC原理过程:

  1. 服务消费方(client)调用以本地调用方式调用服务

  2. client stub接收到调用后负责将方法、参数等组装成能够进行网络传输的消息体

  3. client stub找到服务地址,并将消息发送到服务端;

  4. server stub收到消息后进行解码

  5. server stub根据解码结果调用本地的服务

  6. 本地服务执行并将结果返回给server stub

  7. server stub将返回结果打包成消息并发送至消费方

  8. client stub接收到消息,并进行解码

  9. 服务消费方得到最终结果。

RPC时序图过程:

1.3 什么是分布式

分布式或者说 SOA 分布式重要的就是面向服务,说简单的分布式就是我们把整个系统拆分成不同的服务,然后将这些服务放在不同的服务器上,减轻单体服务的压力提高并发量和性能。比如电商系统可以简单地拆分成订单系统、商品系统、登录系统等等,拆分之后的每个服务可以部署在不同的机器上,如果某一个服务的访问量比较大的话也可以将这个服务同时部署在多台机器上。

1.4 为什么要分布式

从开发角度来讲单体应用的代码都集中在一起,而分布式系统的代码根据业务被拆分

所以,每个团队可以负责一个服务的开发,这样提升了开发效率。另外,代码根据业务拆分之后更加便于维护和扩展。另外,将系统拆分成分布式之后不仅便于系统扩展和维护,更能提高整个系统的性能

2、什么是 Dubbo

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源Java RPC框架,它提供了三大核 心能力面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现

简单来说Dubbo是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。

另外,在开源中国举行的2018年度最受欢迎中国开源软件这个活动的评选中,Dubbo 更是凭借其超高 人气仅次于 vue.js 和 ECharts 获得第三名的好成绩。

Dubbo 是由阿里开源,后来加入了Apache 。正式由于 Dubbo 的出现,才使得越来越多的公司开始使 用以及接受分布式架构。

我们上面说了Dubbo实际上是RPC框架

2.1 Dubbo核心特性

灵活部署模式

一键拉起服务治理体系,屏蔽底层跨平台的微服务基础设施复杂度,支持虚拟机、Docker、Kubernetes、服务网格等多种部署模式。

服务发现

Dubbo 提供了高性能、可伸缩的服务发现机制,面向百万集群实例规模设计,默认提供 Nacos、Zookeeper 等注册中心适配并支持自定义扩展。

流量管控

Dubbo 提供的基于路由规则的流量管控策略,可以帮助实现全链路灰度、金丝雀发布、按比例流量转发、动态调整调试时间、设置重试次数等服务治理能力。

通信协议

支持 HTTP/2、gRPC、TCP、REST 等任意通信协议,切换协议只需要修改一行配置,支持单个端口上的多协议发布。

多语言 SDK

提供 Java、Golang、Rust、Node.js、Python 等多语言 SDK 实现,支持基于 IDL 的跨语言服务定义和基于 Protobuf、Json 的数据编码

可扩展性

一切皆可扩展,通过扩展 (Filter、Router、Service Discovery、Configuration 等) 自定义调用、管控行为,适配开源微服务生态。

可观测性

多维度的可观测指标(Metrics、Tracing、Accesslog)帮助了解服务运行状态,Admin 控制台、Grafana 等帮助实现数据指标可视化展示。

认证鉴权

支持基于 TLS 的传输链路认证与加密通信以及基于请求身份的权限校验,帮助构建零信任分布式微服务体系。

服务网格(Service Mesh)

灵活的数据面 (Proxy & Proxyless) 部署形态支持,无缝接入 Istio 控制面治理体系。

丰富生态

一站式微服务生态适配:注册中心、网关、限流降级、负载均衡、一致性事务、异步消息、Tracing 等。

3、为什么要用 Dubbo

Dubbo 的诞生和 SOA 分布式架构的流行有着莫大的关系

SOA 是面向服务的架构(Service Oriented Architecture),也就是把工程按照业务逻辑拆分成服务层、表现层两个工程。服务层中包含业务逻辑,只需要对外提供服务即可。表现层只需要处理和页面的交互,业务逻辑都是调用服务层的服务来实现。

SOA架构中有两个主要角色:服务提供者(Provider)和服务使用者(Consumer)

如果你要开发分布式程序,你也可以直接基于 HTTP 接口进行通信,但是为什么要用 Dubbo呢? 我觉得主要可以从 Dubbo 提供的下面四点特性来说为什么要用 Dubbo:

  1. 负载均衡——同一个服务部署在不同的机器时该调用那一台机器上的服务。

  2. 服务调用链路生成——随着系统的发展,服务越来越多,服务间依赖关系变得错踪复杂,甚至分不 清哪个应用要在哪个应用之前启动,架构师都不能完整的描述应用的架构关系。Dubbo 可以为我 们解决服务之间互相是如何调用的。

  3. 服务访问压力以及时长统计、资源调度和治理——基于访问压力实时管理集群容量,提高集群利用 率。

  4. 服务降级——某个服务挂掉之后调用备用服务。

    另外,Dubbo 除了能够应用在分布式系统中,也可以应用在现在比较火的微服务系统中。不过,由于 Spring Cloud 在微服务中应用更加广泛,所以,我觉得一般我们提 Dubbo 的话,大部分是分布式系统 的情况。

4、Dubbo的架构

4.1 Dubbo的架构图解

Dubbo 的架构简单说明:

Provider: 暴露服务的服务提供方。

Consumer: 调用远程服务的服务消费方。

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

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

Container: 服务运行容器。

img

调用关系说明:

  1. 服务容器负责启动,加载,运行服务提供者。

  2. 服务提供者在启动时,向注册中心注册自己提供的服务。

  3. 服务消费者在启动时,向注册中心订阅自己所需的服务。

  4. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给 消费者。

  5. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失 败,再选另一台调用。

  6. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中 心。

重要知识点总结:

  1. 注册中心负责服务地址的注册与查找,相当于目录服务,服务提供者和消费者只在启动时与注册中 心交互,注册中心不转发请求,压力较小。

  2. 监控中心负责统计各服务调用次数,调用时间等,统计先在内存汇总后每分钟一次发送到监控中心 服务器,并以报表展示。

  3. 注册中心,服务提供者,服务消费者三者之间均为长连接,监控中心除外。

  4. 注册中心通过长连接感知服务提供者的存在,服务提供者宕机,注册中心将立即推送事件通知消费 者。

  5. 注册中心和监控中心全部宕机,不影响已运行的提供者和消费者,消费者在本地缓存了提供者列表

  6. 注册中心和监控中心都是可选的,服务消费者可以直连服务提供者。

  7. 服务提供者无状态,任意一台宕掉后,不影响使用。

  8. 服务提供者全部宕掉后,服务消费者应用将无法使用,并无限次重连等待服务提供者恢复

4.2 Dubbo 工作原理(整体架构图)

图中从下至上分为十层,各层均为单向依赖,右边的黑色箭头代表层之间的依赖关系,每一层都可以剥离上层被复用,其中,Service 和 Config 层为 API,其它各层均为 SPI。

  • 左边(淡蓝背景):为服务消费方使用的接口

  • 右边(淡绿色背景):为服务提供方使用的接口

  • 位于中轴线上:为双方都用到的接口。

Dubbo 框架设计一共划分了10个层:

1.服务接口层(Service)

第一层:Service层,接口层,给服务提供者和消费者来实现的。

该层是与实际业务逻辑相关的,根据服务提供方和服务消费方的业务设计对应的接口和实现。

2.配置层(Config)

第二层:Config层,配置层,主要是对dubbo进行各种配置的。

对外配置接口,以ServiceConfig和ReferenceConfig为中心可以直接new配置类,也可以通过Spring解析配置生成配置类。

3.服务代理层(Proxy)

第三层:Proxy层,服务接口透明代理,生成服务的客户端 Stub 和服务器端 Skeleton。

服务接口透明代理,生成服务的客户端Stub和服务器端Skeleton,以ServiceProxy为中心,扩展接口为ProxyFactory。

4.服务注册层(Registry)

第四层:Registry层,服务注册层,负责服务的注册与发现。

封装服务地址的注册与发现,以服务URL为中心,扩展接口为RegistryFactory、Registry和RegistryService。可能没有服务注册中心,此时服务提供方直接暴露服务。

5.集群层(Cluster)

第五层:Cluster层,集群层,封装多个服务提供者的路由以及负载均衡,将多个实例组合成一个 服务。

封装多个提供者的路由及负载均衡,并桥接注册中心,以Invoker为中心,扩展接口为Cluster、Directory、Router和LoadBalance。将多个服务提供方组合为一个服务提供方,实现对服务消费方来透明,只需要与一个服务提供方进行交互。

6.监控层(Monitor)

第六层:Monitor层,监控层,对rpc接口的调用次数和调用时间进行监控

RPC调用次数和调用时间监控,以Statistics为中心,扩展接口为MonitorFactory、Monitor和MonitorService。

7.远程调用层(Protocol)

第七层:Protocol层,远程调用层,封装rpc调用。

封将RPC调用,以Invocation和Result为中心,扩展接口为Protocol、Invoker和Exporter。

Protocol是服务域,它是Invoker暴露和引用的主功能入口,它负责Invoker的生命周期管理。Invoker是实体域,它是Dubbo的核心模型,其它模型都向它靠扰,或转换成它,它代表一个可执行体,可向它发起invoke调用,它有可能是一个本地的实现,也可能是一个远程的实现,也可能一个集群实现。

8.信息交换层(Exchange)

第八层:Exchange层,信息交换层,封装请求响应模式,同步转异步。

封装请求响应模式,同步转异步,以Request和Response为中心,扩展接口为Exchanger、ExchangeChannel、ExchangeClient和ExchangeServer。

9.网络传输层(Transport)

第九层:Transport层,网络传输层,抽象mina和netty为统一接口

抽象mina和netty为统一接口,以 Message 为中心,扩展接口为 Channel、Transporter、Client、Server和Codec。

10.数据序列化层(Serialize)

第十层:serialize层,数据序列化层,网络传输需要。

可复用的一些工具,扩展接口为 Serialization、 ObjectInput、ObjectOutput和ThreadPool。

5、Dubbo 的负载均衡策略

5.1 什么是负载均衡

维基百科对负载均衡的定义:

负载均衡改善了跨多个计算资源(例如计算机,计算机集群,网络链接,中央处理单元或磁盘驱动的的工作负载分布。)负载平衡旨在优化资源使用,最大化吞吐量,最小化响应时间,并避免任何单个资源的过载。使用具有负载平衡而不是单个组件的多个组件可以通过冗余提高可靠性和可用性。负载平衡通常涉及专用软件或硬件。

比如我们的系统中的某个服务的访问量特别大,我们将这个服务部署在了多台服务器上,当客户端发起请求的时候,多台服务器都可以处理这个请求。那么,如何正确选择处理该请求的服务器就很关键。假如,你就要一台服务器来处理该服务的请求,那该服务部署在多台服务器的意义就不复存在了。负载均衡就是为了避免单个服务器响应同一请求,容易造成服务器宕机、崩溃等问题,我们从负载均衡的这四个字就能明显感受到它的意义。

5.2 Dubbo 提供的负载均衡策略

在集群负载均衡时,Dubbo 提供了多种均衡策略,默认为random随机调用可以自行扩展负载均衡 策略。

5.2.1 Random LoadBalance

随机,按权重设置随机概率。默认,基于权重的随机负载均衡机制

在一个截面上碰撞的概率高,但调用量越大分布越均匀,而且按概率使用权重后也比较均匀,有利于动态调整提供者权重。

5.2.2 RoundRobin LoadBalance

轮循,按公约后的权重设置轮循比率。不推荐,基于权重的轮询负载均衡机制

存在慢的提供者累积请求的问题,比如:第二台机器很慢,但没挂,当请求调到第二台时就卡在那,久而久之,所有请求都卡在调到第二台上。

5.2.3 LeastActive LoadBalance

最少活跃调用数,相同活跃数的随机,活跃数指调用前后计数差。

使慢的提供者收到更少请求,因为越慢的提供者的调用前后计数差会越大。

5.2.4 ConsistentHash LoadBalance

一致性 Hash相同参数的请求总是发到同一提供者。(如果你需要的不是随机负载均衡,是要一类请求都到一个节点,那就走这个一致性hash策略。)

当某一台提供者挂时,原本发往该提供者的请求,基于虚拟节点,平摊到其它提供者,不会引起剧烈变动。

缺省只对第一个参数 Hash,如果要修改,请配置 :

<dubbo:parameter key="hash.arguments"value="0,1" />

缺省用 160 份虚拟节点,如果要修改,请配置 :

 <dubbo:parameter key="hash.nodes"value="320" />

5.3 配置方式

5.3.1 xml 配置方式

服务端服务级别

 <dubbo:service interface="..." loadbalance="roundrobin" />

客户端服务级别

 <dubbo:reference interface="..." loadbalance="roundrobin" />

服务端方法级别

 <dubbo:service interface="...">
   <dubbo:method name="..." loadbalance="roundrobin"/>
 </dubbo:service>

客户端方法级别

<dubbo:reference interface="...">
   <dubbo:method name="..." loadbalance="roundrobin"/>
 </dubbo:reference>

5.3.2 注解配置方式

消费方基于基于注解的服务级别配置方式:

 @Reference(loadbalance = "roundrobin")
 HelloService helloService;

6、Zookeeper宕机与Dubbo直连的情况

Zookeeper宕机与Dubbo直连的情况在面试中可能会被经常问到,所以要引起重视。

在实际生产中,假如zookeeper注册中心宕掉,一段时间内服务消费方还是能够调用提供方的服务的, 实际上它使用的本地缓存进行通讯,这只是dubbo健壮性的一种体现

6.1 Dubbo的健壮性表现

  1. 监控中心宕掉不影响使用,只是丢失部分采样数据。

  2. 数据库宕掉后,注册中心仍能通过缓存提供服务列表查询,但不能注册新服务

  3. 注册中心对等集群,任意一台宕掉后,将自动切换到另一台

  4. 注册中心全部宕掉后,服务提供者和服务消费者仍能通过本地缓存通讯

  5. 服务提供者无状态,任意一台宕掉后,不影响使用

  6. 服务提供者全部宕掉后,服务消费者应用将无法使用,并无限次重连等待服务提供者恢复

    我们前面提到过:注册中心负责服务地址的注册与查找,相当于目录服务,服务提供者和消费者只在启 动时与注册中心交互,注册中心不转发请求,压力较小。所以,我们可以完全可以绕过注册中心——采 用 dubbo 直连 ,就是在服务消费方配置服务提供方的位置信息

6.2 xml配置方式

 <dubbo:reference id="userService"    interface="com.zang.gmall.service.UserService"
 url="dubbo://localhost:20880" />

6.3 注解方式

 @Reference(url = "127.0.0.1:20880") 
 HelloService helloService;

Logo

开放原子开发者工作坊旨在鼓励更多人参与开源活动,与志同道合的开发者们相互交流开发经验、分享开发心得、获取前沿技术趋势。工作坊有多种形式的开发者活动,如meetup、训练营等,主打技术交流,干货满满,真诚地邀请各位开发者共同参与!

更多推荐