Reactor 模型 和 Proactor 模型

在网络IO设计中,有两种高性能模型:Reactor模型和Proactor模型。

Reactor基于同步IO模式,Proactor基于异步IO模式。

不过,无论是 Reactor,还是 Proactor,都是一种基于「事件分发」的网络编程模式,区别在于 Reactor 模式是基于「待完成」的 I/O 事件,而 Proactor 模式则是基于「已完成」的 I/O 事件。

一、Reactor

Reactor模型主要就是监听事件分发事件处理事件。其中Reactor角色会负责监听事件 和分发事件Handler角色和Acceptor角色会负责处理事件

Netty网络框架,Redis等中间件中都有使用到Reactor模型。

1.单 Reactor 单线程(Redis使用)

 Java 语言实现的是「单 Reactor 单线程」的方案,因为 Java 程序是跑在 Java 虚拟机这个进程上面的,虚拟机中有很多线程,我们写的 Java 程序只是其中的一个线程而已。

优点

  • 将所有处理逻辑放在一个线程中实现,没有多线程通信、竞争的问题。

缺点

  • 一个 Reactor 既要负责处理连接请求,又要负责处理读写请求,在面对瞬间高并发的场景时,容易成为性能的瓶颈的地方
  • 一旦 Reactor 线程意外中断或者进入死循环,会导致整个系统通信模块不可用。
  • 只有一个线程在工作,处理效率低,无法利用多核CPU的优势。
  • Handler 对象在业务处理时,整个线程是无法处理其他连接的事件的。

2.单 Reactor 多线程

优点

  • 多线程模式可以充分利用 多核CPU 的性能。

缺点

  • 单 Reactor 存在两个的问题(同上)。
  • Handler 使用多线程模式,自然带来了多线程竞争资源的开销,同时涉及共享数据的互斥和保护机制,实现比较复杂。(例如,子线程完成业务处理后,要把结果传递给主线程的 Handler 进行发送,这里涉及共享数据的竞争)

3.主从 Reactor 多线程(Netty使用)

思考:为什么一个Reactor同时监听连接事件和处理读写事件是不好的?

  1. 一般来说处理连接请求是很快的,但处理读写请求时涉及到业务逻辑处理,相对慢很多。所以 Reactor 在处理读写请求时,其他请求只能等着,容易造成系统的性能瓶颈。
  2. 客户端连接的建立是不频繁的,但是连接建立后数据的收发是频繁的,所以如果能够将处理读写事件这个动作拆分出来,让多个子Reactor处理读写事件,而原来的主Reactor只监听连接事件,那么整体的效率,会进一步提升,而这,就是主从Reactor多线程模型。

主线程中的 MainReactor 对象通过 select 监控连接建立事件,收到事件后通过 Acceptor 对象中的 accept 获取连接,将新的连接分配给某个子线程;

子线程中的 SubReactor 对象将 MainReactor 对象分配的连接加入 select 继续进行监听,并创建一个 Handler 用于处理连接的响应事件。

优点

  • 主线程和子线程分工明确,主线程只负责接收新连接,子线程负责完成后续的业务处理。
  • 主线程和子线程的交互也很简单,子线程接收主线程的连接后,只管业务处理即可,无须关注主线程,可以直接在子线程将处理结果发送给客户端。
  • 适用于高并发场景。

二、Proactor

关于同步与异步的概念,大家可以看这篇:

最清楚的 BIO、NIO、AIO 详解!-CSDN博客

现在我们再来理解 Reactor 和 Proactor 的区别,就比较清晰了。

  • Reactor 是非阻塞同步网络模式,感知的是就绪可读写事件。在每次感知到有事件发生(比如可读就绪事件)后,就需要应用进程主动调用 read 方法来完成数据的读取,也就是要应用进程主动将 socket 接收缓存中的数据读到应用进程内存中,这个过程是同步的,读取完数据后应用进程才能处理数据
  • Proactor 是异步网络模式, 感知的是已完成的读写事件。在发起异步读写请求时,需要传入数据缓冲区的地址(用来存放结果数据)等信息,这样系统内核才可以自动帮我们把数据的读写工作完成,这里的读写工作全程由操作系统来做,并不需要像 Reactor 那样还需要应用进程主动发起 read/write 来读写数据,操作系统完成读写工作后,就会通知应用进程直接处理数据

因此,Reactor 可以理解为「来了事件操作系统通知应用进程,让应用进程来处理」,而 Proactor 可以理解为「来了事件操作系统来处理,处理完再通知应用进程」。这里的「事件」就是有新连接、有数据可读、有数据可写的这些 I/O 事件这里的「处理」包含从驱动读取到内核以及从内核读取到用户空间。

