当前位置：首页 > 编程日记 > 正文

朴素、Select、Poll和Epoll网络编程模型实现和分析——Poll模型

编程日记 2024-12-09 11:10:00

在《朴素、Select、Poll和Epoll网络编程模型实现和分析——Select模型》中，我们分析了它只能支持1024个连接同时处理的原因。但是在有些需要同时处理更多连接的情况下，1024个连接往往是不够的，也就是不能够高并发。那么这个时候我们就可以采用本文介绍的Poll模型。（转载请指明出于breaksoftware的csdn博客）

在使用Poll模型之前，我们需要定义一个保存连接信息的数组

	struct pollfd fds[FDS_COUNT];

之后创建异步监听socket、绑定端口和监听端口等行为和《朴素、Select、Poll和Epoll网络编程模型实现和分析——Select模型》一文中一模一样，本文就不列出代码了。我们把创建的socket信息赋值给fds数组的第一个元素，并且设定我们需要关注的事件POLLIN——可读。

	int timeout;int cur_fds_count;int rc;int index;int expect_events;int error_events;
……// 创建socketmemset(fds, 0, sizeof(fds));error_events = POLLERR | POLLNVAL;expect_events = POLLIN;fds[0].fd = listen_sock;fds[0].events = expect_events;cur_fds_count = 1;

cur_fds_count用于记录当前fds数组中有多少个被关心的文件描述符。因为一开始我们只关心监听socket，所以它的初始值是1。

然后我们就要在一个死循环中，不停的调用poll函数，监控我们关心的文件描述符是否发生了状态改变

	timeout = (500);	while (1) {rc = poll(fds, cur_fds_count, timeout);if (rc < 0) {perror("poll error\n");exit(EXIT_FAILURE);};if (rc == 0) {//perror("poll timeout\n");};

poll函数的返回值和select函数类似。如果返回小于0，则说明发生了错误，我们让程序退出。如果返回了0，则说明poll函数超时。如果大于0，则说明被关心的文件描述符状态发生了改变。但是此时，我们仍然不知道是哪个文件描述符发生了改变，所以我们要遍历fds数组。

		int cur_fds_count_temp = cur_fds_count;for (index = 0; index < cur_fds_count_temp; ++index) {

这个时候我们有必要说明下pollfd结构体的定义

struct pollfd {int fd;short events;short revents;
};

pollfd中的fd是用于记录我们关心的文件描述符；events表示我们关心的事件，如POLLIN、POLLOUT等。revents是实际发生的事件。于是我们一开始要判断改pollfd是否发生了事件改变

			if (fds[index].revents == 0) {continue;}

接着我们判断下发生的事件是否是我们定义的出错事件。

			if (fds[index].revents & error_events) {perror("revents error");

如果出错的是监听socket，则我们退出程序。

				if (fds[index].fd == listen_sock) {perror("listen sock error");exit(EXIT_FAILURE);}

如果出错的不是监听socket，则它就是客户端接入的socket，我们将它关闭，并且将fds数组的最后一个元素覆盖当前位置，让数组长度减一。这个过程是最精简的数组缩小方式，如果使用新数组去记录，将导致效率降低。

				else {close(fds[index].fd);cur_fds_count--;if (index < cur_fds_count) {memcpy(&fds[index], &fds[cur_fds_count], sizeof(fds[cur_fds_count]));memset(&fds[cur_fds_count], 0, sizeof(fds[cur_fds_count]));index--;}cur_fds_count_temp--;continue;}	}

我们再看发生的事件是否是我们关心的事件，如果不是，则continue掉，继续处理下一个pollfd。

			if (!(fds[index].revents & fds[index].events)) {continue;}

经过上述筛选，剩下的就是我们要正常处理的pollfd了。和Select方式一样，我们先看看其是否是监听socket。如果是，则获取客户端接入的socket值，并记录到数组中。

			if (fds[index].fd == listen_sock) {int new_sock;new_sock = accept(listen_sock, NULL, NULL);if (new_sock < 0) {//perror("accept error");if (errno != EWOULDBLOCK) {continue;}exit(EXIT_FAILURE);}else {request_add(1);//set_block_filedes_timeout(new_sock);if (cur_fds_count + 1 < sizeof(fds)) {fds[cur_fds_count].fd = new_sock;fds[cur_fds_count].events = expect_events;cur_fds_count++;}}}

如果不是监听socket，则是客户端接入的socket。我们就读取这个socket中的内容，并写入我们的回包。

			else {if (0 == server_read(fds[index].fd)) {server_write(fds[index].fd);}close(fds[index].fd);cur_fds_count--;if (index < cur_fds_count) {memcpy(&fds[index], &fds[cur_fds_count], sizeof(fds[cur_fds_count]));memset(&fds[cur_fds_count], 0, sizeof(fds[cur_fds_count]));index--;}cur_fds_count_temp--;}}}return 0;
}

如此，我们便将简单的poll服务器给写完了。我们看下poll模型的处理能力。采用和《朴素、Select、Poll和Epoll网络编程模型实现和分析——朴素模型》一文中相同的环境和压力，我们看下服务器的数据输出

再看下客户端的输出

可见当前环境下poll模型的处理能力大概是每秒7500次请求。

https://www.dkcj.cn/info/31061.html

朴素、Select、Poll和Epoll网络编程模型实现和分析——Poll模型

相关文章：

flashcom中远程共享对象SharedObject的用法

Hive-1.2.0学习笔记（一）安装配置

邮件安全隐患及其防范技术研究

必看！52篇深度强化学习收录论文汇总 | AAAI 2020

朴素、Select、Poll和Epoll网络编程模型实现和分析——Epoll模型

Scala 深入浅出实战经典第88讲：Scala中使用For表达式实现map、flatMap、filter

抛弃Python，我们为什么用Go编写机器学习架构？

朴素、Select、Poll和Epoll网络编程模型实现和分析——模型比较

使用VM虚拟机的一点小技巧

翻译：AKKA笔记 - Actor消息 -1（二）

远程安装oracle 10.2.1 for redhat 5.0 2.6.18-53.el5xen

伯克利新无监督强化学习方法：减少混沌所产生的突现行为

朴素、Select、Poll和Epoll网络编程模型实现和分析——Poll、Epoll模型处理长连接性能比较

Topcoder SRM 663 DIV 1

跨平台PHP调试器设计及使用方法——立项

机器推理文本+视觉，跨模态预训练新进展

[LeetCode]:94:Binary Tree Inorder Traversal

腾讯 AI 2019这一年

跨平台PHP调试器设计及使用方法——探索和设计

Ubuntu下允许Root用户直接登录图形界面

携程App for Apple Watch探索

跨平台PHP调试器设计及使用方法——通信

MVP模式的相关知识

“数学不行，还能干点啥？”面试官+CTO：干啥都费劲！

CentOS7 yum 源的配置与使用

跨平台PHP调试器设计及使用方法——协议解析

测试客户端发图图

搜狐、美团、小米都在用的Apache Doris有什么好？ | BDTC 2019

cacti邮件告警设置

跨平台PHP调试器设计及使用方法——高阶封装