[muduo网络库]——muduo库三大核心组件之 Poller/EpollPoller类(剖析muduo网络库核心部分、设计思想)

接着上文,[muduo网络库]——muduo库三大核心组件之Channel类(剖析muduo网络库核心部分、设计思想),本章我们来学习muduo网络库中第二大核心组件Poller/EpollPoller类。
先回顾一下三大核心组件之间的关系。
在这里插入图片描述接着我们进入正题。

Poller/EpollPoller

Poller负责监听文件描述符事件是否触发以及返回发生事件的文件描述符以及具体事件。在 muduo 中,使用抽象基类 Poller ,并由EpollPoller和PollPoller派生基类中继承实现 epoll 和 poll ,但是在我自己重构的muduo库中,仅支持epoll,以后会将poll补充进去。

重要成员变量

int epollfd_;EventList events_;using ChannelMap = std::unordered_map<int,Channel*>;
ChannelMap channels_;EventLoop *ownerLoop_;  
  • epollfd_epollfd_(::epoll_create1(EPOLL_CLOEXEC))返回的epoll句柄。
  • events_ using EventList = std::vector<epoll_event>;中的元素,它为调用epoll_wait返回的事件集合。
  • channels_std::unordered_map<int, Channel*>类型,它主要负责记录 fd —> Channel的映射,也保管所有注册在这个Poller上的Channel。
  • ownerLoop_:就是所属的EventLoop对象

重要成员函数

首先EPollPoller重写了基类Poller的抽象方法

TimeStamp poll(int timeoutMs, ChannelList* activeChannels) override;void updateChannel(Channel* channel) override;void removeChannel(Channel* channel) override;

需要强调的一点: 在EPollPoller重写的抽象方法,首先派生类要继承基类,基类定义为虚函数,且如果派生类在虚函数声明时使用了override描述符,那么该函数必须重载其基类中的同名函数,否则代码将无法通过编译,所以在Poller中,我们可以看出:

virtual TimeStamp poll(int timeoutMs, ChannelList *activeChannel) = 0;virtual void updateChannel(Channel* channel) = 0;virtual void removeChannel(Channel* channel) = 0;

其中poll为重中之重

TimeStamp EPollPoller::poll(int timeoutMs, ChannelList* activeChannels)
{//实际上因为运行起来poll很多,使用LOG_DEBUG更合理,但是学习阶段使用LOG_INFO即可LOG_INFO("func=%s => fd total count:%lu \n",__FUNCTION__, channels_.size());int numEvents= ::epoll_wait(epollfd_, &*events_.begin(),static_cast<int>(events_.size()),timeoutMs);int saveErrno = errno; //记录最开始poll里面的错误值TimeStamp now(TimeStamp::now());if(numEvents>0){LOG_INFO("%d eventS happened \n",numEvents);fillActiveChannels(numEvents,activeChannels);if(numEvents == events_.size()){events_.resize(events_.size() * 2); //说明当前发生的事件可能多于vector能存放的 ,需要扩容,等待下一轮处理}}    else if (numEvents == 0){LOG_DEBUG("%s timeout! \n",__FUNCTION__);}else{if(saveErrno != EINTR) //不是外部中断引起的{errno = saveErrno;LOG_ERROR("EPollPoller::poll() errno!");}}return now;
}
  • 通过epoll_wait将发生事件的channel通过activeChannels告知给EventLoop
TimeStamp EPollPoller::poll(int timeoutMs, ChannelList* activeChannels)

在这个函数中,实际上就是调用了epoll_wait得到了事件发生的集合,然后调用fillActiveChannels

  • 将发生的事件装入activeChannels
