Dubbo基础入门二

8、Dubbo协议 服务调用

8.1 服务端 启动过程深入分析

image.png

我们查看一下服务启动的过程

ProtocolFilterWrapper.export

image.png

image.png

好我们进入DubboProtocol.export

image.png

创建服务

image.png

image.png

分析我们的Handlerimage.png

image.png

我们接着返回刚才位置

image.png

image.png

image.png

image.png

image.png

下面的super方法里面会创建服务，ChannelHandlers.wrap会对hander进一步包装

image.png

1、我们进入ChannelHandlers.wrap

image.png

image.png

MultiMessageHandler—>HeartbeatHandler---->AllChannelHandler -> DecodeHandler -> HeaderExchangeHandler -> ExchangeHandlerAdapter

我看看一下super创建服务

image.png

image.png

image.png

NettyServerhandler -> NettyServer -> MultiMessageHandler—>HeartbeatHandler---->AllChannelHandler -> DecodeHandler -> HeaderExchangeHandler -> ExchangeHandlerAdapter

8.2 服务端调用过程

image.png

image.png

image.png

我们知道请求过来通过Netty服务一定是Handler的处理,下面就是整个过程

NettyServerHandler -> NettyServer -> MultiMessageHandler—>HeartbeatHandler---->AllChannelHandler -> DecodeHandler -> HeaderExchangeHandler -> ExchangeHandlerAdapter

NettyServerHandler

image.png

MultiMessageHandler

image.png

HeartbeatHandler

image.png

AllChannelHandler

https://cn.dubbo.apache.org/zh-cn/overview/mannual/java-sdk/advanced-features-and-usage/performance/threading-model/provider/

image.png

DecodeHandler

image.png

HeaderExchangeHandler

image.png

ExchangeHandlerAdapter

image.png
这里是调用我们的目标invoker，但是这里目标invoker被filter给包装了，所以先要调用filter

image.png

我们自定义过滤器就会在这里起作用

调用完毕过滤器就会调用到AbstractProxyInvoker#invoke

image.png

image.png

8.3 客户端调用

image.png

会调用JavassistProxyFactory#getProxy获取代理类

image.png

调用的时候一定会调用到InvokerInvocationHandler.invoker的方法

image.png

image.png

image.png

调用过程会有容错负载均衡FailoverClusterInvoker#doInvoke

image.pngimage.png

我们可以简单看一下负载均衡

image.png

image.png

HeaderExchangeChannel#request发送请求

image.png

HeaderExchangeHandler#received处理返回数据

image.png

image.png

9、Triple协议

9.1 背景

在Dubbo2.7中，默认的是Dubbo协议，因为Dubbo协议相比较于Http1.1而言，Dubbo协议性能上是要更好的。

但是Dubbo协议自己的缺点就是不通用，假如现在通过Dubbo协议提供了一个服务，那如果想要调用该服务就必须要求服务消费者也要支持Dubbo协议。

而随着企业的发展，往往可能会出现公司内部使用多种技术栈，可能这个部门使用Dubbo，另外一个部门使用Spring Cloud，另外一个部门使用gRPC，那此时部门之间要想相互调用服务就比较复杂了，所以需要一个通用的、性能也好的协议，这就是Triple协议。

9.2 Triple协议介绍

Triple 是 Dubbo3 提出的基于 HTTP2 的开放协议，旨在解决 Dubbo2 私有协议带来的互通性问题。另外，Google公司开发的gRPC，也基于的HTTP2，目前gRPC是云原生事实上协议标准，包括k8s/etcd等都支持gRPC协议。

9.3 HTTP1 和HTTP2进行对比

9.3.1 HTTP1

image.png

POST /getName HTTP/1.1
Host: example.com
Content-Type: application/x-www-form-urlencoded
Content-Length: 27username=john&password=1234

我们会发现我们除了username=john&password=1234 数据之外，其他的内容都是额外信息，并且这些额外信息量很大。

9.3.2 HTTP2

image.png

  1. 帧长度，用三个字节来存一个数字，这个数字表示当前帧的实际传输的数据的大小，3个字节表示的最大数字是2

    的24次方（16M），所以一个帧最大为9字节+16M。

  2. 帧类型，占一个字节，可以分为数据帧和控制帧

    1. DATA：用于传输请求和响应中的数据，包含有效载荷（payload）。
    2. HEADERS：用于传输HTTP头部信息，包含有效载荷（payload）。
    3. PRIORITY：用于指定数据流的优先级，包含与数据流相关的信息。
    4. RST_STREAM：用于指示数据流的中止，并通知原因。
    5. SETTINGS：用于传输HTTP/2连接的配置参数。
    6. PUSH_PROMISE：用于服务端推送资源，包含预期的请求头和有效载荷。
    7. PING：用于检测HTTP/2连接的可用性和延迟时间。

  3. 标志位，占一个字节，可以用来表示当前帧是整个请求里的最后一帧，方便服务端解析、

  4. 流标识符，占4个字节，在Java中也就是一个int，不过最高位保留不用，表示Stream ID，这也是HTTP2的一个重要设计

  5. 实际传输的数据Payload，如果帧类型是HEADERS，那么这里存的就是请求头，如果帧类型是DATA ，那么这里

    存的就是请求体

