Linux学习笔记(epoll,IO多路复用)

Linux learning note

  • 1、epoll的使用场景
  • 2、epoll的使用方法和内部原理
    • 2.1、创建epoll
    • 2.2、使用epoll监听和处理事件
  • 3、示例

1、epoll的使用场景

epoll的英文全称是extend poll,顾名思义是poll的升级版。常见的IO复用技术有select,poll,epoll三种,本文只介绍epoll。
这里IO多路复用通俗理解是指用一个线程来管理多个输入/输出通道。具体到网络场景中,就是希望服务器只用一个线程就可以处理N个客户端的读写请求。
如果不适用IO多路复用技术,我们当然也可以实现一个服务端和N个客户端之间建立连接,但由于read函数经常被设置为阻塞式的,所以出现这么一种情况:服务器阻塞在客户端1的通道上,而当客户端2发送消息时便无法及时处理。
当然read函数也可以设置为非阻塞式的,不断的扫描哪个客户端发送消息,不过这样就很浪费CPU资源了。
总而言之,epoll在网络通信中几乎是必不可少的一项技术。

2、epoll的使用方法和内部原理

先概况性的讲,epoll是一个管理服务端和多个客户端的工具,当这些设备有“动作”的时候,epoll会通过中断察觉到这些“动作”,并及时去处理。
具体原理如下:

2.1、创建epoll

使用epoll_create()函数创建一个eventpoll的结构体,该结构体又嵌套着许多数据结构,用以维护epoll管理的多个服务器和客户端。其中较为重要的是一个存放服务器和所有客户端的文件描述符的红黑树和一个管理就绪事件的双向链表ready list
在这里插入图片描述
值得注意的是,epoll_create()只是创建eventpoll这么一个数据结构,具体红黑树中的节点的添加和删除需要依靠epoll_ctl()函数来完成。而epoll_ctl()不仅仅添加需要监控的文件描述符,还要添加一个名为epoll_event的结构体,我们可以通过该结构体设置我们需要监听的事件和触发中断的方式。
在这里插入图片描述
监听的事件和触发中断的方式都是通过设置epoll_event中的events这个成员变量来完成的,常规的设置有

struct event_poll ev;
ev.events = EPOLLIN;	//设置监听读事件,如果没有设置触发方式则默认使用水平触发
//or
ev.events = EPOLLIN | EPOLLET;	//设置监听读事件,且边缘触发
  • 水平触发(level triggered):当事件发生之后,一直产生中断,提醒CPU去处理。这也是默认的触发方式。
  • 边缘触发(edge triggered):当事件发生之后,只触发一次中断。

2.2、使用epoll监听和处理事件

这部分就相对简单许多了,无非是在while循环中使用一个epoll_wait()去监听哪一个设备有需要处理的事件。其中epoll_wait()时常被设置成阻塞性函数,即没有事件需要处理的时候就一直阻塞在那。如果有事件需要处理,CPU会把该事件对应的文件描述符放进ready_list,然后通过epoll_wait()函数再将ready_list中的文件描述符对应的设备的事件信息等依次放入epoll_event的队列中来。最后在通过对epoll_event中的文件描述符或事件类型的判断,去决定执行具体的任务。
在这里插入图片描述
可能有点难理解,那再看看代码把。

struct epoll_event events[1024];
int epollfd = epoll_create(1);
/***
A lot of code is omitted here
***/
while(true)
{int nfds = epoll_wait(epollfd, events, 1024, -1);for (int n = 0; n < nfds; ++n) {if (events[n].events & EPOLLIN)		//去处理一个个事件{/******/}}
}

3、示例

该例子完成了一个服务器对多个客户端的连接请求的监控以及对可读事件的回应。

#include <sys/epoll.h>
#include <netinet/in.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <iostream>#define MAX_EVENTS 10
#define READ_SIZE 1024int server_port = 8888;int main() {struct epoll_event ev, events[MAX_EVENTS];struct sockaddr_in addr;char buffer[READ_SIZE];int listen_sock = socket(AF_INET, SOCK_STREAM, 0);memset(&addr, 0, sizeof(addr));addr.sin_family = AF_INET;addr.sin_addr.s_addr = INADDR_ANY;addr.sin_port = htons(server_port);bind(listen_sock, (struct sockaddr*) &addr, sizeof(addr));listen(listen_sock, 5);int epollfd = epoll_create(1);ev.events = EPOLLIN;    ev.data.fd = listen_sock;epoll_ctl(epollfd, EPOLL_CTL_ADD, listen_sock, &ev);int nfds;  while(true) {nfds = epoll_wait(epollfd, events, MAX_EVENTS, -1);for (int n = 0; n < nfds; ++n) {if (events[n].data.fd == listen_sock) {int con_sock = accept(listen_sock, (struct sockaddr *) NULL, NULL);ev.events = EPOLLIN | EPOLLET;ev.data.fd = con_sock;epoll_ctl(epollfd, EPOLL_CTL_ADD, con_sock, &ev);std::cout << "add a new client suessfully!" << std::endl;} else {if (events[n].events & EPOLLIN) {int len  = read(events[n].data.fd, buffer, sizeof(buffer));if(len > 0){std::cout << "server receive is: " << buffer << std::endl;static std::string send_str;send_str.append("receive suessfully!");write(events[n].data.fd, send_str.c_str(), send_str.length());memset(buffer, 0 , sizeof(buffer));send_str.erase(0);} }}}}close(listen_sock);return 0;
}

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

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