无论是 Reactor,还是 Proactor,都是一种基于「事件分发」的网络编程模式,区别在于 Reactor 模式是基于「待完成」的 I/O 事件,而 Proactor 模式则是基于「已完成」的 I/O 事件

介绍一下 Proactor 模式的工作流程:

  • Proactor Initiator 负责创建 Proactor 和 Handler 对象,并将 Proactor 和 Handler 都通过 Asynchronous Operation Processor 注册到内核;
  • Asynchronous Operation Processor 负责处理注册请求,并处理 I/O 操作;
  • Asynchronous Operation Processor 完成 I/O 操作后通知 Proactor;
  • Proactor 根据不同的事件类型回调不同的 Handler 进行业务处理;
  • Handler 完成业务处理;

三、参考

9.3 高性能网络模式:Reactor 和 Proactor | 小林coding (xiaolincoding.com)

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

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

MOZHE SQL手工注入漏洞测试(MySQL数据库)

主界面URL没有参数,无法判断是否有注入点 点击公告 【浏览器不便于查看返回包可以用burp】 测试URL 参数后加上单引号,报错,说明存在注入点 http://124.70.64.48:40021/new_list.php?id1 获取表列数 order by 4 返回200 order by 5 …

怎样在 Nginx 中配置基于请求客户端输入方式的路由?

🍅关注博主🎗️ 带你畅游技术世界,不错过每一次成长机会! 文章目录 怎样在 Nginx 中配置基于请求客户端输入方式的路由一、Nginx 路由的基础概念二、理解客户端输入方式三、基于用户代理的路由配置四、基于请求头的路由配置五、基…

MATLAB基础:数组及其数学运算

今天我们继续学习MATLAB中的数组 我们在学习MATLAB时了解到,MATLAB作者秉持着“万物皆可矩阵”的思想企图将数学甚至世间万物使用矩阵表示出来,而矩阵的处理,自然成了这门语言的重中之重。 数组基础 在MATLAB中,数组是一个基本…

【Android】碎片—动态添加、创建Fragment生命周期、通信

简单用法 在一个活动中添加两个碎片&#xff0c;并让这两个碎片平分活动空间 先新建一个左侧碎片布局和一个右侧碎片布局 左侧碎片 <?xml version"1.0" encoding"utf-8"?> <LinearLayout xmlns:android"http://schemas.android.com/apk/…

Energizer锂电池系列之一的CR2032系列产品介绍

Energizer 的CR2032系列产品是锂纽扣电池&#xff0c;其能量密度高于传统电池。该系列于 2009 年发布&#xff0c;至今仍是最受欢迎的锂电池系列之一。虽然不可充电&#xff0c;但它们的保质期很长&#xff0c;可承受 -30C 至 65C 的环境温度。该系列的一些重要事实包括&#x…

纯电SUV又一个卷王,比亚迪都没它狠

文 | AUTO芯球 作者 | 雷慢 太狠了&#xff0c;就在刚刚&#xff0c; 我劝阻了一个高中同学暂时不要买宋PLUS纯电版&#xff0c; 因为又一个新能源卷王出现了&#xff0c; 在卷价格上&#xff0c;宋PLUS都没它狠。 不信你们看&#xff0c;埃安V第二代刚发布&#xff0c; …

搜维尔科技:scalefit-实时可视化人体工程学评估和直观报告

实时人体工程学评估和直观报告 使用Xsens Ergo Live体验动态人体工程学评估&#xff0c;并进行实时分析和直观报告-具有 Xsens 动作捕捉技术和 scalefit 的 Industrial Athlete。进行实时评估&#xff0c;轻松解释数据&#xff0c;并在 Excel 中生成快速、有见地的报告&#x…

视频编辑处理SDK,助力企业快速响应市场变化

视频已成为企业传播信息、展示品牌、连接用户的重要桥梁&#xff0c;如何在快节奏的市场竞争中&#xff0c;快速制作出高质量、富有创意的视频内容&#xff0c;成为众多企业面临的共同挑战。美摄科技&#xff0c;作为视频编辑处理技术的领航者&#xff0c;携其强大的视频编辑处…

Android 中如何设置activity的启动动画,让它像dialog一样从底部往上出来

本文首发于公众号“AntDream”&#xff0c;欢迎微信搜索“AntDream”或扫描文章底部二维码关注&#xff0c;和我一起每天进步一点点 在 Android 中&#xff0c;你可以通过定义自定义的动画资源并在启动和结束 Activity 时应用这些动画&#xff0c;实现类似对话框从底部向上进入…

