Dubbo一个高性能优秀的RPC框架

客官°小女子只卖身不卖艺 2023-09-24 15:14 114阅读 0赞

> Dubbo(读音\[ˈdʌbəʊ\])是阿里巴巴公司开源的一个高性能优秀的RPC[服务框架][Link 1](后捐献给Apache,有Apache进行维护,我们现在使用的是Apache下的Dubbo)，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和 \[1\]  [Spring][]框架无缝集成。

> Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：**面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。**

**主要核心部件**

**Remoting:** 网络通信框架，实现了 sync-over-async 和 request-response 消息机制.

**RPC:** 一个[远程过程调用][Link 2]的抽象，支持[负载均衡][Link 3]、[容灾][Link 4]和[集群][Link 5]功能

**Registry:** 服务目录框架用于服务的注册和服务事件发布和订阅

### 工作原理 ###

原理图

![8585e9aaa5f04d30bb7bcfa1bfb163ea.png][]

**Provider**

暴露服务方称之为“[服务提供者][Link 6]”。

**Consumer**

调用[远程服务][Link 7]方称之为“服务消费者”。

**Registry**

服务注册与发现的中心目录服务称之为“服务注册中心”。

**Monitor**

统计服务的调用次数和调用时间的日志服务称之为“服务监控中心”。

(1) 连通性：

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

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

服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销

服务消费者向注册中心获取[服务提供者][Link 6]地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销

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

注册中心通过[长连接][Link 9]感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者

注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在[本地缓存][Link 10]了提供者列表

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

(2) 健壮性：

监控中心宕掉不影响使用，只是丢失部分[采样数据][Link 11]

数据库宕掉后，注册中心仍能通过[缓存][Link 12]提供服务列表查询，但不能注册新服务

注册中心对等[集群][Link 5]，任意一台宕掉后，将自动切换到另一台

注册中心全部宕掉后，[服务提供者][Link 6]和服务消费者仍能通过本地缓存通讯

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

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

(3) 伸缩性：

注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心

服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者

### 特性 ###

*  面向接口代理的高性能RPC调用提供高性能的基于代理的远程调用能力，服务以接口为粒度，为开发者屏蔽远程调用底层细节。
 *  智能负载均衡内置多种负载均衡策略，智能感知下游节点健康状况，显著减少调用延迟，提高系统吞吐量。
 *  服务自动注册与发现支持多种注册中心服务，服务实例上下线实时感知。
 *  高度可扩展能力遵循微内核+插件的设计原则，所有核心能力如Protocol、Transport、Serialization被设计为扩展点，平等对待内置实现和第三方实现。
 *  运行期流量调度内置条件、脚本等路由策略，通过配置不同的路由规则，轻松实现灰度发布，同机房优先等功能。
 *  可视化的服务治理与运维提供丰富服务治理、运维工具：随时查询服务元数据、服务健康状态及调用统计，实时下发路由策略、调整配置参数。

### 例子 ###

#### 服务端 ####

定义一个Service Interface：（**HelloService.java**）

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 </td> 
 <td> <code>package</code>&nbsp;<code>com.alibaba.hello.api;</code> <code>public</code>&nbsp;<code>interface</code>&nbsp;<code>HelloService</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>String&nbsp;sayHello(String&nbsp;name);</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