通过这种设计，我们可以发现，我们就可以来压缩请求头了，比如如果帧的类型是HEADERS ，那就进行压缩，当然压缩算法是固定的HPACK算法，不能更换。

9.4 Triple源码分析

通过学习Dubbo协议，我们首先要知道我们启动服务的应该是在TripleProtocol

9.4.1 客户端处理

image.png

调到TripleInvoker.doInvoke

image.png

image.png

发送数据

image.png

发送数据包括请求头和请求体

image.png

发送请求头

这里我们数据会放到队列，最后会调用到HeaderQueueCommand#doSend方法，发送数据

image.png

放入队列

先放到队列，然后会定时flush的时候进行处理

image.png

image.png

下面我们可以看到，当我发现有数据就会一直取知道128个后才发送，如果poll为空，则走下面内容数据不为空则发送

image.png

刷新后则调用到HeaderQueueCommand#doSend方法

image.png

下面发送请求体和完成，与上面发送请求头都是异步处理，代码一样只是最后调用处理不同

发送数据

image.png

image.png

上图我们可以看出，也是异步处理，最终会调用到DataQueueCommand#doSend方法

image.png

发送完成数据

image.png

image.png

image.png

image.png

最终会调用感到EndStreamQueueCommand.doSend方法

image.png

9.4.2 服务端启动

image.png

image.png

image.png

image.png

进入启动Netty的源码

image.png

这里有个处理器NettyPortUnificationServerHandler，我们这里有的decode方法，他会识别我们是不是HTTP2协议

怎样识别HTTP2协议？

如果要建立的是一个HTTP2连接，那么在建立完Socket连接后,客户端立刻会发送一个连接前言，也就是一串字节

(对应的字符串为:“PRI*HTTP/2.0\r\n\r\nSM\r\n\r\n”)， 给到服务端，服务端从而知道要建立的是HTTP2

image.png

如果识别出RECOGNIZED，

image.png

image.png

处理数据

image.png

处理请求头

image.png

image.png

image.png

image.png

获取invoker

image.png

启动监听器

image.png

image.png

image.png

这里处理请求头获取了Invoker和对应的listener:UnaryServerCallListener 处理请求内容中会用到

处理请求

image.png

image.png

image.png

处理请求体

image.png

image.png

image.png

image.png

image.png

这里只是给我们invoker设置了参数，但是没有立刻调用，而是在complete中进行调用

image.png

处理完成帧

image.png

image.png

image.png

image.png

image.png

image.png

image.png

10、扩展点SPI

10.1 概念

SPI是一种软件编程模型，用于实现在运行时动态加载和扩展组件的能力。在Dubbo3中，SPI机制被广泛应用于扩展框架功能，允许用户自定义实现各种接口，以满足业务需求。

Java中的SPI机制

image.png

我们使用Mybatis操作数据库，那我们应该使用怎样操作mysql 或者oracle或者DB2呢？ 首先我们应该引入对应的Mysql的jar，我们利用这jar才能操作数据库，那对于JDBC操作DriveMananger获取链接的时候，他怎样获取Mysql的jar包中对应的类，来链接mysql呢

image.png

实例：

image.png

加载对应的配置

image.png

image.png

缺点：我们如果对应配置文件中com.msb.dubbo.provider.SPI.JDK.Course配置多个实现类，但是我们只需要EnglishCourse，所以为了效率我们只应该加载EnglishCourse，但是JDK的SPI会把所有的加载掉，所以Dubbo退出自己的SPI

image.png

image.png

image.png

Dubbo3 SPI演示

image.png

image.png

image.png

image.png

image.png

image.png

Wrapper包装（AOP）

image.png

image.png

image.png

10.2源码分析

image.png

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/520826.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【Proteus仿真】【51单片机】井盖安全检测装置设计

【Proteus仿真】【51单片机】井盖安全检测装置设计

文章目录 一、功能简介二、软件设计三、实验现象联系作者 一、功能简介 本项目使用Proteus8仿真51单片机控制器，使用LCD1602液晶显示模块、WIFI模块、蜂鸣器、LED按键、ADC PCF8591、角度/可燃气检测传感器等。 主要功能： 系统运行后，LCD16…
阅读更多...
【MATLAB 】 EMD信号分解+FFT傅里叶频谱变换组合算法

【MATLAB 】 EMD信号分解+FFT傅里叶频谱变换组合算法

