基于多反应堆的高并发服务器【C/C++/Reactor】（中）在EventLoop中处理被激活的文件描述符的事件

文件描述符处理与回调函数

一、主要概念

  1. 反应堆模型：一种处理系统事件或网络事件的模型，当文件描述符被激活时，可以检测到
  2. 文件描述符：在操作系统中，用于标识打开的文件、套接字等的一种数据类型 
  3. 处理激活的文件描述符的函数：当文件描述符被激活时，需要有一个函数来处理这些事件
  4. dispatch函数：用于分发或处理不同类型事件的函数
  5. channel结构体：存储与文件描述符相关的事件处理动作的结构体
  6. 回调函数：在初始化channel对象时指定的读回调和写回调，用于处理不同类型的事件
  7. select函数：用于检测多个文件描述符的状态，看是否有数据可读或可写
  8. fd_set集合：用于存储文件描述符的集合，通过宏函数FD_ISSET判断文件描述符是否被触发

二、处理流程

  1. 当反应堆模型启动，检测到被激活的文件描述符
  2. 调用dispatch函数，得到文件描述符fd
  3. 根据fd从channelMap中取出对应的channel，判断是读事件还是写事件
  4. 调用对应的回调函数，处理事件
  5. 在select函数中，通过fd_set集合判断是否有数据可读或可写，调用eventActivate函数处理事件
  6. 在epoll函数中，通过epoll_wait进行检测，遍历返回的events数组，调用eventActivate函数处理事件
  7. 在poll函数中，通过poll进行检测，遍历返回的事件列表,调用eventActivate函数处理事件

三、注意事项

  • 在调用回调函数时，需要传入注册时指定的参数
  • 在使用回调函数时，需要注意处理函数的参数和返回值

四、概括

  • 本文主要介绍了在EventLoop中处理被激活的文件描述符的事件和回调机制
  • 当反应堆模型启动时，可以检测到被激活的文件描述符，并使用dispatch函数获取文件描述符。(EventLoop初始化和启动)
  • 根据文件描述符从ChannelMap中取出对应的channel，判断是读事件还是写事件，并调用相应的回调函数处理

核心观点:

  1. 反应堆模型启动后，可以检测到被激活的文件描述符
  2. 使用dispatch函数获取文件描述符，并根据文件描述符从ChannelMap中取出对应的channel
  3. 根据channel判断是读事件还是写事件，并调用相应的回调函数处理
  4. 在select函数中，通过fd_set集合判断是否有数据可读或可写，调用eventActivate函数处理事件
  5. 在epoll函数中，通过epoll_wait进行检测，遍历返回的events数组，调用eventActivate函数处理事件
  6. 在poll函数中，通过poll进行检测，遍历返回的事件列表,调用eventActivate函数处理事件

>>回顾ChannelMap 模块的实现和Channel 模块的实现

  • Channel.h
// 定义函数指针
typedef int(*handleFunc)(void* arg);
 
// 定义文件描述符的读写事件
enum FDEvent {
    TimeOut = 0x01;
    ReadEvent = 0x02;
    WriteEvent = 0x04;
};
 
struct Channel {
    // 文件描述符
    int fd;
    // 事件
    int events;
    // 回调函数
    handleFunc readCallback;// 读回调
    handleFunc writeCallback;// 写回调
    // 回调函数的参数
    void* arg;
};

 >>在EventLoop中处理被激活的文件描述符的事件

  • EpollLoop.h 
// 处理被激活的文件描述符fd
int eventActivate(struct EventLoop* evLoop,int fd,int event);
  •  EpollLoop.c  
// 处理被激活的文件描述符fd
int eventActivate(struct EventLoop* evLoop,int fd,int event) {
    if(fd < 0 || evLoop == NULL) {+
        return -1;
    }
    // 取出channel
    struct Channel* channel = evLoop->channelMap->list[fd];
    assert(channel->fd == fd);
    if(event & ReadEvent && channel->readCallback) {
        channel->readCallback(channel->arg);
    }
    if(event & WriteEvent && channel->writeCallback) {
        channel->writeCallback(channel->arg);
    }
    return 0;
}

>>回顾Dispatcher模块,Dispatcher模块的实现思路和定义 ，补充代码

  • SelectDispatcher.c  
