【高级IO】- 多路转接之 poll | epoll


目录

I/O多路转接 - poll

poll 函数

poll 服务器 

poll 服务器

poll 的优点

poll 的缺点

I/O 多路转接 - epoll

epoll 的相关系统调用

epoll_create 函数

epoll_ctl 函数

epoll_wait 函数 

epoll 工作原理 

epoll 服务器

​编辑 epoll 的优点(与 select 的缺点对应)

select、poll 和 epoll 的不同之处

epoll 的工作方式

水平触发(Level Triggered,LT) 

边缘触发(Edge Triggered,ET)

  ET 工作模式下如何进行读写


I/O多路转接 - poll

• poll 系统调用也可以让程序同时监视多个文件描述符上的事件是否就绪,和 select 的定位是一样的,适用场景也是一样的。

poll 函数

参数说明:

• fds:表示监视的结构列表,每一个元素包含三个部分内容,文件描述符,监视的事件集合,就绪的事件集合

• nfds:表示 fds 数组的长度

• timeout:表示poll 函数的超时事件,单位是毫秒(ms)

timeout 的取值:

• -1:poll 调用后进行阻塞等待,直到某个被监视的文件描述符上的某个事件就绪

• 0:poll 调用后进行非阻塞等待,无论被监视的文件描述符上的事件是否就绪,poll 检测后立马返回

• 特定的时间值:poll 调用后在指定的时间内进行阻塞等待,如果被监视的文件描述符上一直没有事件就绪,则在该时间后 poll 进行超时返回

poll 返回值说明:

• 如果函数调用成功,则返回有事件就绪的文件描述符的个数

• 如果 timeout 时间耗尽,则返回0

• 如果函数调用失败,则返回 -1,同时错误码被设置,可能会被设置为如下:

( • EFAULT:fds 数组不包含在调用程序的地址空间中

    • EINTR:此调用被信号所中断

    • EINVAL:nfds 值超过RLIMIT_NOFILE 值

    • ENOMEM:核心内存不足 )

struct pollfd 结构:

• fd:特定的文件描述符,若设置为负值,则忽略events字段,并且revents字段返回0

• events:需要监视的文件描述符上的哪些事件

• revents:poll 函数返回时告知用户该文件描述符上的哪些事件已经就绪

 

events 和 revents 的取值:

事件描述是否可作为输入是否可作为输出
POLLIN数据(包括普通数据和优先数据)可读
POLLRDNORM普通数据可读
POLLRDBAND优先级带数据可读(Linux不支持)
POLLPRI高优先级数据可读,比如TCP带外数据
POLLOUT数据(包括普通数据和优先数据)可读
POLLWRNORM普通数据可写
POLLWRBAND优先级带数据可写
POLLRDHUPTCP连接被对方关闭,或者对方关闭了写操作,它由GNU引入
POLLERR错误
POLLHUP挂起,比如管道的写端被关闭后,读端描述符上将收到POLLHUP事件
POLLNVAL文件描述符没有打开

这些取值实际上都是以宏的方式进行定义的,二进制序列当中只要一个比特位是1,且1的位置各不相同:

• 在调用 poll 函数之前,将要监视的事件设置进入到 events 成员中

• poll 函数返回后,可以通过运算符检测在 revents 成员中是否包含特定的事件,得知对应的描述符的特定事件是否就绪


poll 服务器 

该服务器也只是读取客户端发来的数据然后进行打印即可,成员变量需要包含监听套接字和端口号这两个,服务器绑定时将IP地址设置为 INADDR_ANY(之前对Sock操作等进行了封装)。

• 在初始化 poll 服务器的时候,依次进行套接字的创建,绑定,监听等工作

• 析构函数中,可以选择调用 close 函数对监听套接字等进行关闭

#pragma once
#include <iostream>
#include <string>
#include <unistd.h>
#include <sys/time.h>
#include <sys/types.h>
#include <functional>
#include <poll.h>#include "sock.hpp"class pollServer{public:pollServer(func_t f, int port): _func(f), _listensock(-1), _port(port){}~pollServer(){if (_listensock){close(_listensock);}if (_rfds){delete[] _rfds;}}private:int _port;int _listensock;};

初始化及运行服务器

• 在 poll 服务器运行之前,先初始化服务器,定义一个 fds 结构体数组,该数组中的每个位置都是一个struct pollfd 结构,先将每个位置初始化为无效,并将监听套接字添加到 fds 数组中,服务器开始运行时,只需要监视监听套接字的读事件即可。

