Apache Dubbo是一款高性能、轻量级的开源Java RPC框架。
它有三大核心能力&＃xff1a;面向接口的远程方法调用&＃xff0c;智能容错和负载均衡&＃xff0c;以及服务自动注册和发现。
1、面向接口代理的高性能RPC调用&＃xff1a;提供高性能的基于代理的远程调用能力&＃xff0c;服务以接口为粒度&＃xff0c;为开发者屏蔽远程调用底层细节。
2、智能负载均衡&＃xff1a;内置多种负载均衡策略&＃xff0c;智能感知下游节点健康状况&＃xff0c;显著减少调用延迟&＃xff0c;提高系统吞吐量。
3、服务自动注册与发现&＃xff1a;支持多种注册中心服务&＃xff0c;服务实例上下线实时感知。
4、高度可扩展能力&＃xff1a; 遵循微内核&＃43;插件的设计原则&＃xff0c;所有核心能力如Protocol、Transport、Serialization被设计为扩展点&＃xff0c;平等对待内置实现和第三方实现。
5、运行期流量调度&＃xff1a;内置条件、脚本等路由策略&＃xff0c;通过配置不同的路由规则&＃xff0c;轻松实现灰度发布&＃xff0c;同机房优先等功能。
6、可视化的服务治理与运维&＃xff1a;提供丰富服务治理、运维工具&＃xff1a;随时查询服务元数据、服务健康状态及调用统计&＃xff0c;实时下发路由策略、调整配置参数。
1、跨语言支持较弱&＃xff1a;目前Dubbo只在JAVA语言流行&＃xff0c;其他语言支持较少。不适用跨语言调用。
2、Registry 严重依赖第三方组件&＃xff08;ZooKeeper 或者 Redis&＃xff09;&＃xff0c;当这些组件出现问题时&＃xff0c;服务调用很快就会中断。
是Google开发的高性能、通用的开源RPC框架&＃xff0c;基于ProtoBuf(Protocol Buffers)序列化协议开发&＃xff0c;且支持众多开发语言。在业界非JAVA语言的框架中&＃xff0c;GRPC是最为常用通用的rpc框架。不过GRPC没有服务发现功能&＃xff0c;一般需要结合ETCD做服务发现功能。
Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发&＃xff0c;如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等&＃xff0c;都可以用Spring Boot的开发风格做到一键启动和部署。
motan是新浪微博开源的一套轻量级、方便使用的RPC框架。支持动态自定义负载均衡、跨机房流量调整等高级服务调度能力。基于高并发、高负载场景进行优化&＃xff0c;保障生产环境下RPC服务高可用。
| 框架 | 开发语言 | 服务治理 | 跨语言支持 | 调用方式 | 管理中心 | 关注度 |
|---|---|---|---|---|---|---|
| dubbo | java | zookeeper | 基本不支持 | tcp | 支持 | 高 |
| gRPC | 多语言 | 不执行&＃xff0c;需要自行实现 | 支持 | http | 不支持 | 高 |
| springCloud | java | spring cloud | Eureka | 不支持 | http-rest | 支持 |
| Motan | java | consul、zookeeper | java、go、php | tcp | 支持 | 中 |
另外由于dubbo在2012年开源之后&＃xff0c;在2017年中旬一直没有做更新&＃xff0c;故当当网基于dubbo改造了dubbox的版本。以下是dubbox和dubbo的对比只要特点如下&＃xff1a;
上述所述为Dubbo内部交互图&＃xff0c;主要包括&＃xff1a;
调用流程如下所述&＃xff1a;
1、服务启动&＃xff0c;包括服务提供者和消费者的启动&＃xff0c;封装服务调用链路。
2、服务提供者在启动时&＃xff0c;向注册中心注册自己提供的服务。
3、服务消费者在启动时&＃xff0c;向注册中心订阅自己所需的服务。
4、注册中心返回服务提供者地址列表给消费者&＃xff0c;如果有变更&＃xff0c;注册中心将基于长连接推送变更数据给消费者。
5、服务消费者&＃xff0c;从提供者地址列表中&＃xff0c;基于服务路由信息、负载均衡规则&＃xff0c;选一台提供者进行调用。
6、服务消费者和提供者&＃xff0c;在内存中累计调用次数和调用时间&＃xff0c;定时发送一次统计数据到监控中心。
7、服务提供方停止服务或者服务调用方关闭JVM的时候&＃xff0c;会将provider及consumer进行销毁处理。
Dubbo框架设计一共划分了10个层&＃xff0c;而最上面的Service层是留给实际想要使用Dubbo开发分布式服务的开发者实现业务逻辑的接口层。图中左边淡蓝背景的为服务消费方使用的接口&＃xff0c;右边淡绿色背景的为服务提供方使用的接口&＃xff0c; 位于中轴线上的为双方都用到的接口。
可以通过Dubbo的代码&＃xff08;使用Maven管理&＃xff09;组织&＃xff0c;与上面的模块进行比较。简单说明各个包的情况&＃xff1a;
1、dubbo网络通信remoting及线程模型
dubbo中网络通信主要借助通过Netty来实现server及client。在netty接收完消息后&＃xff0c;将通过不同的线程模型分配进行业务处理。
1、Dubbo中线程派发Dispatcher分配类型包括&＃xff1a;
all 所有消息都派发到线程池&＃xff0c;包括请求&＃xff0c;响应&＃xff0c;连接事件&＃xff0c;断开事件&＃xff0c;心跳等。
direct 所有消息都不派发到线程池&＃xff0c;全部在 IO 线程上直接执行。
message 只有请求响应消息派发到线程池&＃xff0c;其它连接断开事件&＃xff0c;心跳等消息&＃xff0c;直接在 IO 线程上执行。
execution 只请求消息派发到线程池&＃xff0c;不含响应&＃xff0c;响应和其它连接断开事件&＃xff0c;心跳等消息&＃xff0c;直接在 IO 线程上执行。
connection 在 IO 线程上&＃xff0c;将连接断开事件放入队列&＃xff0c;有序逐个执行&＃xff0c;其它消息派发到线程池。
2、ThreadPool线程池类型&＃xff1a;
fixed 固定大小线程池&＃xff0c;启动时建立线程&＃xff0c;不关闭&＃xff0c;一直持有。(缺省)
cached 缓存线程池&＃xff0c;空闲一分钟自动删除&＃xff0c;需要时重建。
limited 可伸缩线程池&＃xff0c;但池中的线程数只会增长不会收缩。只增长不收缩的目的是为了避免收缩时突然来了大流量引起的性能问题。
eager 优先创建Worker线程池。在任务数量大于corePoolSize但是小于maximumPoolSize时&＃xff0c;优先创建Worker来处理任务。当任务数量大于maximumPoolSize时&＃xff0c;将任务放入阻塞队列中。阻塞队列充满时抛出RejectedExecutionException。(相比于cached:cached在任务数量超过maximumPoolSize时直接抛出异常而不是将任务放入阻塞队列)
3、消息发送涉及到&＃xff1a;同步、异步、单向方式
4、dubbo数据包结构&＃xff1a;Dubbo 数据包分为消息头和消息体&＃xff0c;消息头用于存储一些元信息&＃xff0c;比如魔数&＃xff08;Magic&＃xff09;&＃xff0c;数据包类型&＃xff08;Request/Response&＃xff09;&＃xff0c;消息体长度&＃xff08;Data Length&＃xff09;等。消息体中用于存储具体的调用消息
5、序列化&＃xff1a;在远程通信过程中涉及到序列化内容&＃xff0c;主要采用Hessian2。
SPI 全称为 Service Provider Interface&＃xff0c;是一种服务发现机制。SPI 的本质是将接口实现类的全限定名配置在文件中&＃xff0c;并由服务加载器读取配置文件&＃xff0c;加载实现类。这样可以在运行时&＃xff0c;动态为接口替换实现类。正因此特性&＃xff0c;我们可以很容易的通过 SPI 机制为我们的程序提供拓展功能。SPI 机制在第三方框架中也有所应用&＃xff0c;比如 Dubbo 就是通过 SPI 机制加载所有的组件。不过&＃xff0c;Dubbo 并未使用 Java 原生的 SPI 机制&＃xff0c;而是对其进行了增强&＃xff0c;使其能够更好的满足需求。在 Dubbo 中&＃xff0c;SPI 是一个非常重要的模块。基于 SPI&＃xff0c;我们可以很容易的对 Dubbo 进行拓展。
Dubbo中SPI机制类为ExtensionLoader&＃xff0c;ExtensionLoader是扩展点载入器&＃xff0c;用于载入Dubbo中的各种可配置组件&＃xff0c;比如&＃xff1a;动态代理方式&＃xff08;ProxyFactory&＃xff09;、负载均衡策略&＃xff08;LoadBalance&＃xff09;、RCP协议&＃xff08;Protocol&＃xff09;、拦截器&＃xff08;Filter&＃xff09;、容器类型&＃xff08;Container&＃xff09;、集群方式&＃xff08;Cluster&＃xff09;和注册中心类型&＃xff08;RegistryFactory&＃xff09;。
SPI 做了三个方面的扩展&＃xff1a;
方便获取扩展实现&＃xff1a;JDK SPI仅仅通过接口类名获取所有实现&＃xff0c;而ExtensionLoader则通过接口类名和key值获取一个实现&＃xff1b;
IOC依赖注入功能&＃xff1a;Adaptive实现&＃xff0c;就是生成一个代理类&＃xff0c;这样就可以根据实际调用时的一些参数动态决定要调用的类了。
采用装饰器模式进行功能增强&＃xff0c;自动包装实现&＃xff0c;这种实现的类一般是自动激活的&＃xff0c;常用于包装类&＃xff0c;比如&＃xff1a;Protocol的两个实现类&＃xff1a;ProtocolFilterWrapper、ProtocolListenerWrapper。
自适应拓展机制的实现逻辑比较复杂&＃xff0c;首先 Dubbo 会为拓展接口(Adaptive )生成具有代理功能的代码。然后通过 javassist 或 jdk 编译这段代码&＃xff0c;得到 Class 类、
当 Adaptive 注解在类上时&＃xff0c;Dubbo 不会为该类生成代理类。注解在方法&＃xff08;接口方法&＃xff09;上时&＃xff0c;Dubbo 则会为该方法生成代理逻辑。
Adaptive 注解在类上的情况很少&＃xff0c;在 Dubbo 中&＃xff0c;仅有两个类被 Adaptive 注解了&＃xff0c;分别是 AdaptiveCompiler 和 AdaptiveExtensionFactory。此种情况&＃xff0c;表示拓展的加载逻辑由人工编码完成。更多时候&＃xff0c;Adaptive 是注解在接口方法上的&＃xff0c;表示拓展的加载逻辑需由框架自动生成。Adaptive 注解的地方不同&＃xff0c;相应的处理逻辑也是不同的。
服务启动包括服务暴露及服务引入&＃xff0c;主要涉及Exporter及Invoker的包装。
Dubbo 服务导出过程始于 Spring 容器发布刷新事件&＃xff0c;Dubbo 在接收到事件后&＃xff0c;会立即执行服务导出逻辑。整个逻辑大致可分为三个部分&＃xff0c;
第一部分是前置工作&＃xff0c;主要用于检查参数&＃xff0c;组装 URL。
第二部分是导出服务&＃xff0c;包含导出服务到本地 (JVM)&＃xff0c;和导出服务到远程两个过程。
第三部分是向注册中心注册服务&＃xff0c;用于服务发现。
Dubbo 服务引用的时机有两个&＃xff0c;第一个是在 Spring 容器调用 ReferenceBean 的 afterPropertiesSet 方法时引用服务&＃xff0c;第二个是在 ReferenceBean 对应的服务被注入到其他类中时引用。这两个引用服务的时机区别在于&＃xff0c;第一个是饿汉式的&＃xff0c;第二个是懒汉式的。默认情况下&＃xff0c;Dubbo 使用懒汉式引用服务。如果需要使用饿汉式&＃xff0c;可通过配置 dubbo:reference 的 init 属性开启。下面我们按照 Dubbo 默认配置进行分析&＃xff0c;整个分析过程从 ReferenceBean 的 getObject 方法开始。当我们的服务被注入到其他类中时&＃xff0c;Spring 会第一时间调用 getObject 方法&＃xff0c;并由该方法执行服务引用逻辑。按照惯例&＃xff0c;在进行具体工作之前&＃xff0c;需先进行配置检查与收集工作。接着根据收集到的信息决定服务用的方式&＃xff0c;有三种&＃xff0c;第一种是引用本地 (JVM) 服务&＃xff0c;第二是通过直连方式引用远程服务&＃xff0c;第三是通过注册中心引用远程服务。不管是哪种引用方式&＃xff0c;最后都会得到一个 Invoker 实例。如果有多个注册中心&＃xff0c;多个服务提供者&＃xff0c;这个时候会得到一组 Invoker 实例&＃xff0c;此时需要通过集群管理类 Cluster 将多个 Invoker 合并成一个实例。合并后的 Invoker 实例已经具备调用本地或远程服务的能力了&＃xff0c;但并不能将此实例暴露给用户使用&＃xff0c;这会对用户业务代码造成侵入。此时框架还需要通过代理工厂类 (ProxyFactory) 为服务接口生成代理类&＃xff0c;并让代理类去调用 Invoker 逻辑。避免了 Dubbo 框架代码对业务代码的侵入&＃xff0c;同时也让框架更容易使用。
服务注册就是把已经暴露的服务信息注册到第三方平台&＃xff0c;以供消费者使用。服务注册主要涉及的逻辑在RegistryProtocol.export方法。
服务订阅是消费端订阅所需的服务&＃xff0c;并执行服务引用&＃xff0c;服务订阅主要在RegistryProtocol 的 refer 方法逻辑。消费端完成订阅后&＃xff0c;若注册中心存在服务提供者&＃xff0c;那么消费端将对服务为服务做成服务目录&＃xff0c;供调用的时候获取地址列表。
目前dubbo支持的注册中心包括zookeeper和redis等&＃xff0c;笔者将在详细文档中做源码讲解&＃xff0c;下面介绍下消费端如何维护服务列表。
服务字典
服务目录目前内置的实现有两个&＃xff0c;分别为 StaticDirectory 和 RegistryDirectory&＃xff0c;实际环境中主要使用RegistryDirectory&＃xff0c;当注册中心节点信息发生变化后&＃xff0c;RegistryDirectory 可以通过此接口方法得到变更信息&＃xff0c;并根据变更信息动态调整内部 Invoker 列表。
RegistryDirectory服务字典
RegistryDirectory 收到变更通知后&＃xff0c;可根据配置变更信息刷新 Invoker 列表。RegistryDirectory 中有几个比较重要的逻辑&＃xff0c;第一是 Invoker 的列举逻辑&＃xff0c;第二是接收服务配置变更的逻辑&＃xff0c;第三是 Invoker 列表的刷新逻辑。
Dubbo 服务调用过程比较复杂&＃xff0c;包含众多步骤&＃xff0c;比如发送请求、编解码、服务降级、过滤器链处理、序列化、线程派发以及响应请求等步骤。
Dubbo 支持同步和异步两种调用方式&＃xff0c;其中异步调用还可细分为“有返回值”的异步调用和“无返回值”的异步调用。所谓“无返回值”异步调用是指服务消费方只管调用&＃xff0c;但不关心调用结果&＃xff0c;此时 Dubbo 会直接返回一个空的 RpcResult。若要使用异步特性&＃xff0c;需要服务消费方手动进行配置。默认情况下&＃xff0c;Dubbo 使用同步调用方式。
从下往上看&＃xff0c;首先服务消费者通过代理对象 Proxy 发起远程调用&＃xff0c;接着通过网络客户端 Client 将编码后的请求发送给服务提供方的网络层上&＃xff0c;也就是 Server。Server 在收到请求后&＃xff0c;首先要做的事情是对数据包进行解码。然后将解码后的请求发送至分发器 Dispatcher&＃xff0c;再由分发器将请求派发到指定的线程池上&＃xff0c;最后由线程池调用具体的服务。这就是一个远程调用请求的发送与接收过程。
服务目录在刷新 Invoker 列表的过程中&＃xff0c;会通过 Router 进行服务路由&＃xff0c;筛选出符合路由规则的服务提供者。在详细分析服务路由的源码之前&＃xff0c;先来介绍一下服务路由是什么。服务路由包含一条路由规则&＃xff0c;路由规则决定了服务消费者的调用目标&＃xff0c;即规定了服务消费者可调用哪些服务提供者。Dubbo 目前提供了三种服务路由实现&＃xff0c;分别为条件路由 ConditionRouter、脚本路由 ScriptRouter 和标签路由 TagRouter。其中条件路由是我们最常使用的。
集群工作过程可分为两个阶段&＃xff1a;
第一个阶段是在服务消费者初始化期间&＃xff0c;集群 Cluster 实现类为服务消费者创建 Cluster Invoker 实例&＃xff0c;即上图中的 merge 操作。
第二个阶段是在服务消费者进行远程调用时。以 FailoverClusterInvoker 为例&＃xff0c;该类型 Cluster Invoker 首先会调用 Directory 的 list 方法列举 Invoker 列表&＃xff08;可将 Invoker 简单理解为服务提供者&＃xff09;。Directory 的用途是保存 Invoker&＃xff0c;可简单类比为 List。其实现类 RegistryDirectory 是一个动态服务目录&＃xff0c;可感知注册中心配置的变化&＃xff0c;它所持有的 Invoker 列表会随着注册中心内容的变化而变化。每次变化后&＃xff0c;RegistryDirectory 会动态增删 Invoker&＃xff0c;并调用 Router 的 route 方法进行路由&＃xff0c;过滤掉不符合路由规则的 Invoker。当 FailoverClusterInvoker 拿到 Directory 返回的 Invoker 列表后&＃xff0c;它会通过 LoadBalance 从 Invoker 列表中选择一个 Invoker。最后 FailoverClusterInvoker 会将参数传给 LoadBalance 选择出的 Invoker 实例的 invoker 方法&＃xff0c;进行真正的远程调用。
Dubbo 主要提供了这样几种容错方式&＃xff1a;
在 Dubbo 中&＃xff0c;也有负载均衡的概念和相应的实现。Dubbo 需要对服务消费者的调用请求进行分配&＃xff0c;避免少数服务提供者负载过大。服务提供者负载过大&＃xff0c;会导致部分请求超时。因此将负载均衡到每个服务提供者上&＃xff0c;是非常必要的。Dubbo 提供了4种负载均衡实现&＃xff1a;
filter在dubbo中的应用非常广泛&＃xff0c;它通过在启动中对服务端及消费端方法前注入fifter链&＃xff0c;使得在调用的时候它可以对服务端、消费端的调用过程进行拦截&＃xff0c;从而对dubbo进行功能上的扩展。
dubbo中比较常见的fifter链包括&＃xff1a;EchoFilter、GenericFilter、TokenFilter、MonitorFilter、ContextFilter等。
其中GenericFilter是泛化调用的核心&＃xff0c;它能将调用泛化的url地址转换为真实的类及方法地址。
MonitorFilter是监控统计的核心&＃xff0c;MonitorFilter统计计算数据&＃xff0c;然后通过DubboMonitor将数据进行聚合&＃xff0c;并发送给外界。
GenericFilter及MonitorFilter笔者将在详细文档中做源码剖析。
在整个链路调用完成后&＃xff0c;总有一个时间点需要将服务从注册中心取消&＃xff0c;并销毁服务提供者。这个时候如果在服务切换的过程中老的服务没有正常关闭的话&＃xff0c;容易造成内存清理问题&＃xff0c;所以优雅停机是dubbo的重要的一环。
Dubbo的优雅停机是依赖于JDK的ShutdownHook函数。主要涉及到在运行时注册钩子函数&＃xff0c;并在销毁是主动调用钩子函数。
京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有