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.rhkb.cn/news/271283.html

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

相关文章

19-Java中介者模式 ( Mediator Pattern )

19-Java中介者模式 ( Mediator Pattern )

Java中介者模式 摘要实现范例 中介者模式（Mediator Pattern）提供了一个中介类，该类通常处理不同类之间的通信，并支持松耦合，使代码易于维护中介者模式是用来降低多个对象和类之间的通信复杂性中介者模式属于行为型模式…
阅读更多...
每周一算法：A*（A Star）算法

每周一算法：A*（A Star）算法

八数码难题 题目描述 在 3 3 3\times 3 33 的棋盘上，摆有八个棋子，每个棋子上标有 1 1 1 至 8 8 8 的某一数字。棋盘中留有一个空格，空格用 0 0 0 来表示。空格周围的棋子可以移到空格中。要求解的问题是：给出一种初始布局…
阅读更多...
【RT-DETR有效改进】全新的SOATA轻量化下采样操作ADown（轻量又涨点，附手撕结构图）

【RT-DETR有效改进】全新的SOATA轻量化下采样操作ADown（轻量又涨点，附手撕结构图）

一、本文介绍 本文给大家带来的改进机制是利用2024/02/21号最新发布的YOLOv9其中提出的ADown模块来改进我们的Conv模块，其中YOLOv9针对于这个模块并没有介绍，只是在其项目文件中用到了，我将其整理出来用于我们的RT-DETR的项目，经过实验我发现该卷积模块（作为下采样模块）…
阅读更多...
nicegui学习使用

nicegui学习使用

https://www.douyin.com/shipin/7283814177230178363 python轻量级高自由度web框架 - NiceGUI (6) - 知乎 python做界面，为什么我会强烈推荐nicegui 秒杀官方实现，python界面库，去掉90%事件代码的nicegui python web GUI框架-NiceGUI 教程…
阅读更多...
嵌入式学习第二十五天！（网络的概念、UDP编程）

嵌入式学习第二十五天！（网络的概念、UDP编程）

网络： 可以用来：数据传输、数据共享 1. 网络协议模型： 1. OSI协议模型： 应用层实际收发的数据表示层发送的数据是否加密会话层是否建立会话连接传输层数据传输的方式（数据包，流式）网络层数据的…
阅读更多...
吴恩达深度学习笔记：神经网络的编程基础2.1-2.3

吴恩达深度学习笔记：神经网络的编程基础2.1-2.3

目录 第一门课：神经网络和深度学习 (Neural Networks and Deep Learning)第二周：神经网络的编程基础 (Basics of Neural Network programming)2.1 二分类(Binary Classification)2.2 逻辑回归(Logistic Regression) 第一门课：神经网络和深度学…
阅读更多...
基于YOLOv5的无人机视角水稻杂草识别检测

基于YOLOv5的无人机视角水稻杂草识别检测

💡💡💡本文主要内容:详细介绍了无人机视角水稻杂草识别检测整个过程，从数据集到训练模型到结果可视化分析。 博主简介 AI小怪兽，YOLO骨灰级玩家，1）YOLOv5、v7、v8优化创新，轻松涨点…
阅读更多...
Github 2024-03-08 Java开源项目日报 Top10

Github 2024-03-08 Java开源项目日报 Top10

根据Github Trendings的统计，今日(2024-03-08统计)共有10个项目上榜。根据开发语言中项目的数量，汇总情况如下： 开发语言项目数量Java项目9C++项目1非开发语言项目1《Hello 算法》：动画图解、一键运行的数据结构与算法教程 创建周期：476 天协议类型：OtherStar数量：63556…
阅读更多...
网络原理初识(2)

网络原理初识(2)

目录 一、协议分层 1、分层的作用 2、OSI七层模型 3、TCP / IP五层（或四层）模型 4、网络设备所在分层 5、网络分层对应 二、封装和分用 发送过程（封装） 1、应用层(应用程序) QQ 2、输入层 3、网络层 4、数据链路层 5、物理…
阅读更多...
金融行业专题｜基金超融合架构转型与场景探索合集（2023版）

金融行业专题｜基金超融合架构转型与场景探索合集（2023版）