相关文章

Photoshop粘贴 lorem-ipsum 占位符文本

Photoshop在使用文字工具的时候&#xff0c;点击画布会自动出现一段英文“Lorem Ipsum”&#xff0c;这是占位文本&#xff0c;除了响应速度慢外&#xff0c;目前我也没发现它有什么太大意义。 那么要如何操作才能取消占位文本的填写呢&#xff1f;在菜单栏点 编辑-首选项-文字…

window 安装 nginx

下载、安装 官网下载地址&#xff1a;https://nginx.org/en/download.html 选择稳定版 在这里插入图片描述

MindSpore实践图神经网络之环境篇

MindSpore在Windows11系统下的环境配置。 MindSpore环境配置大概分为三步&#xff1a;&#xff08;1&#xff09;安装Python环境&#xff0c;&#xff08;2&#xff09;安装MindSpore&#xff0c;&#xff08;3&#xff09;验证是否成功 如果是GPU环境还需安装CUDA等环境&…

JTW结构

JTW(JSON Web Token)的结构 在这篇笔记中,我们将了解JTW(JSON Web Token)的结构。我们将看到JTW是如何创建的,令牌的各个部分是什么,以及您如何自己构建和构造JTW。您还将了解一些这种结构的含义,以及使用JTW进行授权时的一些结果优缺点。 基本上,JTW本质上就是一个…

Android 四大组件 service

前言 在Android系统中&#xff0c;Service 是一个用来执行长时间运行的操作而不提供用户界面的应用组件。它可以在后台执行任务&#xff0c;即使用户切换到其他应用也不会被中断。 Service 在Android中主要用于在后台执行长时间运行的任务&#xff0c;例如播放音乐、执行文件…

机器学习-10-可解释性机器学习库Shapash

可解释性机器学习库Shapash——鸢尾花XGBoost分类解释实现 shapash的GitHub地址 机器学习的可解释性 1 机器学习的可解释性 1.1 可解释性简介 在机器学习的场景中,可解释性(interpretability)就表示模型能够使用人类可认知的说法进行解释和呈现。 机器学习模型被许多人称…

新火种AI|寻求合作伙伴,展开豪赌,推出神秘AI项目...苹果能否突破AI困境?

作者&#xff1a;小岩 编辑&#xff1a;彩云 2024年&#xff0c;伴随着AI技术的多次爆火&#xff0c;不仅各大科技巨头纷纷进入AI赛道展开角力&#xff0c;诸多智能手机厂商也纷纷加紧布局相关技术&#xff0c;推出众多AI手机。作为手机领域的龙头老大&#xff0c;苹果自然是…

学生成绩统计分析系统介绍

学生成绩统计分析系统是一种用于收集、管理和分析学生学业成绩的软件系统。该系统旨在帮助学校和教育机构更好地了解学生的学习情况&#xff0c;进行成绩评估和分析&#xff0c;以支持教学决策和学生发展。学生成绩分析系统 系统专门针对学校/班级成绩管理使用&#xff0c;支持…

F. Longest Strike[双指针详解]

Longest Strike 题面翻译 给你一个长度为 n n n 的序列 a a a 和一个整数 k k k&#xff0c;你要求一个区间 [ l , r ] [l,r] [l,r] 满足&#xff1a; 对于任何整数 x ∈ [ l , r ] x∈[l,r] x∈[l,r]&#xff0c; x x x 在 a a a 中的出现次数不少于 k k k 次。最大…

redis数据类型之Hash,Bitmaps

