分享好友 最新动态首页 最新动态分类 切换频道
Java中的RPC框架Dubbo原理和机制详解
2024-12-26 13:17

Dubbo主要提供了3大核心功能:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。

Java中的RPC框架Dubbo原理和机制详解

1)远程方法调用

网络通信框架,提供对多种NIO框架抽象封装,包括“同步转异步”和“请求-响应”模式的信息交换方式。

 2)智能容错和负载均衡

提供基于接口方法的透明远程过程调用,包括多协议支持,以及软负载均衡,失败容错,地址路由,动态配置等集群支持。

3)服务注册和发现

服务注册,基于注册中心目录服务,使服务消费方能动态的查找服务提供方,使地址透明,使服务提供方可以平滑增加或减少机器。

主要包含如下几个核心组件:

1)注册中心(registry)

生产者在此注册并发布内容,消费者在此订阅并接收发布的内容。

2)消费者(consumer)

客户端,从注册中心获取到方法,可以调用生产者中的方法。

3)生产者(provider)

服务端,生产内容,生产前需要依赖容器(先启动容器)。

4)容器(container)

生产者在启动执行的时候,必须依赖容器才能正常启动(默认依赖的是spring容器),

5)监控(Monitor)

统计服务的调用次数与时间等。

Dubbo整体架构如下图所示:

图中左边淡蓝背景的为服务消费方使用的接口,右边淡绿色背景的为服务提供方使用的接口, 位于中轴线上的为双方都用到的接口。

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

1. 服务接口层(Service)

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

2. 配置层(Config)

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

3.服务代理层(Proxy)

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

4.服务注册层(Registry)

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

5.集群层(Cluster)

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

6.监控层(Monitor)

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

7.远程调用层(Protocol)

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

8. 信息交换层(Exchange)

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

9.网络传输层(Transport)

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

10.数据序列化层(Serialize)

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

 对照上面的整体架构图,大致分为以下8大步骤:

1、服务提供者启动,开启Netty服务,创建Zookeeper客户端,向注册中心注册服务;

2、服务消费者启动,通过Zookeeper向注册中心获取服务提供者列表,与服务提供者通过Netty建立长连接;

3、服务消费者通过接口开始远程调用服务,ProxyFactory通过初始化Proxy对象,Proxy通过创建动态代理对象;

4、动态代理对象通过invoke方法,层层包装生成一个Invoker对象,该对象包含了代理对象;

5、Invoker通过路由,负载均衡选择了一个最合适的服务提供者,在通过加入各种过滤器,协议层包装生成一个新的DubboInvoker对象;

6、再通过交换成将DubboInvoker对象包装成一个Reuqest对象,该对象通过序列化通过NettyClient传输到服务提供者的NettyServer端;

7、到了服务提供者这边,再通过反序列化、协议解密等操作生成一个DubboExporter对象,再层层传递处理,会生成一个服务提供端的Invoker对象;

8、这个Invoker对象会调用本地服务,获得结果再通过层层回调返回到服务消费者,服务消费者拿到结果后,再解析获得最终结果。

最新文章
3D5月周日连号走势图近1000期带连线
功能类福彩3D显示遗漏:显示/隐藏遗漏值,遗漏值是指自上期开出到本期间隔的期数。福彩3D遗漏分层:是将当前遗漏值用柱状图形标注。福彩3D分段线:是每五期使用分隔线,使横向导航更加清晰。福彩3D显示断区:在分区走势中使用,将开出0个号
AIGC数字人克隆系统:打造个性化虚拟形象新选择
**AIGC数字人克隆系统:打造个性化虚拟形象新选择**在科技日新月异的今天,虚拟形象已不再局限于简单的卡通或游戏角色,而是逐渐发展成为一种全新的个性化表达方式。随着人工智能技术的飞速发展,AIGC(Artificial Intelligence Generated
300021大禹节水改名;大禹智能人工智能子公司慧图科技研发的慧图科技人工智能T
300021大禹节水 改名;大禹智能人工智能子公司慧图科技研发的慧图科技人工智能Top AI平台,通过底层高效的AI+核心识别应用引 擎,利用智能识别逻辑单元,快速的识别和理解应用图像场景,利用积滞水场景图像大数据和深 度学习技术,建立积滞
12月十大金股:十二月策略和十大金股报告.docxVIP
1、12月十大金股组合序号公司代码名称行业总市值PE(亿元)202320242025EPS20232024202序号公司代码名称行业总市值PE(亿元)202320242025EPS20232024202联系人51002739.SZ万达电影传媒新消费267.4129.2120.1116.580.420.610.74朱珠2300788
4000199070总是发短信是什么意思?
01070总是发短信小编导语在现代社会中,手机已经成为我们生活中不可或缺的一部分。我们通过手机进行沟通、获取信息和进行各种交易。随着手机使用的普及,各种信息也随之而来,其中不乏一些令人困扰的短信。尤其是来自开头的号码,这类短信
2024湖南株洲市公安局荷塘分局警务辅助人员招聘16人公告
根据工作需要,株洲市公安局荷塘分局面向社会公开招聘16名警务辅助人员,具体招聘方案公告如下:一、招聘计划株洲市公安局荷塘分局本次计划招聘警务辅助人员16名,具体的招聘职位、人数、资格条件等详见下方《株洲市公安局荷塘分局招聘警务
AI面试辅助工具是否算作弊?大学生求职时能否使用多面鹅?
在当前激烈的求职竞争中,大学生面临着巨大的挑战。他们不仅要展示自己的专业技能和学术成就,还要在面试中展现出卓越的沟通能力和个人魅力。随着人工智能技术的发展,AI面试辅助工具应运而生,为求职者提供了一种
angular试题
mvc:View 传送指令到 ControllerController 完成业务逻辑后,要求 Model 改变状态Model 将新的数据发送到 View,用户得到反馈所有通信都是单向的。Angular它采用双向绑定(data-binding):View的变动,自动反映在 ViewModel,反之亦然。组
IDEA安装docker详细教程
目录 首先 服务器上的配置(以阿里云服务器为例): 1.服务器设置 2.设置规则 3.配置宝塔 4.安装docker并配置阿里仓库(可理解为maven仓库类似) 5.IDEA安装docker(推荐新开一个spring快速搭建项目&#
AI怎么做字体设计?一个矩形工具就能搞定!
更新时间:2023-03-28 14:19:27AI(Adobe Illustrator)怎么做?一些刚入门的初学者或者对 AI 有兴趣的小伙伴们大多数情况下都对 AI 工具有一些心理误区,经常会觉得用 AI 做字体设计是很难得一个过程,今天,本文将给大家带来一份详细的 A
相关文章
推荐文章
发表评论
0评