static int selectDispatch(struct EventLoop* evLoop,int timeout) {
    struct SelectData* data = (struct SelectData*)evLoop->dispatcherData;
    struct timeval val;
    val.tv_sec = timeout;
    val.tv_usec = 0;
    fd_set rdtmp = data->readSet;
    fd_set wrtmp = data->writeSet;
    int count = select(Max,&rdtmp,&wrtmp,NULL,&val);
    if(count == -1) {
        perror("select");
        exit(0);
    }
    for(int i=0;i<Max;++i) { 
        if(FD_ISSET(i,&rdtmp)) {
            // 已续写...
            eventActivate(evLoop,i,ReadEvent);
        }
        if(FD_ISSET(i,&wrtmp)) {
            // 已续写...
            eventActivate(evLoop,i,WriteEvent);
        }
    }
    return 0;
}
  • PollDispatcher.c  
static int pollDispatch(struct EventLoop* evLoop,int timeout) {
    struct PollData* data = (struct PollData*)evLoop->dispatcherData;
    int count = poll(data->fds,data->maxfd + 1,timeout * 1000);
    if(count == -1) {
        perror("poll");
        exit(0);
    }
    for(int i=0;i<=data->maxfd;++i) {
        if(data->fds[i].fd == -1) {
            continue;
        }
        if(data->fds[i].revents & POLLIN) {
            // 已续写...
            eventActivate(evLoop,data->fds[i].fd,ReadEvent);
        }
        if(data->fds[i].revents & POLLOUT) {
            // 已续写...
            eventActivate(evLoop,data->fds[i].fd,WriteEvent);
        }
    }
    return 0;
}
  • EpollDispatcher.c  
static int epollDispatch(struct EventLoop* evLoop,int timeout) {
    struct EpollData* data = (struct EpollData*)evLoop->dispatcherData;
    int count = epoll_wait(data->epfd,data->events,Max,timeout * 1000);
    for(int i=0;i<count;++i) {
        int events = data->events[i].events;
        int fd = data->events[i].data.fd;
        if(events & EPOLLERR || events & EPOLLHUP) {
            // 对方断开了连接，删除 fd
            // epollRemove(&evLoop->channels[fd],evLoop);
            continue;
        }
        if(events & EPOLLIN) {
            // 已续写...
            eventActivate(evLoop,fd,ReadEvent);
        }
        if(events & EPOLLOUT) {
            // 已续写...
            eventActivate(evLoop,fd,WriteEvent);
        }
    }
    return 0;
}

五、回顾select函数、poll函数、epoll_wait函数(CodeGeex生成)

  • select函数

Linux 中的 select 函数主要用于等待多个文件描述符(fd)就绪,从而可以一次性处理多个文件描述符。select 函数会检查指定的文件描述符是否就绪,如果其中任何一个是就绪的,则 select 函数返回。select 函数的原型为:

#include <sys/select.h>
int select(int nfds,fd_set *readfds,fd_set *writefds,fd_set *exceptfds,const struct timeval *timeout);

其中,nfds 表示要检查的文件描述符数量,readfds、writefds 和 exceptfds 分别表示要检查的读、写和异常文件描述符集合,timeout 表示等待的时间限制。

例如,下面代码等待两个文件描述符(fd)就绪,最多等待 5 秒钟:

int fd1 = open("file1", O_RDONLY);
int fd2 = open("file2", O_RDONLY);

fd_set readfds;
FD_ZERO(&readfds);
FD_SET(fd1, &readfds);
FD_SET(fd2, &readfds);

struct timeval timeout;
timeout.tv_sec = 5;
timeout.tv_usec = 0;

int ret = select(2, &readfds, NULL, NULL, &timeout);

if (ret > 0) {
   if (FD_ISSET(fd1, &readfds)) {
       // fd1 is ready to read
   }
   if (FD_ISSET(fd2, &readfds)) {
       // fd2 is ready to read
   }
}
  • poll函数

Linux 中的 poll 函数与 select 函数类似,用于等待多个文件描述符就绪,但是 poll 函数返回的是一个事件列表,而不是像 select 函数那样返回就绪的文件描述符数量。poll 函数的原型为:

#include <poll.h>
int poll(struct pollfd *fds, nfds_t nfds, int timeout);

其中,fds 是一个 pollfd 结构数组,每个结构中包含一个文件描述符和一个事件掩码,timeout 表示等待的时间限制。