接口的实现类：（**HelloServiceImpl.java**）

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>package</code>&nbsp;<code>com.alibaba.hello.impl;</code> <code>import</code>&nbsp;<code>com.alibaba.hello.api.HelloService;</code> <code>public</code>&nbsp;&nbsp;<code>class</code>&nbsp;&nbsp;<code>HelloServiceImpl&nbsp;&nbsp;</code><code>implements</code>&nbsp;&nbsp;<code>HelloService{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;&nbsp;<code>String&nbsp;&nbsp;sayHello(String&nbsp;&nbsp;name){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;&nbsp;<code>"Hello"</code>&nbsp;<code>+&nbsp;name;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

Spring配置：（**provider.xml**）

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 </td> 
 <td> <code>&lt;?</code><code>xmlversion</code><code>=</code><code>"1.0"</code><code>encoding</code><code>=</code><code>"UTF-8"</code><code>?&gt;</code> <code>&lt;</code><code>beans......</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--Applicationname--&gt;</code> <code>&nbsp; &nbsp; &nbsp;//进行服务注册</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:applicationname</code><code>=</code><code>"hello-world-app"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--registryaddress,usedforservicetoregisteritself--&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:registryaddress</code><code>=</code><code>"multicast://224.5.6.7:1234"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--exposethisservicethroughdubboprotocol,throughport20880--&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:protocolname</code><code>=</code><code>"dubbo"</code><code>port</code><code>=</code><code>"20880"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--whichserviceinterfacedoweexpose?--&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:serviceinterface</code><code>=</code><code>"com.alibaba.hello.api.HelloService"</code><code>ref</code><code>=</code><code>"helloService"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--designateimplementation--&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>beanid</code><code>=</code><code>"helloService"</code><code>class</code><code>=</code><code>"com.alibaba.hello.impl.HelloServiceImpl"</code><code>/&gt;</code> <code>&lt;/</code><code>beans</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

测试代码：（**Provider.java**）

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>importorg.springframework.context.support.ClassPathXmlApplicationContext;</code> <code>public</code>&nbsp;&nbsp;<code>class</code>&nbsp;&nbsp;<code>Provider{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;&nbsp;<code>static</code>&nbsp;&nbsp;<code>void</code>&nbsp;&nbsp;<code>main(String[]&nbsp;&nbsp;args){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ClassPathXmlApplicationContext&nbsp;&nbsp;context&nbsp;=&nbsp;</code><code>new</code>&nbsp;&nbsp;<code>ClassPathXmlApplicationContext(newString[]{ </code><code>"provider.xml"</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//启动成功，监听端口为20880System.in.read();//按任意键退出</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

#### 客户端 ####

Spring配置文件：(**consumer.xml**)

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>&lt;?</code><code>xmlversion</code><code>=</code><code>"1.0"</code><code>encoding</code><code>=</code><code>"UTF-8"</code><code>?&gt;</code> <code>&lt;</code><code>beans</code>&nbsp;<code>xmlns=......&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--consumerapplicationname--&gt;</code> <code>&nbsp; &nbsp; &nbsp;//服务订阅与引用</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:applicationname</code><code>=</code><code>"consumer-of-helloworld-app"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--registryaddress,usedforconsumertodiscoverservices--&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:registryaddress</code><code>=</code><code>"multicast://224.5.6.7:1234"</code><code>/&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;!--whichservicetoconsume?--&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>dubbo:referenceid</code><code>=</code><code>"helloService"</code><code>interface</code><code>=</code><code>"com.alibaba.hello.api.HelloService"</code><code>/&gt;</code> <code>&lt;/</code><code>beans</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

客户端测试代码：（**Consumer.java**）

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
 <td> <code>import</code>&nbsp;&nbsp;<code>org.springframework.context.support.ClassPathXmlApplicationContext;</code> <code>import</code>&nbsp;&nbsp;<code>com.alibaba.hello.api.HelloService;</code> <code>public</code>&nbsp;&nbsp;<code>class</code>&nbsp;&nbsp;<code>Consumer{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;&nbsp;<code>static</code>&nbsp;&nbsp;<code>void</code>&nbsp;&nbsp;<code>main(String[]&nbsp;&nbsp;args){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ClassPathXmlApplicationContext&nbsp;&nbsp;context&nbsp;=&nbsp;</code><code>new</code>&nbsp;&nbsp;<code>ClassPathXmlApplicationContext(newString[]{ </code><code>"consumer.xml"</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>HelloService&nbsp;&nbsp;helloService&nbsp;=&nbsp;(HelloService)context.getBean(</code><code>"helloService"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//getserviceinvocationproxyStringhello=helloService.sayHello("world");</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//doinvoke!System.out.println(hello);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//cool,howareyou~</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

[Link 1]: https://baike.baidu.com/item/%E6%9C%8D%E5%8A%A1%E6%A1%86%E6%9E%B6?fromModule=lemma_inlink
[Spring]: https://baike.baidu.com/item/Spring?fromModule=lemma_inlink
[Link 2]: https://baike.baidu.com/item/%E8%BF%9C%E7%A8%8B%E8%BF%87%E7%A8%8B%E8%B0%83%E7%94%A8?fromModule=lemma_inlink
[Link 3]: https://baike.baidu.com/item/%E8%B4%9F%E8%BD%BD%E5%9D%87%E8%A1%A1?fromModule=lemma_inlink
[Link 4]: https://baike.baidu.com/item/%E5%AE%B9%E7%81%BE?fromModule=lemma_inlink
[Link 5]: https://baike.baidu.com/item/%E9%9B%86%E7%BE%A4?fromModule=lemma_inlink
[8585e9aaa5f04d30bb7bcfa1bfb163ea.png]: https://img-blog.csdnimg.cn/8585e9aaa5f04d30bb7bcfa1bfb163ea.png
[Link 6]: https://baike.baidu.com/item/%E6%9C%8D%E5%8A%A1%E6%8F%90%E4%BE%9B%E8%80%85/12725153?fromModule=lemma_inlink
[Link 7]: https://baike.baidu.com/item/%E8%BF%9C%E7%A8%8B%E6%9C%8D%E5%8A%A1?fromModule=lemma_inlink
[Link 8]: https://baike.baidu.com/item/%E7%9B%AE%E5%BD%95%E6%9C%8D%E5%8A%A1?fromModule=lemma_inlink
[Link 9]: https://baike.baidu.com/item/%E9%95%BF%E8%BF%9E%E6%8E%A5?fromModule=lemma_inlink
[Link 10]: https://baike.baidu.com/item/%E6%9C%AC%E5%9C%B0%E7%BC%93%E5%AD%98?fromModule=lemma_inlink
[Link 11]: https://baike.baidu.com/item/%E9%87%87%E6%A0%B7%E6%95%B0%E6%8D%AE?fromModule=lemma_inlink
[Link 12]: https://baike.baidu.com/item/%E7%BC%93%E5%AD%98?fromModule=lemma_inlink