高性能网络模式-Reactor

事实上,Reactor 模式也叫Dispatcher模式,即I/O 多路复⽤监听事件,收到事件后,根据事件类型分配(Dispatch)给某个进程/线程。Reactor 模式也是一种非阻塞同步网络模式。

Reactor 模式主要由 Reactor部分处理事件部分这两个核⼼部分组成,它俩负责的事情如下:

  • Reactor部分负责监听和分发事件,事件类型包含连接事件、读写事件;
  • 处理事件部分负责处理事件,如 read -> 业务逻辑 -> send

Reactor 模式是灵活多变的,可以应对不同的业务场景,灵活在于:

  • Reactor 的数量可以只有⼀个,也可以有多个;
  • 处理事件部分可以是单个进程/线程,也可以是多个进程/线程

单Reactor单进程/线程

方案示意图
在这里插入图片描述
其中:

  1. Reactor对象用于监听所有的套接字以及按事件类型分发给不同对象。
  2. Acceptor对象用于listen套接字事件发生后的建立新连接。
  3. Hander对象用于普通套接字事件发生后处理对应的业务。

💡具体思想我们可以理解为:

  • Reactor 对象通过IO 多路复⽤接⼝监听事件,收到事件后通过 dispatch 进⾏分发,具体分发给 Acceptor 对象还是 Handler 对象,还要看收到的事件类型;
  • 如果是连接建⽴的事件,则交由 Acceptor 对象进⾏处理,Acceptor 对象会通过 accept⽅法 获取连接,并创建⼀个 Handler 对象来处理后续的响应事件;
  • 如果不是连接建⽴事件, 则交由当前连接对应的 Handler 对象来进⾏响应;Handler 对象通过 read -> 业务处理 -> send 的流程来完成完整的业务流程。

该方案的缺点:

  1. 因为是单进程,所以无法充分利用多核CPU性能。
  2. Hander对象在处理业务的时候,整个进程是无法处理其他连接的事件的,如果业务处理耗时比较长的话,会造成响应的延迟,因此适用于业务处理快速的场景,比如Redis

单Reactor多进程/线程

方案示意图:
在这里插入图片描述
相比与单进程:

  1. Hander对象不再负责业务的处理逻辑,只负责数据的接收和发送。
  2. 添加了线程池方案,将对应的要处理的业务逻辑交由线程池中的线程处理。

💡方案思想:

  1. Reactor 对象通过多路复用监听事件,收到事件后通过 dispatch 进⾏分发,具体分发给 Acceptor 对象还是 Handler 对象,还要看收到的事件类型;
  2. 如果是连接建⽴的事件,则交由 Acceptor 对象进⾏处理,Acceptor 对象会通过 accept⽅法 获取连接,并创建⼀个 Handler 对象来处理后续的响应事件;
  3. 如果不是连接建⽴事件, 则交由当前连接对应的 Handler 对象来进⾏响应;
  4. Handler 对象不再负责业务处理,只负责数据的接收和发送,Handler 对象通过 read 读取到数据后,会将数据发给线程池中的空闲⼦线程⾥的 Processor 对象进⾏业务处理;
  5. ⼦线程⾥的 Processor 对象就进⾏业务处理,处理完后,将结果发给主线程中的 Handler对象,接着由 Handler 通过 send ⽅法将响应结果发送给 client;

多线程的方案优势在于能够充分利用多核CPU的性能,但是引入了多线程,自然也带来了多线程资源竞争的问题。

多Reactor多进程/线程

单 Reactor的模式还有个问题,因为⼀个 Reactor 对象承担所有事件的监听和分发,⽽且只在主线程中运⾏,在⾯对瞬间⾼并发的场景时,容易成为性能的瓶颈的地⽅
那我们此时会想到什么?不错!再引入Reactor
示意图:
在这里插入图片描述
相比于单Reactor的改进:

  1. 通过将需要监听的套接字分布在多个Reactor上,从而减轻主线程主Reactor的负担。
  2. 主线程的Reactor对象只负责监听listen套接字并建立新连接。

💡方案思想:

  1. 主线程中的 MainReactor 对象通过 select 监控连接建⽴事件,收到事件后通过 Acceptor对象中的 accept 获取连接,将新的连接分配给某个子线程
  2. ⼦线程中的 SubReactor 对象将 MainReactor 对象分配的连接加⼊ select 继续进⾏监听,并创建⼀个 Handler ⽤于处理连接的响应事件;
  3. 如果有新的事件发⽣时,SubReactor 对象会调⽤当前连接对应的 Handler 对象来进⾏响应;
  4. Handler 对象通过 read -> 业务处理 -> send 的流程来完成完整的业务流程;

⭐️⭐️⭐️优点

  • 主线程和⼦线程分⼯明确,主线程只负责接收新连接并将新连接交给子线程,⼦线程负责完成该连接后续的监听和业务处理
  • 主线程和⼦线程的交互很简单,主线程只需要把新连接传给⼦线程,⼦线程⽆须返回数据,直接就可以在⼦线程将处理结果发送给客户端。

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

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