例如,下面代码使用 poll 函数等待两个文件描述符(FD)就绪,最多等待 5 秒钟:

int fd1 = open("file1", O_RDONLY);
int fd2 = open("file2", O_RDONLY);

struct pollfd fds[2];
fds[0].fd = fd1;
fds[0].events = POLLIN;
fds[1].fd = fd2;
fds[1].events = POLLIN;

int timeout = 5000; // 5 秒

int ret = poll(fds, 2, timeout);

if (ret > 0) {
  if (fds[0].revents & POLLIN) {
      // fd1 is ready to read
  }
  if (fds[1].revents & POLLIN) {
      // fd2 is ready to read
  }
}

如果 poll 函数返回 0,则表示超时,如果返回值大于 0,则表示有文件描述符就绪。与 select 函数不同的是,poll 函数返回的是一个事件列表,而不是具体的文件描述符。

  • epoll函数

Linux 中的 epoll 函数是 Linux 2.6.8 引入的一个新的 I/O 模型,它提供了高效的 I/O 事件通知机制,能够处理大量文件描述符,并且具有低延迟和高吞吐量的优点。

epoll 函数的原型为:

#include <sys/epoll.h>
int epoll_create(int size);
int epoll_ctl(int epoll_fd, int op, int fd, int event);
int epoll_wait(int epoll_fd, struct epoll_event *events, int maxevents, int timeout);

其中,epoll_create 函数用于创建一个 epoll 实例,size 参数指定要创建的 epoll 实例可以容纳的最大文件描述符数量。epoll_ctl 函数用于控制 epoll 实例,op 参数指定要进行的操作(例如,添加、修改或删除文件描述符),fd 参数指定要操作的文件描述符,event 参数指定要设置的事件掩码。epoll_wait 函数用于等待 epoll 实例中的文件描述符就绪,events 参数指向一个 epoll_event 结构数组,用于存储就绪的文件描述符和事件信息,maxevents 参数指定最多等待的文件描述符数量,timeout 参数指定等待的时间限制。

例如,下面代码使用 epoll 函数等待两个文件描述符(fd)就绪,最多等待 5 秒钟:

int fd1 = open("file1", O_RDONLY);
int fd2 = open("file2", O_RDONLY);

int epoll_fd = epoll_create(10);

struct epoll_event event;
event.events = EPOLLIN;
event.data.fd = fd1;

int ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd1, &event);

event.data.fd = fd2;
ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd2, &event);

struct epoll_event events[2];
int timeout = 5000; // 5 秒

int num = epoll_wait(epoll_fd, events, 2, timeout);

if (num > 0) {
 if (events[0].data.fd == fd1 && events[0].events & EPOLLIN) {
     // fd1 is ready to read
 }
 if (events[1].data.fd == fd2 && events[1].events & EPOLLIN) {
     // fd2 is ready to read
 }
}

如果 epoll 函数返回 0,则表示超时,如果返回值大于 0,则表示有文件描述符就绪。与 select 和 poll 函数不同的是,epoll 函数能够处理大量的文件描述符,并且具有低延迟和高吞吐量的优点

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

k8s中ConfigMap详解及应用

k8s中ConfigMap详解及应用

一、ConfigMap概述 ConfigMap是k8s的一个配置管理组件&#xff0c;可以将配置以key-value的形式传递&#xff0c;通常用来保存不需要加密的配置信息&#xff0c;加密信息则需用到Secret&#xff0c;主要用来应对以下场景&#xff1a; 使用k8s部署应用&#xff0c;当你将应用配置…
阅读更多...
DrGraph原理示教 - OpenCV 4 功能 - 二值化

DrGraph原理示教 - OpenCV 4 功能 - 二值化

二值化&#xff0c;也就是处理结果为0或1&#xff0c;当然是针对图像的各像素而言的 1或0&#xff0c;对应于有无&#xff0c;也就是留下有用的&#xff0c;删除无用的&#xff0c;有用的部分&#xff0c;就是关心的部分 在图像处理中&#xff0c;也不仅仅只是1或0&#xff0c;…
阅读更多...
docker安装postgresql15或者PG15

docker安装postgresql15或者PG15