更新内容 更新 SmartX 超融合在基金行业的覆盖范围、部署规模与应用场景。更新信创云资源池、关键业务系统性能优化等场景实践。更多超融合金融核心生产业务场景实践，欢迎下载阅读电子书《金融核心生产业务场景探索文章合集》。 随着数字化经济的蓬勃发展&#xf…
阅读更多...
记一次Flink任务无限期INITIALIZING排查过程

记一次Flink任务无限期INITIALIZING排查过程

1.前言 环境：Flink-1.16.1，部署模式：Flink On YARN，现象：Flink程序能正常提交到 YARN，Job状态是 RUNNING，而 Task状态一直处于 INITIALIZING，如下图： 通过界面可以看到…
阅读更多...
ue4.27 发现 getRandomReachedLocation 返回 false

ue4.27 发现 getRandomReachedLocation 返回 false

把这个玩意儿删掉，重启工程，即可 如果还不行 保证运动物体在 volum 内部，也就是绿色范围内确保 project setting 里面的 navigation system 中 auto create navigation data 是打开的(看到过博客说关掉，不知道为啥) 如果还不行&…
阅读更多...
智奇科技工业 Linux 屏更新开机logo

智奇科技工业 Linux 屏更新开机logo

智奇科技工业 Linux 屏更新开机logo 简介制作logo.img文件1、转换格式得到logo.bmp2、使用Linux命令生成img文件 制作rootfs.img文件替换rootfs.img中的logo 生成update.img固件附件 简介 智奇科技的 Linux 屏刷开机logo必须刷img镜像文件，比较复杂。 制作logo.i…
阅读更多...
深入浅出（二）MVVM

深入浅出（二）MVVM

MVVM 1. 简介2. 示例 1. 简介 2. 示例 示例下载地址：https://download.csdn.net/download/qq_43572400/88925141 创建C# WPF应用(.NET Framework)工程，WpfApp1 添加程序集 GalaSoft.MvvmLight 创建ViewModel文件夹，并创建MainWindowV…
阅读更多...
通过对话式人工智能打破语言障碍

通过对话式人工智能打破语言障碍

「AI突破语言障碍」智能人工智能如何让全球交流无障碍 在当今互联的世界中，跨越语言界限进行交流的能力比以往任何时候都更加重要。 对话式人工智能（包括聊天机器人和语音助手等技术）在打破这些语言障碍方面发挥着关键作用。 在这篇博文中&am…
阅读更多...
简站wordpress主题看上去差不多 实际大不一样

简站wordpress主题看上去差不多 实际大不一样

有人说简站wordpress主题，都差不多嘛。我表示无语。表面看上去是差不多的，实际的细节是不一样的。 下面以编号：JZP4431和编号：JZP4878这两个主题为例子来讲一下，简站wordpress主题，在细节方面的不一样之处…
阅读更多...
【观察】华为：加速行业智能化，正在“走深向实”

【观察】华为：加速行业智能化，正在“走深向实”

毫无疑问，犹如历史上蒸汽机、电力、计算机和互联网等通用技术一样，近20年来，人工智能正以史无前例的速度和深度改变着人类社会和经济，为释放人类创造力和行业生产力，以及促进经济增长都提供了巨大的机会。 根据高盛报告…
阅读更多...
字符串函数和内存函数

字符串函数和内存函数

文章目录 字符串函数strlen函数模拟实现 strcpy函数模拟实现 strcat函数使用模拟实现 strcmp函数使用模拟实现 strncpy函数使用模拟实现 strstr函数使用模拟实现 strtok函数使用 strerror函数使用 内存函数memset函数使用memcmp函数memcpy函数使用模拟实现 memmove函数使用模拟…
阅读更多...
【深度优先】【图论】【C++算法】2045. 到达目的地的第二短时间

【深度优先】【图论】【C++算法】2045. 到达目的地的第二短时间

作者推荐 视频算法专题 LeetCode2045. 到达目的地的第二短时间 城市用一个 双向连通 图表示，图中有 n 个节点，从 1 到 n 编号（包含 1 和 n）。图中的边用一个二维整数数组 edges 表示，其中每个 edges[i] [ui, vi] 表…
阅读更多...
HCIP---IS-IS协议

HCIP---IS-IS协议

文章目录 前言一、pandas是什么？二、使用步骤 1.引入库2.读入数据总结 一.IS-IS协议概述 IS-IS是一种基于链路状态的内部网关协议（IGP），它使用最短路径优先算法（SPF或Dijkstra）进行路由计算。这种协议在自治…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023