相关文章

LeetCode 面试题 02.04. 分割链表

文章目录 一、题目二、C# 题解 一、题目 给你一个链表的头节点 head 和一个特定值 x,请你对链表进行分隔,使得所有 小于 x 的节点都出现在 大于或等于 x 的节点之前。 你不需要 保留 每个分区中各节点的初始相对位置。 点击此处跳转题目。 示例 1&#…

Linux下的系统编程——vim/gcc编辑(二)

前言: 在Linux操作系统之中有很多使用的工具,我们可以用vim来进行程序的编写,然后用gcc来生成可执行文件,最终运行程序。下面就让我们一起了解一下vim和gcc吧 目录 一、vim编辑 1.vim的三种工作模式 2.基本操作之跳转字符 &a…

无涯教程-Android - 环境设置

您可以从Oracle的Java网站下载最新版本的Java JDK-Java SE下载,您将在下载的文件中找到有关安装JDK的说明,按照给定的说明安装和配置安装程序。最后,将PATH和JAVA_HOME环境变量设置为引用包含 java 和 javac 的目录,通常分别是java_install_dir/bin和java_install_d…

Acwing796.子矩阵的和

理解二维前缀和&#xff1a; #include <iostream>using namespace std;const int N 1010;int a[N][N], s[N][N];int main() {int n, m, q;cin >> n >> m >> q;for (int i 1; i < n; i)for (int j 1; j < m; j) {scanf("%d", &a…

jvm的内存区域

JVM 内存分为线程私有区和线程共享区&#xff0c;其中方法区和堆是线程共享区&#xff0c;虚拟机栈、本地方法栈和程序计数器是线程隔离的数据区。 1&#xff09;程序计数器 程序计数器&#xff08;Program Counter Register&#xff09;也被称为 PC 寄存器&#xff0c;是一块…

新亮点!安防视频监控/视频集中存储/云存储平台EasyCVR平台六分屏功能展示

安防视频监控/视频集中存储/云存储/磁盘阵列EasyCVR平台可拓展性强、视频能力灵活、部署轻快&#xff0c;可支持的主流标准协议有国标GB28181、RTSP/Onvif、RTMP等&#xff0c;以及支持厂家私有协议与SDK接入&#xff0c;包括海康Ehome、海大宇等设备的SDK等。平台既具备传统安…

回归预测 | MATLAB实现GWO-ELM灰狼算法优化极限学习机多输入单输出回归预测(多指标,多图)

回归预测 | MATLAB实现GWO-ELM灰狼算法优化极限学习机多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09; 目录 回归预测 | MATLAB实现GWO-ELM灰狼算法优化极限学习机多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09;效果一览基本介绍程…

【uniapp 配置启动页面隐私弹窗】

为什么需要配置 原因 根据工业和信息化部关于开展APP侵害用户权益专项整治要求&#xff0c;App提交到应用市场必须满足以下条件&#xff1a; 1.应用启动运行时需弹出隐私政策协议&#xff0c;说明应用采集用户数据 2.应用不能强制要求用户授予权限&#xff0c;即不能“不给权…

C语言网络编程实现广播

1.概念 如果同时发给局域网中的所有主机&#xff0c;称为广播 我们可以使用命令查看我们Linux下当前的广播地址&#xff1a;ifconfig 2.广播地址 以192.168.1.0 (255.255.255.0) 网段为例&#xff0c;最大的主机地址192.168.1.255代表该网段的广播地址&#xff08;具体以ifcon…

深度学习9:简单理解生成对抗网络原理

目录 生成算法 生成对抗网络&#xff08;GAN&#xff09; “生成”部分 “对抗性”部分 GAN如何运作&#xff1f; 培训GAN的技巧&#xff1f; GAN代码示例 如何改善GAN&#xff1f; 结论 生成算法 您可以将生成算法分组到三个桶中的一个&#xff1a; 鉴于标签&#…

C语言网络编程:实现自己的高性能网络框架

一般生产环境中最耗时的其实是业务逻辑处理。所以&#xff0c;是不是可以将处理业务逻辑的代码给拆出来丢到线程池中去执行。 比如像下面这样&#xff1a; ​我们事先创建好一堆worker线程&#xff0c;主线程accepter拿到一个连接上来的套接字&#xff0c;就从线程池中取出一个…

基于Jenkins自动打包并部署docker、PHP环境,ansible部署-------从小白到大神之路之学习运维第86天

第四阶段提升 时 间&#xff1a;2023年8月23日 参加人&#xff1a;全班人员 内 容&#xff1a; 基于Jenkins部署docker、PHP环境 目录 一、环境部署 &#xff08;一&#xff09;实验环境&#xff0c;服务器设置 &#xff08;二&#xff09;所有主机关闭防火墙和selinu…