1. 查询版本 docker search postgresql docker pull postgres:15.3 # 也可以拉取其他版本2.运行容器并挂载数据卷 mkdir -p /data/postgresql docker run --name postgres \--restartalways \-e POSTGRES_PASSWORDpostgresql \-p 5433:5432 \-v /data/postgresql:/var/lib/p…
阅读更多...
工业制造领域，折弯工艺如何进行优化？

工业制造领域，折弯工艺如何进行优化？

若将消费互联网与工业互联网相比较&#xff0c;消费互联网就好似一片宽度为1000米、深度仅有1米的水域&#xff0c;而工业互联网则类似于宽度有1000米、深达10000米的海域。消费互联网因为被限制了深度&#xff0c;便只能在浅显的焦虑中创造出一种消费趋势。相较之下&#xff0…
阅读更多...
数据库迁移工具包：DBSofts ESF Database Migration Crack

数据库迁移工具包：DBSofts ESF Database Migration Crack

ESF 数据库迁移工具包 - 11.2.17 允许您通过 3 个步骤在各种数据库格式之间迁移数据&#xff0c;无需任何脚本&#xff01; DBSofts ESF Database Migration它极大地减少了与以下任何数据库格式之间迁移的工作量、成本和风险&#xff1a;Oracle、MySQL、MariaDB、SQL Server、…
阅读更多...
（15）Linux 进程创建与终止函数forkslab 分派器

（15）Linux 进程创建与终止函数forkslab 分派器

前言&#xff1a;本章我们主要讲解进程的创建与终止&#xff0c;最后简单介绍一下 slab 分派器。 一、进程创建&#xff08;Process creation&#xff09; 1、分叉函数 fork 在 中&#xff0c; fork 函数是非常重要的函数&#xff0c;它从已存在进程中创建一个新的进程。 …
阅读更多...
html引入react以及hook的使用

html引入react以及hook的使用

html引入react 效果代码注意 效果 分享react demo片段的时候&#xff0c;如果是整个工程项目就有点太麻烦了&#xff0c;打开速度慢&#xff0c;文件多且没必要&#xff0c;这个时候用html就很方便。 在html中能正常使用useState 和 useEffect 等hook。 代码 <!DOCTYPE htm…
阅读更多...
助力成长的开源项目 —— 筑梦之路

助力成长的开源项目 —— 筑梦之路

闯关式 SQL 自学&#xff1a;sql-mother 免费的闯关式 SQL 自学教程网站&#xff0c;从 0 到 1 带大家掌握常用 SQL 语法&#xff0c;目前一共有 30 多个关卡&#xff0c;希望你在通关的时候&#xff0c;变身为一个 SQL 高手。除了闯关模式之外&#xff0c;这个项目支持自由选…
阅读更多...
Redis（二）数据类型

Redis（二）数据类型

文章目录 官网备注十大数据类型StringListHashSetZSetBitmapHyperLogLog&#xff1a;GEOStreamBitfield 官网 英文&#xff1a;https://redis.io/commands/ 中文&#xff1a;http://www.redis.cn/commands.html 备注 命令不区分大小写&#xff0c;key区分大小写帮助命令help…
阅读更多...
阿里云服务器开放端口Oracle 1521方法教程

阿里云服务器开放端口Oracle 1521方法教程

阿里云服务器ECS端口是在安全组设置的&#xff0c;Oracle数据库1521端口号开放是在安全组中添加规则来实现的&#xff0c;阿里云服务器网aliyunfuwuqi.com来详细说下阿里云服务器开放Oracle 1521端口方法教程&#xff1a; 阿里云服务器开放Oracle 1521端口 在阿里云服务器ECS…
阅读更多...
前端Web系统架构设计

前端Web系统架构设计

文章目录 1.目录结构定义2. 路由封装2.1 API路由定义2.2 组件路由定义 3. Axios请求开发4. 环境变量封装5. storage模块封装(sessionStorage, localStorage)6. 公共函数封装(日期,金额,权限..)7. 通用交互定义(删除二次确认,类别,面包屑...)8. 接口全貌概览 1.目录结构定义 2. …
阅读更多...
mysql 单表 操作 最大条数验证 以及优化

mysql 单表 操作 最大条数验证 以及优化