Linux并发程序设计(3):守护进程

目录 前言 一、介绍 1.1 概念 1.2 特点 1.3 举例 二、系统编程 2.1 setsid函数 2.2 getpid函数 2.3 getsid函数 2.4 getpgid函数 2.5 chdir函数 三、代码例程 3.1 使子进程在后台运行 3.2 使子进程脱离原终端 3.3 更换目录&#xff0c;并设定权限&#xff08;非…

noVNC使用与介绍

noVNC使用与介绍报告 1. 概述 VNC&#xff08;Virtual Network Console&#xff0c;虚拟网络控制台&#xff09;是一种流行的远程桌面访问协议&#xff0c;它允许用户通过网络连接到远程计算机的图形界面。VNC协议的实现通常包括两个主要组件&#xff1a;服务器端&#xff08…

【Python】 基于Q-learning 强化学习的贪吃蛇游戏(源码+论文)【独一无二】

&#x1f449;博__主&#x1f448;&#xff1a;米码收割机 &#x1f449;技__能&#x1f448;&#xff1a;C/Python语言 &#x1f449;公众号&#x1f448;&#xff1a;测试开发自动化【获取源码商业合作】 &#x1f449;荣__誉&#x1f448;&#xff1a;阿里云博客专家博主、5…

java.lang.ThreadLocal

ThreadLocal万字总结https://blog.csdn.net/sinat_33921105/article/details/103295070 key的唯一性 一个线程中的多个ThreadLocal变量如何存储、如何保证唯一性&#xff1f; 每一个 ThreadLocal<T> tl new ThreadLocal<>(); 创建出来都有一个不变且唯一的thre…

vue-plugin-hiprint 打印 预览打印+静默打印

1.安装 npm install vue-plugin-hiprint npm i socket.io-client --save //为了静默打印 &#xff08;为此还需安装客户端&#xff09; 2…html页面 引入css <link rel"stylesheet" type"text/css" media"print" href"https://cdn.jsde…

新手做短视频素材在哪里找?做短视频素材工具教程网站有哪些?

新手短视频制作指南&#xff1a;从零开始&#xff0c;快速成为短视频达人 蛙学网&#xff1a;新手短视频制作的首选平台 作为短视频制作新手&#xff0c;你是否在寻找合适的素材和工具来打造令人眼前一亮的作品&#xff1f;不用担心&#xff0c;蛙学网作为国内领先的素材平台&…

远程割草机行业全景剖析与投资前瞻预测:未来六年年复合增长率CAGR为7.8%

一、市场趋势分析 随着科技的进步和生活节奏的加快&#xff0c;远程割草机行业迎来了快速发展期。消费者对于省时省力的自动化园艺工具的需求推动了这一行业的增长。数据显示&#xff0c;远程割草机提供了更为安全、高效和环保的草坪维护解决方案。预计未来几年&#xff0c;随…

react小程序分包(遇见的坑)

使用的是taro组件 pages是原文件&#xff0c;分包文件夹是package 为了减少修改路径直接复制的pages的文件夹 第一个坑&#xff1a; 我做了分包&#xff0c;没有build打包导致没有生效&#xff08;所以需要build一下再dist里面生成分包的文件&#xff09; 第二个坑——路由…

C++笔记---缺省参数和函数重载

1. 缺省参数 1.1 定义 缺省参数是声明或定义函数时为函数的参数指定一个缺省值&#xff08;默认值&#xff09;。在调用该函数时&#xff0c;如果没有指定实参 则采用该形参的缺省值&#xff0c;否则使用指定的实参&#xff0c;缺省参数分为全缺省和半缺省参数。 void Func(…

LwIP入门实战 — 1 计算机网络简述

目录 1 计算机网络类别 2 常用网络协议与协议栈 2.1 常用网络协议 2.2 常用TCP/IP协议栈 3 网络协议的分层模型 4 协议层报文间的封装与拆封 5 WAN接口和LAN接口 1 计算机网络类别 广域网WAN(Wide Area Network)&#xff1a;广域网的作用范围通常为几十到几千公里&…

【用最少数量的箭引爆气球】python刷题记录

R2-贪心篇. 求最小&#xff0c;那就尽可能地假设更多的气球y值不相同咯。 不对&#xff0c;气球除了y值我们随便摆&#xff0c;所以找尽可能多重叠的&#xff0c;就作为同一只箭。 class Solution:def findMinArrowShots(self, points: List[List[int]]) -> int:#贪心策略…