华子目录 Hash结构图相关命令hexists key fieldhmset key field1 value1 [field2 value2...]hscan key cursor [MATCH pattern] [COUNT count] Bitmaps位图相关命令setbit1. **命令描述**2. **语法**3. **参数限制**4. **内存分配与性能**5. **应用实例**6. **其他相关命令**7.…

19 - grace数据处理 - 补充 - 地下水储量计算过程分解 - 冰后回弹(GIA)改正

19 - grace数据处理 - 补充 - 地下水储量计算过程分解 - 冰后回弹(GIA)改正 0 引言1 gia数据处理过程0 引言 由水量平衡方程可以将地下水储量的计算过程分解为3个部分,第一部分计算陆地水储量变化、第二部分计算地表水储量变化、第三部分计算冰后回弹改正、第四部分计算地下…

07- Redis 中的 HyperLogLog 数据类型和应用场景

1. 介绍 Redis HyperLogLog 是 Redis 2.8.9 版本新增的数据类型&#xff0c;是一种用于【统计基数】的数据集合类型&#xff0c;基数统计就是指统计一个集合中不重复的元素个数。但要注意&#xff0c;HyperLogLog 的统计规则是基于概率完成的&#xff0c;不是非常准确&#xf…

ABAP MD04增强排除MRP元素

场景 MD04跑出来很多MRP元素&#xff0c;用户想手工控制某些MRP元素不参与运算 分析 增强点还蛮好找的&#xff0c;控制MRP元素是否参与运算用下面的se19三代增强点就可以&#xff0c;打个断点看下MD04进的哪个增强点就行 旧版本的用这个&#xff1a;MD_CHANGE_MRP_DATA 新…

《广告数据定量分析》读书笔记之理论/概论

《广告数据定量分析 如何成为一位厉害的广告优化师》 一、理论/概况 1.广告优化中的统计学&#xff1a; &#xff08;1&#xff09;获取推广相关数据&#xff1b; &#xff08;2&#xff09;将数据处理为需要的指标如转化率、roi等进行分析其投放效果&#xff1b; &#x…

flask的一些简要基础问答

1. Flask 中的 blinker&#xff1a; Blinker 是一个用于信号分发的库。在 Flask 中&#xff0c;它主要用于实现事件的发送和接收机制。通过使用 blinker&#xff0c;可以方便地在不同的组件之间进行通信和协调&#xff0c;当特定的事件发生时&#xff0c;可以触发相关的处理函…

NVIDIA Jetson 上编译opencv 4.9.0

直接上命令 cmake .. \ -DCMAKE_C_COMPILER/usr/bin/gcc-7 -DCMAKE_CXX_COMPILER/usr/bin/g-7 \ -DCMAKE_BUILD_TYPERelease \ -DCMAKE_INSTALL_PREFIX/usr/local \ -DOPENCV_ENABLE_NONFREE1 \ -DBUILD_opencv_python21 \ -DBUILD_opencv_python31 \ -DCUDA_TOOLKIT_ROOT_DIR…

C++STL容器系列(三)list的详细用法和底层实现

目录 一&#xff1a;介绍二&#xff1a;list的创建和方法创建list方法 三&#xff1a;list的具体用法3.1 push_back、pop_back、push_front、pop_front3.2 insert() 和 erase()3.3 splice 函数 四&#xff1a;list容器底层实现4.1 list 容器节点结构5.2 list容器迭代器的底层实…

【window 安装 service bus explorer】

安装ServiceBusExplorer 首先需要安装Chocolatey安装 service bus explorer 首先需要安装Chocolatey 参考&#xff1a; https://chocolatey.org/install#install-step2 以管理员身份运行powershell输入Get-ExecutionPolicy回车&#xff0c;若显示 Restricted输入Set-Executio…

CentOS8环境下FTP服务器安装与配置

在本指南中&#xff0c;我们将一步步介绍如何在CentOS 8环境下安装和配置一个FTP服务器。FTP&#xff08;文件传输协议&#xff09;是一种网络传输协议&#xff0c;用于在网络中的计算机之间传输文件。虽然现在有更安全的传输方式&#xff0c;如SFTP或FTP over SSL&#xff0c;…

python -【一】基础语法

python 基础语法 一. 基础数据类型 常用的 6 种数据类型 类型描述说明数字&#xff08;Number&#xff09;int&#xff0c;float&#xff0c;complex(复数)&#xff0c;bool复数&#xff1a;4 3j&#xff0c;j 表示复数字符串&#xff08;String&#xff09;文本&#xff1…