• 运行服务器,不断调用 poll 函数监视读事件是否就绪,如果 poll 函数的返回值大于0,则说明 poll 函数调用成功,此时已经有文件描述符的读事件就绪了,接下来就是对就绪事件的处理逻辑;返回值等于0,说明 timeout 时间耗尽,超时了,继续进行下一次的 poll 调用即可,返回值为-1,说明 poll 调用失败,根据错误码进一步判断是否继续调用 poll 函数。

        void pollInit(int pos){_rfds[pos].fd = defaultnum;_rfds[pos].events = 0;_rfds[pos].revents = 0;}void InitServer(){_listensock = Sock::Socket();Sock::Bind(_listensock, _port);Sock::Listen(_listensock);_rfds = new struct pollfd[num];for (int i = 0; i < num; i++){pollInit(i);}// 第一个位置添加为 _listensock套接字_rfds[0].fd = _listensock;_rfds[0].events = POLLIN;}void Start(){// 等 + 处理数据  select返回的是fd的个数int timeout = -1; // 毫秒for (;;){int n = poll(_rfds, num, timeout);switch (n){case 0:// 超时logMessage(NORMAL, "time out ...");break;case -1:logMessage(WARNING, "select errno code: %d, select errno message: %s", errno, strerror(errno));break;default:// 走到这里说明有fd就绪了,需要进行处理,但是只有 listensock 就绪logMessage(NORMAL, "have event ready!\n");// 进行业务逻辑处理Handerevent();break;}}}

事件处理

当 poll 检测到有文件描述符的读事件就绪时,就会在其对应的 struct pollfd 结构体中的 revents 成员中添加读事件并返回,后面对就绪事件进行处理:

• 遍历 rfds 数组中的每个struct pollfd 结构,如果该结果当中的 fd 有效,且 revents 当中包含读事件,说明该文件描述符的读事件就绪,对该文件描述符进一步的判断,是监听套接字还是与客户端建立连接的套接字

• 如果是监听套接字的读事件就绪,就调用 accept 函数将底层建立好的连接获取上来,并添加到 rfds 数组中,下一次调用 poll 函数时需要监视该套接字的读事件

• 如果是与客户端建立连接对应的读事件就绪,则调用 read 函数读取客户端发来的数据,并将读到的数据在服务端进行打印

• 如果在调用 read 函数时,发现客户端将连接关闭或 read 函数失败,则 poll 服务器也直接关闭对应的连接,并将连接对应的文 rfds 数组中移除,下一次调用 poll 函数时不需要再监视该套接字的读事件

void Print(){std::cout << "fd list: ";for (int i = 0; i < num; i++){if (_rfds[i].fd != defaultnum){std::cout << _rfds[i].fd << " ";}}std::cout << std::endl;}void Accpeter(int listensock){// 获取新连接后,直接添加进入到 _fdarray 数组中logMessage(NORMAL, "Accpeter begin ...\n");uint16_t clientPort = 0;std::string clientIP;int sock = Sock::Accpet(listensock, &clientPort, &clientIP);if (sock < 0){return;}int i = 0;for (; i < num; i++){if (_rfds[i].fd != defaultnum){continue;}else{break;}}// 找到位置if (i == num){// 说明已经满了logMessage(WARNING, "server is full,please wait ...\n");close(sock);}else{_rfds[i].fd = sock;_rfds[i].events = POLLIN; // 只考虑读事件_rfds[i].revents = 0;}// 进行打印Print();logMessage(NORMAL, "Accpeter end ...\n");}void Recver(int pos){// 通过sock这个fd进行接受数据logMessage(NORMAL, "Recver begin ...\n");char buffer[1024];ssize_t n = recv(_rfds[pos].fd, buffer, sizeof(buffer) - 1, 0); // 这里读取不会阻塞,只有sock就绪了,才进来if (n > 0){buffer[n - 1] = 0;logMessage(NORMAL, "client# %s", buffer);}else if (n < 0){// 读取错误close(_rfds[pos].fd);pollInit(pos);logMessage(WARNING, "recv error# %s", strerror(errno));return;}else // == 0{// client 退出了close(_rfds[pos].fd);pollInit(pos);logMessage(NORMAL, "client quit,me too ...");return;}// 此时数据都在buffer当中,处理 requeststd::string response = _func(buffer);write(_rfds[pos].fd, response.c_str(), response.size());logMessage(NORMAL, "Recver end ...\n");}// 处理逻辑void Handerevent(){// 判断是listensock,还是普通sock的for (int i = 0; i < num; i++){if (_rfds[i].fd == defaultnum){continue; // 后面需要进行置空,不能break}if (_rfds[i].fd == _listensock && _rfds[i].revents & POLLIN){// 需要进行accpetAccpeter(_rfds[i].fd);}else if (_rfds[i].revents & POLLIN) // 普通读事件{// 其他fd 而且就绪Recver(i);}else{}}}

因为 rfds 数组的大小是固定设置的,在获取新连接并添加到数组中时,可能会因为数组已满而导致添加失败,只需要将 poll 服务器获取上来的连接套接字进行关闭即可。


poll 服务器

 先实例化一个 pollServer 对象,再初始化服务器,和运行服务器:

#include <iostream>
#include <string>
#include <memory>#include "error.hpp"
#include "pollServer.hpp"void Usage(std::string arg)
{std::cout << "\n Usage: \n\t" << arg << " port"<< "\n\t" << std::endl;
}std::string transmition(const std::string &request)
{return request;
}// ./main 8080
int main(int argc, char *argv[])
{if (argc != 2){Usage(argv[0]);}std::unique_ptr<Server::pollServer> us(new Server::pollServer(transmition, atoi(argv[1])));us->InitServer();us->Start();return 0;
}

在调用 poll 服务器时,此时 timeout 被设置为 -1,运行服务器,如果没有客户端发送连接请求,服务器就会调用 poll 函数后进行阻塞等待:

适用 telnet 工具当客户端进行连接 poll 服务器请求,此时 poll 函数检测到监听套接字的读事件就绪后,就立即进行业务逻辑处理:

 


poll 的优点

• struct pollfd 结构当中包含了 events 和 revents,相当于select 函数的输入输出型参数进行分离,不再适用 select 参数 - 值 传递的方式,接口适用更简单

• poll 并没有最大数量限制(但是数量过大后性能也会下降)

poll 的缺点

poll 中监听的文件描述符数量太多时:

• 和 select 函数一样,poll 返回后,需要轮询 pollfd 来获取就绪的描述符

• 每次调用 poll 都需要把大量的 pollfd 结构从用户态拷贝到内核中

• 同时连接的大量客户端在一起时刻,可能只有很少的处于就绪状态,因此随着监视的描述符数量的增长,其效率也会线性下降


I/O 多路转接 - epoll

epoll 也是系统提供的一个多路转接接口。

• epoll 在命名上比 poll 多了一个e,这个 e 可以理解为 extend,epoll 也是为了同时监视多个文件描述符上的事件是否就绪而对 poll 的改进。

epoll 的相关系统调用

epoll 有三个相关的系统调用,epoll_create、epoll_ctl、epoll_wait 。

epoll_create 函数

用于创建一个 epoll 模型:

• size:自从Linux 2.6.8 之后,size 参数是被忽略的,但是 size 的值必须设置为大于 0 的值

• 用完之后,必须调用 close 函数

返回值说明:

• epoll 模型创建成功返回其对应的文件描述符,否则返回 -1,同时错误码被设置。

epoll_ctl 函数

epoll_ctl 用于向指定的 epoll 模型中注册事件:

 参数说明:

• epfd:指定的 epoll 模型

• op:表示具体的动作,用三个宏来表示

• fd:需要监视的文件描述符

• event:需要监视该文件描述符的哪些事件

返回值说明:

• 函数调用成功返回0,调用失败返回 -1,同时错误码被设置。

struct epoll_event 结构如下:

struct epoll_event 结构中有两个成员,第一个成员 events 表示的是需要监视的事件,第二个成员 data 是一个联合体,一般选择使用该结构中的 fd 成员,表示需要监听的文件描述符。

这些也都是宏的定义方式,二进制序列中有且只有一个比特位1,并且1的位置各不相同。 


epoll_wait 函数 

 用于收集监视的事件中已经就绪的事件:

参数说明:

• epfd:指定的 epoll 模型

• events:内核会将已经就绪的事件拷贝到 events 数组中(events 不能是空指针,内核只负责将就绪事件拷贝到该数组中,不负责在用户态中分配内存空间)

• maxevents:events 数组中的元素个数,该值不能大于创建 epoll 模型时传入的 size 值

• timeout:表示 epoll_wait 函数的超时时间,单位是毫秒(ms)这里的 timeout 事件与 poll 一致。

返回值说明:

• 如果函数调用成功,则返回有事件就绪的文件描述符的个数

• 如果 timeout 时间耗尽,则返回0

• 如果函数调用失败,则返回 -1,同时错误码被设置,可能会被设置为如下:


epoll 工作原理 

epoll的本质是什么 - 花卷不好吃丶

 当某一个进程调用 epoll_create 函数时,Linux 会创建一个 eventpoll 的结构体,也就是 epoll 模型,eventpoll 结构体当中的成员 rbr 和 rdlist 与 epoll 的使用方式密切相关:

struct eventpoll{...//红黑树的根节点,这棵树中存储着所有添加到epoll中的需要监视的事件struct rb_root rbr;//就绪队列中则存放着将要通过epoll_wait返回给用户的满足条件的事件struct list_head rdlist;...
}

• 每一个epoll对象有一个独立的eventpoll结构体,用于存放通过 epoll_ctl 方法向 epoll 对象中添加进来的事件

• 这些事件会挂载在红黑树中,如此,重复添加的事件就可以通过红黑树而高效的识别出来(红黑树的插入时间复杂度是 log N,N是树的高度)

• 而所添加到 epoll 中的事件都会与设备(网卡)驱动程序建立回调关系,响应的事件发生时会调用这个回调方法

• 这个回调方法在内核中叫 ep_poll_callback,会将发生的事件添加到 rdlist 双链表中(就绪队列)

• 在 epoll 中,对于每一个事件都会建立一个epitem结构体

struct epitem{struct rb_node rbn; //红黑树节点struct list_head rdllink; //双向链表节点struct epoll_filefd ffd; //事件句柄信息struct eventpoll *ep; //指向其所属的eventpoll对象struct epoll_event event; //期待发生的事件类型
}

ffd 记录的是指定文件描述符,event 记录的是该文件描述符对应的事件: 

• 对于当中的 rbn 成员来说,ffd 与 event 的含义是,需要监视 ffd 上的 event 事件是否就绪

• 对于 rdlink 成员来说,ffd 与 event 的含义是,ffd上的event事件已经就绪

• 对于 epoll 来说,操作系统不需要主动进行事件都检测,当红黑树中监视的事件就绪时,会自动调用对应的回调方法,将就绪的事件添加到就绪队列中

• 当调用 epoll_wait 函数获取就绪事件时,只需要关注底层就绪队列是否为空,如果不为空,将就绪队列当中的就绪事件拷贝给用户即可

epoll 服务器

这里的 epoll 服务器,也只是读取客户端发来的数据并进行打印。

类中成员除了包含监听的套接字和端口号之外,还需要包含 epoll 模型对应的文件描述符,

#include <iostream>
#include <unistd.h>
#include <sys/epoll.h>
#include <functional>
#include <string>#include "sock.hpp"
#include "error.hpp"namespace Server
{static const int defaultPort = 8080;static const int size = 128;static const int defaultnum = 64;static const int defaultvalue = -1;using func_t = std::function<std::string(const std::string &)>;class epollServer{public:epollServer(func_t func, uint16_t port = defaultPort, int num = defaultnum): _port(port), _listensock(defaultvalue), _num(num), _epfd(defaultvalue), _func(func){}~epollServer(){if (_listensock != defaultvalue){close(_listensock);}if (_erfds){delete[] _erfds;}if (_epfd != defaultvalue){close(_epfd);}}private:uint16_t _port;int _listensock;int _epfd;int _num;                   // 就绪事件的空间大小struct epoll_event *_erfds; // 就绪事件func_t _func;};
}

初始化及运行服务器:

• 在运行服务器之前,需要需要依次调用封装Sock类中的函数,创建套接字,绑定和设置监听状态,并创建 epoll 模型,再调用 epoll_ctl 将监听套接字添加到 epoll 模型当中,表示服务器开始运行时,只需要监视监听套接字的读事件

• epoll 服务器不断调用 epoll_wait 函数监视是否有读事件就绪,如果 epoll_wait 函数的返回值大于0,说明已经有文件描述符的读事件就绪,接下来就是对就绪事件的逻辑操作

• epoll_wait 函数的返回值等于0,说明 timeout 时间耗尽,准备继续下一次的 epoll_wait 调用,返回值等于 -1,需要根据错误码进一步判断是否继续调用 epoll_wait 函数

        void InitServer(){// 1.创建套接字_listensock = Sock::Socket();Sock::Bind(_listensock, _port);Sock::Listen(_listensock);// 2.创建epoll模型_epfd = epoll_create(size);if (_epfd < 0){logMessage(ERROR, "create epoll 模型 error");exit(EPOLL_CREATE_ERR);}// 3.将listensock添加进入epoll中struct epoll_event ev;ev.events = EPOLLIN;ev.data.fd = _listensock;epoll_ctl(_epfd, EPOLL_CTL_ADD, _listensock, &ev);// 申请就绪空间的大小_erfds = new struct epoll_event[_num];logMessage(NORMAL, "Init epoll success!");}void Start(){int timeout = -1;for (;;){int n = epoll_wait(_epfd, _erfds, _num, timeout); // 就绪事件全部存储在 _erfds 中switch (n){case 0: // 超时logMessage(NORMAL, "time out ...\n");break;case -1:logMessage(FATAL, "EPOLL_WAIT EORROR\n");break;default:logMessage(NORMAL, "have a event readys\n");Handlerevents(n);break;}}}

注意:

• 只要底层有就绪事件没有处理,epoll 会一直通知用户,本质原因是实际没有对底层就绪的数据进行读取。


事件处理:

如果底层就绪队列中有就绪事件,epoll_wait 函数会将底层就绪队列中的事件拷贝到定义的 _erfds

数组中,epoll 服务器再进行对就绪事件的处理:

• 根据 epoll_wait 的返回值,来判断操作系统向 _erfds 数组中拷贝了多少个 struct epoll_event 结构,进而对这些文件描述法上的事件进行处理

• 对于该结构当中的 events 当中包含读事件,则说明该文件描述符对应的读事件就绪,接下来还需要进一步判断该文件描述符是监听套接字,还是与客户端建立连接的套接字

• 如果是监听套接字的读事件就绪,就调用 accept 函数将底层建立好的连接获取上来,并调用 epoll_ctl 函数将获取的套接字添加到 epoll 模型中,表示下一次调用 epoll_wait 函数时需要检视该套接字

• 如果是与客户端建立的连接对应的事件就绪,则调用 recv 函数读取客户端发来的数据,并将读取到的数据在服务端打印

• 如果在调用 recv 函数时发现客户端将连接关闭,或者 recv 函数调用失败,则 epoll 服务器也直接关闭对应的连接,则调用 epoll_ctl 函数将对应连接的文件描述符从 epoll 模型中移除,表示下一次调用 epoll_wait 函数时无需监视该套接字的读事件

 void Handlerevents(int readyNum){logMessage(DEBUG, "Handlerevents begin ...\n");for (int i = 0; i < readyNum; i++){uint32_t event = _erfds[i].events;int sock = _erfds[i].data.fd;if (sock == _listensock && (event & EPOLLIN)){uint16_t clientPort;std::string clientIP;// 监听套接字就绪int fd = Sock::Accpet(sock, &clientPort, &clientIP);if (fd < 0){logMessage(NORMAL, "Accept fail ...\n");continue;}// 将fd添加到 epoll 模型中struct epoll_event ev;ev.events = EPOLLIN;ev.data.fd = fd;epoll_ctl(_epfd, EPOLL_CTL_ADD, fd, &ev);}else if (event & EPOLLIN){// 普通事件就绪char buffer[2048];int n = recv(sock, buffer, sizeof(buffer) - 1, 0);if (n > 0){buffer[n] = 0;logMessage(DEBUG, "client#: %s\n", buffer);std::string response = _func(buffer);send(sock, response.c_str(), response.size(), 0);}else if (n == 0){// 客户端退出  先将sock从epoll中移除,再关闭sockepoll_ctl(_epfd, EPOLL_CTL_DEL, sock, nullptr);close(sock);logMessage(NORMAL, "client quit,me too ...\n");}else{epoll_ctl(_epfd, EPOLL_CTL_DEL, sock, nullptr);close(sock);logMessage(WARNING, "recv error ...\n");}}}}

在调用 epoll_wait 函数时,将 timeout 值设置为了 -1,运行服务器后,如果没有客户端发来的连接请求,服务器就会在 epoll_wait 函数后进行阻塞等待:

 使用 telnet 工具连接 epoll 服务器后,epoll 服务器调用 epoll_wait 函数在检测到监听套接字的读事件就绪后,就会调用 accept 函数获取建立好的连接:

使用 ls /proc/PID/fd 命令,查看当前 epoll 服务器文件描述的使用情况,文件描述符0、1、2 是默认打开的分别是 标准输入,标准输出,标准错误,3号文件描述符是监听套接字,4号文件描述符是服务器创建的 epoll 模型,5号文件描述是 telnet 工具建立连接的客户端:

 epoll 的优点(与 select 的缺点对应)

• 接口使用起来更方便,虽然被拆分成了三个函数,但使用起来更方便高效,不需要每次循环设置关注的关键描述符,也做到了输入输出参数分离开

• 数据拷贝轻量:只在新增监视事件都时候,调用 epoll_ctl 时将数据从用户拷贝到内核,而 select 和 poll 每次都需要重新将需要监视的事件从用户拷贝到内核。此外,调用 epoll_wait 获取就绪事件时,只会拷贝就绪的事件,不会进行不必须的拷贝操作

• 事件回调机制:避免使用遍历,而是使用回调函数的方式,将就绪的文件描述符结构加入到就绪队列中,epoll_wait 返回直接访问就绪队列就知道哪些文件描述符就绪,这个操作的时间复杂度是O(1),即使文件描述符数量很多,效率也不会受到影响

• 没有数量限制:监视的文件描述符数量无上限,只要内存允许,就可以一直向红黑数中新增节点

注意:

网上说epoll 使用了内存映射机制?

• 内存映射机制:内核直接将就绪队列通过 mmap 的方式映射到用户态,避免了拷贝内存这样的额外性能开销

• 这种说法是不准确的,实际操作系统并没有做任何的映射机制,操作系统是不相信任何人的,不会让用户进程直接访问到内核的数据,用户只能通过系统调用来获取内核的数据

• 用户要获取内核当中的数据,势必需要将内核的数据拷贝到用户空间

select、poll 和 epoll 的不同之处

• 在使用 select 和 poll 时,都需要借助第三方数组来维护之前的文件描述符以及需要监视的事件,这个第三方数据时用户自己维护的,对用户的增删改操作都是用户自己进行

• epoll 的使用,不需要用户自己维护第三方数据,底层的红黑树就充当了这个数组的功能,该红黑树的增删改操作都是内核来维护的,用户只需要调用 epoll_ctl 函数让内核对红黑树进行对应的操作即可

• 使用多路转接接口时,数据流都有两个方向,一个是告知内核,一个是告知用户,select 和 poll 将这两个事件都交给了同一个函数来完成,而 epoll 在接口层面上将这两件事情分离了,调用 epoll_ctl 完成用户告知内核,epoll_wait 完成内核告知用户


epoll 的工作方式

epoll 有两种工作模式,一种是水平触发工作模式,一种是边缘触发工作模式:

水平触发(Level Triggered,LT) 

• 只要底层有事件就绪,epoll 就会一直通知用户,epoll 默认状态下就是 LT 的工作模式(select 和 poll 也是)

• 当 epoll 检测底层读事件就绪时,可以不立即处理,或者只处理一部分,因为只要底层数据没有处理完,下一次 epoll 还会通知用户事件就行

• 支持阻塞读写和非阻塞读写

边缘触发(Edge Triggered,ET)

• 只有底层就绪事件数量由无到有或由有到多发生变化时,从会通知用户

• epoll 检测到底层读事件就绪时,必须立即进行处理,而且必须全部处理完毕,有可能此后底层再也没有事件就绪,epoll 就再也不会通知用户进行事件处理,此时相当于没有处理完的数据丢失了

• ET 模式下 epoll 通知用户的次数比LT模式下少,因此ET的性能比LT性能高,Nginx 就是采用ET模式使用的 epoll

• 只支持非阻塞读写

如果将 epoll 服务器修改为 ET 工作模式,就需要在初始化服务器添加事件时设置 EPOLLET 选项:

 void InitServer(){// 1.创建套接字_listensock = Sock::Socket();Sock::Bind(_listensock, _port);Sock::Listen(_listensock);// 2.创建epoll模型_epfd = epoll_create(size);if (_epfd < 0){logMessage(ERROR, "create epoll 模型 error");exit(EPOLL_CREATE_ERR);}// 3.将listensock添加进入epoll中struct epoll_event ev;ev.events = EPOLLIN | EPOLLET; //添加 EPOLLET 选项ev.data.fd = _listensock;epoll_ctl(_epfd, EPOLL_CTL_ADD, _listensock, &ev);// 申请就绪空间的大小_erfds = new struct epoll_event[_num];logMessage(NORMAL, "Init epoll success!");}

此时,注释掉事件处理逻辑函数,并运行服务器,此时因为服务器工作模式是 ET 的,所以只通知用户及时取走数据一次:


  ET 工作模式下如何进行读写

在ET工作模式下,当写事件必须一次向发送缓冲区写满,否则可能再也没有机会进行读写,读事件前面以及说过了,必须一次性读取完。

• 当底层读事件就绪时,循环调用 recv 函数进行读取,直到某次调用 recv 读取时,实际读取到的字节数小于期望读取到字节数,说明本次底层数据已经读取完毕

• 有可能最后一次调用 recv 函数读取时,刚好读取的字节数和期望的字节数相等,此时底层数据也读取完毕,如果再调用 recv 函数读取,就会因为底层没有数据而被阻塞住

• 如果服务器是单进程的,recv 被阻塞住,此时该数据再也就绪,相当于服务器挂掉了,因此 ET 工作模式下循环调用 recv 函数进行读取时,必须将对应的文件描述设置为非阻塞

• 调用 send 函数写数据时,也是一样的原理,必须将对应的文件描述符设置为非阻塞(必须的必)


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

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

相关文章

Go语言基础:Interface接口、Goroutines线程、Channels通道详细案例教程

目录标题 一、Interface1. Declaring and implementing an interface2. Practical use of an interface3. Nterface internal representation4. Empty interface5. Type assertion6. Type switch7. Implementing interfaces using pointer receivers VS value receivers8. Impl…

使用Ftp服务器+快解析软件,让你的文件随时随地可访问

你是否曾经遇到过这样的情况&#xff1f;你在办公室工作到很晚&#xff0c;突然想起家里的电脑里有重要文件&#xff0c;但却无法立即访问&#xff1f;或者你想要和朋友分享一些照片&#xff0c;却发现你的电脑和他们之间的距离太远&#xff0c;无法直接传输文件&#xff1f;如…

Win系统下安装Linux双系统教程

软件下载 软件&#xff1a;Linux版本&#xff1a;18.0.4语言&#xff1a;简体中文大小&#xff1a;1.82G安装环境&#xff1a;Win11/Win10/Win8/Win7硬件要求&#xff1a;CPU2.0GHz 内存4G(或更高&#xff09;下载通道①丨百度网盘&#xff1a;1.ubuntu18.0.4下载链接&#xf…

回归预测 | MATLAB实现SCN随机配置网络多输入单输出回归预测(多指标,多图)

回归预测 | MATLAB实现SCN随机配置网络多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09; 目录 回归预测 | MATLAB实现SCN随机配置网络多输入单输出回归预测&#xff08;多指标&#xff0c;多图&#xff09;效果一览基本介绍程序设计参考资料 效果一览 基本…

C语言,Linux,静态库编写方法,makefile与shell脚本的关系。

静态库编写&#xff1a; 编写.o文件gcc -c(小写) seqlist.c(需要和头文件、main.c文件在同一文件目录下) libs.a->去掉lib与.a剩下的为库的名称‘s’。 -ls是指库名为s。 -L库的路径。 makefile文件编写&#xff1a; CFLAGS-Wall -O2 -g -I ./inc/ LDFLAGS-L./lib/ -l…

c# 实现sql查询DataTable数据集 对接SqlSugar ORM

有时候对于已经查询到的数据集&#xff0c;想要进行二次筛选或者查询&#xff0c;还得再查一遍数据库 或者其他的一些逻辑处理不太方便&#xff0c;就想着为什么不能直接使用sql来查询DataTable呢&#xff1f; 搜索全网没找到可用方案&#xff0c;所以自己实现了一个。 主要…

HTTP连接管理

基础知识&#xff1a;非持久连接 HTTP初始时1.0版本在浏览器每一次向服务器请求完资源都会立即断开TCP连接&#xff0c;如果想要请求多个资源&#xff0c;就必须建立多个连接&#xff0c;这就导致了服务端和客户端维护连接的开销。 例如&#xff1a;一个网页中包含文字资源也包…

Stable Diffusion的使用以及各种资源

Stable Diffsuion资源目录 SD简述sd安装模型下载关键词&#xff0c;描述语句插件管理controlNet自己训练模型 SD简述 Stable Diffusion是2022年发布的深度学习文本到图像生成模型。它主要用于根据文本的描述产生详细图像&#xff0c;尽管它也可以应用于其他任务&#xff0c;如…

MySQL之索引和事务

索引什么是索引索引怎么用索引的原理 事务使用事务事务特性MySQL隔离级别 索引 什么是索引 索引包含数据表所有记录的引用指针&#xff1b;你可以对某一列或者多列创建索引和指定不同的类型&#xff08;唯一索引、主键索引、普通索引等不同类型&#xff1b;他们底层实现也是不…

Vue 2 组件注册

组件名的命名规则 定义组件名的两种方式&#xff1a; 短横线分隔命名&#xff0c;Kebab Case&#xff0c;例如my-component-name。单词首字母大写命名&#xff0c;Pascal Case&#xff0c;例如MyComponentName。 第一种方式在模板中使用<my-component-name>引用该元素…

FastDFS与Nginx结合搭建文件服务器,并实现公网访问【内网穿透】

文章目录 前言1. 本地搭建FastDFS文件系统1.1 环境安装1.2 安装libfastcommon1.3 安装FastDFS1.4 配置Tracker1.5 配置Storage1.6 测试上传下载1.7 与Nginx整合1.8 安装Nginx1.9 配置Nginx 2. 局域网测试访问FastDFS3. 安装cpolar内网穿透4. 配置公网访问地址5. 固定公网地址5.…

Asyncio support

Python 3.4及更高版本中内置的asyncio模块可用于在单个线程中编写异步代码。此库支持使用can.Notifier类在事件循环中异步接收消息。 每个CAN总线仍将有一个线程,但用户应用程序将完全在事件循环中执行,从而实现更简单的并发性,而无需担心线程问题。但是,具有有效文件描述…

常用的图像校正方法

在数字图像处理中&#xff0c;常用的校正方法包括明场均匀性校正、查找表&#xff08;LUT&#xff09;校正和伽玛&#xff08;Gamma&#xff09;校正。这些校正方法分别针对不同的图像问题&#xff0c;可以改善图像质量&#xff0c;提升图像的可读性和可分析性。下面是这三种校…

openpnp - 板子上最小物料封装尺寸的选择

文章目录 openpnp - 板子上最小物料封装尺寸的选择概述END openpnp - 板子上最小物料封装尺寸的选择 概述 现在设备调试完了, 用散料飞达载入物料试了一下. 0402以上贴的贴别准, 贴片流程也稳, 基本不需要手工干预. 0201可以贴, 但是由于底部相机元件视觉识别成功率不是很高…

uni-app打包后安卓不显示地图及相关操作详解

新公司最近用uni-app写app&#xff0c;之前的代码有很多问题&#xff0c;正好趁着改bug的时间学习下uni-app。 问题现象&#xff1a; 使用uni-app在浏览器调试的时候&#xff0c;地图是展示的&#xff0c;但是打包完成后&#xff0c;在app端是空白的。咱第一次写app&#xff…

docker 06(docker compose)

一、服务编排 二、docker compose

查看所有数据库各表容量大小

查看所有数据库各表容量大小 1. 查看所有数据库各表容量大小2.查看指定数据库容量大小3. 查看所有数据库容量大小 1. 查看所有数据库各表容量大小 select table_schema as 数据库, table_name as 表名, table_rows as 记录数, truncate(data_length/1024/1024, 2) as 数据容量…

Mac常见恶意软件再现,办公应用程序潜藏风险如何防范?

Mac电脑正受到臭名昭著的XLoader恶意软件的新变种的攻击&#xff0c;该恶意软件已被重写为在最好的MacBook上本地运行。 虽然XLoader至少从2015年开始出现&#xff0c;但在2021年发现macOS变体之前&#xff0c;它主要用于针对Windows PC。然而&#xff0c;该版本是作为Java程序…

解决Fastjson2 oom(Out Of Memory),支持大对象(LargeObject 1G)json操作

在使用Fastjson中的 JSON.toJSONString时,如果对象数据太大&#xff08;>64M&#xff09;会出现Out Of Memory,查看源码发现为JSONWriter中的判断代码 其中maxArraySize默认最大为64M,如果超过了就会抛出oom错误 如果fastjson过多的使用内存,也可能导致java堆内存溢出,所以这…

C++ STL无序关联式容器(详解)

STL无序关联式容器 继 map、multimap、set、multiset 关联式容器之后&#xff0c;从本节开始&#xff0c;再讲解一类“特殊”的关联式容器&#xff0c;它们常被称为“无序容器”、“哈希容器”或者“无序关联容器”。 注意&#xff0c;无序容器是 C 11 标准才正式引入到 STL 标…