void EPollPoller::fillActiveChannels(int numEvents, ChannelList *activeChannels) const
{for(int i=0; i<numEvents; ++i){Channel *channel = static_cast<Channel*>(events_[i].data.ptr);channel->set_revents(events_[i].events);//EventLoop就拿到了他的poller给他返回的所有发生事件的channel列表了activeChannels->push_back(channel);}
}

activeChannelsChannelList = std::vector<Channel*>;类型,将监听到该fd发生的事件写进这个Channel中的revents成员变量中。这样获取到了发生事件的集合,然后把这个Channel装进activeChannels中,当外界调用完poll之后就能拿到事件监听器的监听结果,在EventLoop中就可以对它进行处理。

  • 更新 channel 通道 epoll_ctl add/mod/del
void EPollPoller::updateChannel(Channel* channel) 
{const int index = channel->index();LOG_INFO("func=%s => fd=%d  events=%d index=%d\n",__FUNCTION__, channel->fd(),channel->events(), index);if(index == kNew || index ==kDeleted)//如果是完全没在或者曾经在epoll队列中的,就添加到epoll队列中{if(index == kNew){int fd = channel->fd();channels_[fd] = channel;//将新添加的fd和channel添加到channels_中}channel->set_index(kAdded);update(EPOLL_CTL_ADD,channel);}else //channel 已经在poller上注册过了{int fd = channel->fd();if (channel->isNoneEvent()) //没有到关注的事件{update(EPOLL_CTL_DEL,channel);channel->set_index(kDeleted);}else{update(EPOLL_CTL_MOD,channel);}}
}

在这个函数中,通过判断 index 来决定对channel的修改 mod/add/del,index在channel类中,对其初始化为-1,在这里对应:

const int kNew = -1;       //表示一个channel还没有被添加进epoll里面 channel中index_初始化为-1
const int kAdded = 1;      //表示一个channel已经添加进epoll里面
const int kDeleted = 2;    //表示一个channel已经从epoll里面删除

归根到底,在updateChannel进一步调用了update,然后调用了epoll_ctl,实现了更新channel。同时在removeChannel以及updateChannel中也更改channels_删除/添加,也就是改了Map表。

  • 删除Channel
void EPollPoller::removeChannel(Channel* channel)
{int fd = channel->fd();channels_.erase(fd);LOG_INFO("func=%s => fd=%d  \n",__FUNCTION__, fd);int index = channel->index();if (index == kAdded){update(EPOLL_CTL_DEL,channel);}channel->set_index(kNew);}
  • Poller还存在一个newDefaultPoller函数
static Poller* newDefaultPoller(EventLoop *loop);

通过单独创建一个 DefaultPoller.cc 的文件去实现。在EventLoop中,会调用poller_(Poller::newDefaultPoller(this)),而此函数源码如下:

Poller* Poller::newDefaultPoller(EventLoop *loop)
{if(::getenv("MODUO_USE_POLL")){return nullptr; //生成poll的实例}else{return new EPollPoller(loop); //生成epoll的实例}
}

可以看出,本质是还是调用了EPollPoller。需要强调的一点: muduo库在这里选择了poll还是epoll,这里因为我没有实现poll,所以只能选择EPollPoller。

好了,梳理到这里,我们可以看出经过Poller/EpollPoller, EventLoop就会获得它的poller给他返回的所有发生事件的channel列表了。

实际上,流程是这样的 channel update remove => EventLoop updateChannel removeChannel =>Poller updateChannel removeChannel 在讲到EventLoop时还会在梳理一下。

思考一下,为什么要单独创建一个DefaultPoller.cc文件呢?

我们来回忆一下,newDefaultPoller函数是在poller.h文件中的,如果我们在poller.cc去实现它,从它的实现上可以看出,我们是需要包含 "EPollPoller.h" PollPoller.h等头文件的,但是Poller是一个基类,我们使用EPollPoller派生类去实现它,又在基类中去包含派生类的头文件,这样的设计是非常不好的,所以我们会采用一个单独的文件去实现newDefaultPoller函数。

代码地址:https://github.com/Cheeron955/mymuduo/tree/master

好了~ 有关于muduo库三大核心组件之 Poller/EpollPoller类的细节就到此结束了,不过一个网络库,每一个类之间的联系还是千丝万缕的,所以之后一定是还会提起之前的类的。接下来我们会介绍muduo库三大核心组件之 EventLoop 类,我们下一节见~~

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

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

相关文章

解决VScode -正在本地下载 VS Code 服务器

不知道怎么回事再次连接服务器的时候一直卡在这里了&#xff0c;查看输出信息发现一直卡在下载处&#xff0c;报错信息如图1&#xff0c;输出信息如图2。 1.报错信息 图1 报错信息 图2 输出信息 2.尝试 【已解决】设置SSH主机&#xff1a;VS Code-正在本地下载 VS Code 服务器…

javascript入门基础(一)

js是什么&#xff1a;是一门运行在客户端&#xff08;浏览器&#xff09;的编程语言&#xff0c;实现人机交互的效果 js组成是什么&#xff1a;ECMAScript和web APIs&#xff08;DOM文档对象模型和BOM浏览器对象模型&#xff09; console.log():控制台输出语法&#xff0c;程…

代码随想录算法训练营第二十五天 | 669. 修剪二叉搜索树、108.将有序数组转换为二叉搜索树、538.把二叉搜索树转换为累加树

669. 修剪二叉搜索树 题目链接/文章讲解&#xff1a; 代码随想录 视频讲解&#xff1a; 你修剪的方式不对&#xff0c;我来给你纠正一下&#xff01;| LeetCode&#xff1a;669. 修剪二叉搜索树_哔哩哔哩_bilibili 解题思路 在上一题的删除二叉树节点中&#xff0c;我们通过在…

无线收发模块家电控制实验

zkhengyang可申请加入数字音频系统研究开发交流答疑群(课题组) 当然可以先用固定电平发送&#xff0c;可以实现&#xff0c;0/1数据发送&#xff0c;接收。 可以使用51单片机来编码码&#xff0c;解码&#xff0c;或者任何MCU或者SOC&#xff0c;DSP&#xff0c;FPGA。 注意G…

初识指针(4)<C语言>

前言 前面的文章&#xff0c;已经对指针的基础概念以及运用有了初步了解&#xff0c;我们可以进一步探究指针比较深入的知识&#xff0c;下文将主要介绍&#xff1a;使用指针数组模拟二维数组、字符指针变量、数组指针、二维数组传参的本质、函数指针、typedef关键字等。 目录…

F. Circle Perimeter

思路&#xff1a;线性时间复杂度就可以解决&#xff0c;不用二分&#xff0c;我们枚举横坐标&#xff0c;然后看当前横坐标情况下多少个纵坐标满足条件。 代码&#xff1a; void solve(){int r;cin >> r;int y r, ans 0;for(int x 0;x < r;x ){ //枚举横坐标x&am…

只需3步,使用Stable Diffusion无限生成AI数字人视频(附安装包)

基本方法 搞一张照片&#xff0c;搞一段语音&#xff0c;合成照片和语音&#xff0c;同时让照片中的人物动起来&#xff0c;特别是头、眼睛和嘴。 语音合成 语音合成的方法很多&#xff0c;也比较成熟了&#xff0c;大家可以选择自己方便的&#xff0c;直接录音也可以&#…

Codeforces Round 944 (Div. 4) A - G

div.4只写部分题解了&#xff0c;都比较基础&#xff0c;数学偏多一点&#xff0c;几乎没有算法&#xff0c;有不懂的欢迎评论区提问&#xff01; A. My First Sorting Problem #include<bits/stdc.h> using namespace std ; typedef long long ll ; const int maxn 2…

org.hsqldb.jdbcDriver 类,导致 ClassNotFoundException 异常如何解决?

确保JDBC驱动包存在&#xff1a;检查系统是否已经安装了HSQLDB JDBC驱动。如果没有安装或驱动没有正确放置在类路径中&#xff0c;需要下载并添加它。你可以从 HSQLDB官网 下载JDBC驱动包。 添加JDBC驱动到类路径&#xff1a;将下载的HSQLDB JDBC驱动&#xff08;通常是一个JA…

2024年,Web开发新趋势!

随着我们迈入新的一年&#xff0c;现在正是审视2024年网页开发领域开始流行哪些趋势的绝佳时机。回顾2023年的一系列更新&#xff0c;以下是来年一些热门话题的概览。 自主托管有回归的趋势 近些年&#xff0c;自主托管一直是网页开发者和公司托管其应用程序的默认方式。开发…

【Linux系统编程】第十六弹---冯诺依曼体系结构与操作系统

✨个人主页&#xff1a; 熬夜学编程的小林 &#x1f497;系列专栏&#xff1a; 【C语言详解】 【数据结构详解】【C详解】【Linux系统编程】 目录 1、冯诺依曼体系结构 2、操作系统原理 2.1、什么是操作系统&#xff1f; 2.2、用图解释操作系统 2.3、理解操作系统 总结 …

ES6+新特性-Let、Const与解构赋值

let&#xff1a;let关键字用于声明一个块级作用域的变量。这意味着变量只在声明它的代码块中可见&#xff0c;并且在代码块外不可访问。let声明的变量可以被重新赋值。 示例&#xff1a; {let x 10;console.log(x); // 输出10 } console.log(x); // 报错&#xff0c;x未定义…

C++ ——排序并保留索引

C自带的排序函数sort只能获得排好序的值&#xff0c;没办法像Matlab一样同时返回排序索引。 下面使用c11中的 lambda来为sort函数添加一个模式&#xff1a; #include <iostream> #include <vector> #include <numeric> #include <algorithm> using n…

SSH简介:安全远程访问的基石

在当今高度互联的数字时代&#xff0c;远程访问技术已成为IT运维、云服务管理以及日常开发不可或缺的一部分。SSH&#xff08;Secure Shell&#xff09;协议正是这一领域中最重要、应用最为广泛的工具之一。本文将深入浅出地介绍SSH的基本概念、工作原理、安全特性以及应用场景…

centos7.9系统rabbitmq3.8.5升级为3.8.35版本

说明 本文仅适用rabbitmq为RPM安装方式。 升级准备 查看环境当前版本&#xff1a; # cat /etc/redhat-release CentOS Linux release 7.9.2009 (Core) # rabbitmqctl status Status of node rabbitmq01 ... RuntimeOS PID: 19333 OS: Linux Uptime (seconds): 58 Is under …

在Tiled中制作动画瓦片图

什么是瓦片图&#xff1f;瓦片图是指用图块把游戏场景评出来 工具安装链接&#xff1a;Tiled | Flexible level editor 资源下载教程 资源下载&#xff1a;Mystic Woods - 16x16 Pixel Art Asset Pack by Game Endeavor 解压后得到一些资源 新建图块集合 Tiled的安装就不介绍…

【MySQL】——课程平台的创建设计

&#x1f4bb;博主现有专栏&#xff1a; C51单片机&#xff08;STC89C516&#xff09;&#xff0c;c语言&#xff0c;c&#xff0c;离散数学&#xff0c;算法设计与分析&#xff0c;数据结构&#xff0c;Python&#xff0c;Java基础&#xff0c;MySQL&#xff0c;linux&#xf…

element-plus表单上传,唯一替换文件校验,封装方法统一管理

<el-formref"ruleFormRef":model"ruleForm":rules"rules"label-width"110px" ><el-form-item label"语言成绩材料" prop"languageList"><div class"dis-flex w100"><el-uploadref…

Column ‘xxx‘ not found.

java.sql.SQLException: Column xxx not found.上面的报错&#xff0c;是目标库表没有该字段&#xff0c;一般是访问错库表或者的确没有对应的字段&#xff0c;又或者是一些分布式数据库的从库schema缓存没来得及更新&#xff1b; 本次遇到上面的报错&#xff0c;一开始排查方…

什么是Meme币?——区块链技术的加密货币

Meme代币是一种基于区块链技术的加密货币&#xff0c;旨在为用户提供一种简单、有趣且易于传播的方式来进行数字资产交易和投资。Meme代币通常与特定的主题或故事相关联&#xff0c;通过社交媒体等渠道进行传播和推广&#xff0c;吸引更多的用户参与并增加其价值。 Meme代币的…