1、背景 开车的多年老司机&#xff0c;是不是经常听到过&#xff0c;“mysql 单表最好不要超过 2000w”,“单表超过 2000w 就要考虑数据迁移了”&#xff0c;“你这个表数据都马上要到 2000w 了&#xff0c;难怪查询速度慢”。 2、实验 实验一把看看… 建一张表 CREATE TABL…
阅读更多...
机器学习-基于Word2vec搜狐新闻文本分类实验

机器学习-基于Word2vec搜狐新闻文本分类实验

机器学习-基于Word2vec搜狐新闻文本分类实验 实验介绍 Word2vec是一群用来产生词向量的相关模型&#xff0c;由Google公司在2013年开放。Word2vec可以根据给定的语料库&#xff0c;通过优化后的训练模型快速有效地将一个词语表达成向量形式&#xff0c;为自然语言处理领域的应…
阅读更多...
STC进阶开发（三）蜂鸣器、RTC时钟、I2C总线、外部中断、RTC闹钟设置、RTC计时器设置

STC进阶开发（三）蜂鸣器、RTC时钟、I2C总线、外部中断、RTC闹钟设置、RTC计时器设置

前言 这一期我们首先学习如何让蜂鸣器响起来&#xff0c;并且如何让蜂鸣器发出简单的歌曲&#xff0c;然后我们介绍RTC时钟&#xff0c;要想明白RTC时钟&#xff0c;我们还需要先介绍I2C总线和外部中断。接下来就开始这一期的学习吧&#xff01; 蜂鸣器 简单介绍 蜂鸣器是一种…
阅读更多...
论文笔记：CellSense: Human Mobility Recovery via Cellular Network Data Enhancement

论文笔记：CellSense: Human Mobility Recovery via Cellular Network Data Enhancement

1 intro 1.1 背景 1.1.1 蜂窝计费记录&#xff08;CBR&#xff09; 人类移动性在蜂窝网络上的研究近些年得到了显著关注&#xff0c;这主要是因为手机的高渗透率和收集手机数据的边际成本低蜂窝服务提供商收集蜂窝计费记录&#xff08;CBR&#xff09;用于计费目的&#xf…
阅读更多...
哲学家进餐问题-第三十二天

哲学家进餐问题-第三十二天

目录 问题描述 解决问题 结论 问题描述 解决问题 1、 关系分析&#xff1a;找出题目中描述的各个进程&#xff0c;分析它们之间的同步、互斥关系 系统中有5个哲学家进程&#xff0c;5位哲学家与左右邻居对其中间筷子的访问是互斥关系 2、整理思路&#xff1a;根据各进程的操…
阅读更多...
ubuntu terminator 非常好用的护眼配置

ubuntu terminator 非常好用的护眼配置

安装 sudo apt install terminator 配置文件&#xff1a;sudo gedit ~/.config/terminator/config &#xff08;如果没有就创建&#xff09; 配置如下&#xff1a; [global_config] handle_size -3 title_transmit_fg_color "#000000" title_trans…
阅读更多...
KBDNO1.DLL文件缺失，软件或游戏无法启动运行，怎样快速修复

KBDNO1.DLL文件缺失，软件或游戏无法启动运行，怎样快速修复

不少小伙伴&#xff0c;求助电脑报错“KBDNO1.DLL文件缺失&#xff0c;软件或游戏无法启动或运行”&#xff0c;应该怎么办&#xff1f; 首先&#xff0c;我们先来了解“KBDNO1.DLL文件”是什么&#xff1f; KBDNO1.DLL是Windows操作系统中的一个动态链接库文件&#xff0c;主…
阅读更多...
Java基础进阶（学习笔记）

Java基础进阶（学习笔记）

注&#xff1a;本篇的代码和PPT图片来源于黑马程序员&#xff0c;本篇仅为学习笔记 static static 是静态的意思&#xff0c;可以修饰成员变量&#xff0c;也可以修饰成员方法 修饰成员的特点&#xff1a; 被其修饰的成员, 被该类的所有对象所共享 多了一种调用方式, 可以通过…
阅读更多...
MACOS Atrust服务异常

MACOS Atrust服务异常

MAC版Atrust服务异常 点击进入办公后出现提示其一&#xff1a; 核心服务未启动&#xff0c;部分功能存在异常&#xff0c;确定重新启动吗&#xff1f; 可能的原因&#xff1a; 1.上次已完全退出客户端 2.核心服务被其他程序优化禁用 点击重新启动后&#xff0c;出现提示&#x…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站