有意向获取代码，请转文末观看代码获取方式~ 展示出图效果 1 EMD信号分解算法 EMD 分解又叫经验模态分解，英文全称为 Empirical Mode Decomposition。 EMD 是一种信号分解方法，它将一个信号分解成有限个本质模态函数 (EMD) 的和&#xff0c…
阅读更多...
掌握Docker容器监控：Docker命令与Prometheus的协同作战（上）

掌握Docker容器监控：Docker命令与Prometheus的协同作战（上）

🐇明明跟你说过：个人主页 🏅个人专栏：《Docker入门到精通》 《k8s入门到实战》🏅 🔖行路有良友，便是天堂🔖 目录 一、引言 1、Docker简介 2、为什么要对Docker容器实行监控 3…
阅读更多...
【智能家居入门1之环境信息监测】（STM32、ONENET云平台、微信小程序、HTTP协议）

【智能家居入门1之环境信息监测】（STM32、ONENET云平台、微信小程序、HTTP协议）

作为入门本篇只实现微信小程序接收下位机上传的数据，之后会持续发布如下项目：①可以实现微信小程序控制下位机动作，真正意义上的智能家居；②将网络通讯协议换成MQTT协议再实现上述功能，此时的服务器也不再是ONENET&…
阅读更多...
为什么电容器放电电阻器现在被强制要求作为基本安全装置

为什么电容器放电电阻器现在被强制要求作为基本安全装置

在电子产品中，电容器放电电阻器或泄放电阻器是与高压电源电路的输出并联的电阻器，其明确目的是释放存储在电源滤波电容器中的剩余电荷。 例如，开关模式电源使用桥式整流器将交流市电转换为 320V（市电电压为 220/240V）或…
阅读更多...
先进电机技术 —— 编码器

先进电机技术 —— 编码器

一、编码器 电机编码器是一种用于检测和反馈电动机转轴位置、旋转速度和方向的传感器装置。它在电机控制系统中起到关键作用，通过将机械运动转换为电信号，帮助控制器精确控制电机的动态性能。 编码器主要组成 1. **光学或磁性传感元件**：基于…
阅读更多...
VSCode报错：/bin/sh: python: command not found

VSCode报错：/bin/sh: python: command not found

背景 以前都是直接用txt写python，然后直接命令行运行。 这次涉及的代码较多，决定用编译器。 写好的一段python点击运行报错！ 问题描述 因为我本地安装的是python3，但是vscode用的是另一个路径的python，所以找不到 解…
阅读更多...
IDEA自定义Maven仓库

IDEA自定义Maven仓库

Maven 是一款广泛应用于 Java 开发的工具，其作用类似于一个全自动的 JAR 包管理器，能够方便地导入开发所需的相关 JAR 包。在使用 Maven 进行 Java 程序开发时，开发者能够极大地提高开发效率。以下是关于如何安装 Maven 以及在 IDEA 中配置自…
阅读更多...
【C++】学习记录

【C++】学习记录

一、第一个C程序 #include<iostream> using namespace std;int main() {cout << "Hello World!";return 0; } 二、数据类型、变量与常量、运算符 2.1 数据类型 2.2 变量与常量 2.3 运算符 三 、判断语句&#xff08;if-else、switch-case&#xff09; …
阅读更多...
开源分子对接程序rDock使用方法(1)-Docking in 3 steps

开源分子对接程序rDock使用方法(1)-Docking in 3 steps

欢迎浏览我的CSND博客&#xff01; Blockbuater_drug …点击进入 文章目录 前言一、Docking in 3 steps 标准对接rDock 的基本对接步骤及注意事项 二、 三步对接案例Step 1. 结构文件准备Step 2. 产生对接位点Step 3. 运行分子对接3.1 检查输入文件3.2 测试-只进行打分3.3 运行…
阅读更多...
绝地求生：PUBG2024萌新入坑指南四排建议避坑

绝地求生：PUBG2024萌新入坑指南四排建议避坑

PUBG自2017年起至今已近7个年头了&#xff0c;许多游戏玩家都体验过这款游戏&#xff0c;但也有相当多的玩家对这种模式不感冒。 游戏市场日新月异&#xff0c;经过多年发展&#xff0c;PUBG这款游戏不可避免的衰落&#xff0c;哪怕他本体免费了。 闲游盒免费给这款游戏续了一…
阅读更多...
免费分享一套SpringBoot+Vue旅游管理系统，帅呆了~~

免费分享一套SpringBoot+Vue旅游管理系统，帅呆了~~

大家好&#xff0c;我是java1234_小锋老师&#xff0c;看到一个不错的SpringBootVue旅游管理系统&#xff0c;分享下哈。 项目视频演示 【免费】SpringBootVue旅游管理系统 Java毕业设计_哔哩哔哩_bilibili【免费】SpringBootVue旅游管理系统 Java毕业设计项目来自互联网&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023