IO复用之epoll模型

news/2024/7/9 16:18:56 标签: c++, epoll

epoll_0">什么是epoll

epoll 是 Linux 操作系统提供的一种高性能的事件通知机制，用于处理大量文件描述符上的事件。它是一种 I/O 事件通知机制，通常用于处理网络编程中的并发连接。

在传统的 I/O 模型中，程序通常使用 select 或 poll 函数来等待多个文件描述符上的事件。这种方式有一些性能上的限制，特别是当需要监视的文件描述符数量很大时。epoll 的设计旨在解决这些性能问题。

epoll__7">以下是一些关键的 epoll 特性：

高性能： epoll 使用红黑树（RB tree）来存储文件描述符，这允许它在处理大量描述符时保持较低的时间复杂度，从而提高性能。

事件驱动： epoll 使用事件驱动的模型，即当文件描述符上有事件发生时，内核会通知应用程序。这避免了应用程序不断地轮询文件描述符，从而提高效率。

支持边缘触发和水平触发： epoll 可以以边缘触发（edge-triggered）或水平触发（level-triggered）的方式工作。边缘触发模式表示只有在文件描述符上的状态变化时才会通知应用程序，而水平触发模式表示只要文件描述符上有事件发生，就会通知应用程序。

支持单个系统调用处理多个事件： epoll 允许在一个系统调用中处理多个事件，这减少了系统调用的次数，提高了效率。

使用 epoll 可以更有效地管理大量并发连接，适用于服务器应用程序，特别是网络服务器，以提高性能和可伸缩性。在实际应用中，epoll 通常与非阻塞 I/O 配合使用，以更好地处理并发请求。

epoll_createepoll_wait_epoll_ctl_19">Epoll的三大函数：epoll_create，epoll_wait， epoll_ctl

epoll_create_20">epoll_create

#include<sys/epoll.h>
int epoll_create(int size);

成功时返回epoll文件描述符，失败时返回-1。

  • size：epoll实例的大小。
  • 该函数从2.3.2版本的开始加入的，2.6版开始引入内核
  • Linux最新的内核稳定版本已经到了5.8.14，长期支持版本到了5.4.70
  • 从2.6.8内核开始的Linux，会忽略这个参数，但是必须要大于0
  • 这个是Linux独有的函数

epoll_ctl_33">epoll_ctl

#include<sys/epoll.h>
int epoll_ctl(int epfd, int op, int fd, struct epoll_event* event);

成功时返回0，失败时返回-1。

  • epfd 用于注册监视对象的epoll例程的文件描述符。
  • op 用于指定监视对象的添加、删除或更改等操作。

EPOLL_CTL_ADD,EPOLL_CTL_MOD,EPOLL_CTL_DEL

  • fd 需要注册的监视对象文件描述符。

event 监视对象的事件类型。
EPOLLIN∶需要读取数据的情况。
EPOLLOUT∶输出缓冲为空，可以立即发送数据的情况。
EPOLLPRI∶收到OOB数据的情况。
EPOLLRDHUP∶断开连接或半关闭的情况，这在边缘触发方式下非常有用。
EPOLLERR∶发生错误的情况。
EPOLLET∶以边缘触发的方式得到事件通知。
EPOLLONESHOT∶发生一次事件后，相应文件描述符不再收到事件通知。因此需要向
epoll_ctl函数的第二个参数传递
EPOLLCTL_MOD，再次设置事件

epoll_wait_59">epoll_wait：

#include <sys/epoll.h>
int epoll_wait(int epfd, struct epoll_event*events,int maxevents,int timeout);

成功时返回发生事件的文件描述符数，失败时返回-1。

  • epfd 表示事件发生监视范围的epol例程的文件描述符
  • events 保存发生事件的文件描述符集合的结构体地址值。
  • maxevents 第二个参数中可以保存的最大事件数目。
  • Timeout：以1/1000秒为单位的等待时间，传递-1时，一直等待直到发生事件。

Epoll实战案例

基于eopll实现简单的文件上传下载功能，仅服务端代码

#include <cstdio>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/epoll.h>
#include<pthread.h>
//#include<sys/types.h>
//#include<sys/stat.h>
#include <fcntl.h>
#include <sys/file.h>
#include <unordered_map>

#define EPOLL_EVENT_SIZE 100
#define USER_NUM 100

// 文件存放路径
const char* PATH = "/root/projects/chatdata/";

struct Data
{
	char typ;// 请求类型
	char content[1024]; // 请求内容
};
void error_handling(const char* msg) {
	fputs(msg, stderr);
	fputc('\n', stderr);
	exit(-1);
}

// 一个线程专门用来上传下载文件
void* thread_main(void* arg)
{
    //一个map管理文件描述符
	std::unordered_map<int, int> fdMap;
	pthread_detach(pthread_self());
	char filePath[1024];
	char buf[sizeof(Data)];
	memset(&buf, 0, sizeof(buf));
	// 准备套接字
	int serv_sock, clnt_sock;
	sockaddr_in serv_adr, clnt_adr;
	socklen_t client_sz;
	client_sz = sizeof(clnt_adr);
	serv_sock = socket(PF_INET, SOCK_STREAM, 0);
	serv_adr.sin_family = AF_INET;
	serv_adr.sin_addr.s_addr = htonl(INADDR_ANY);
	serv_adr.sin_port = htons(9091);

	if (bind(serv_sock, (struct sockaddr*)&serv_adr, sizeof(serv_adr)) == -1) {
		error_handling("bind() error");
		close(serv_sock);
		return 0;
	}
	if (listen(serv_sock, 5) == -1) {
		error_handling("listen() error");
		close(serv_sock);
		return 0;
	}
	epoll_event event;
	memset(&event, 0, sizeof(event));
	int epfd, event_cnt;
	epfd = epoll_create(1);
	if (epfd == -1) {
		error_handling("epoll_create() error");
		close(serv_sock);
		return 0;
	}
	epoll_event* all_events = new epoll_event[EPOLL_EVENT_SIZE];
	event.events = EPOLLIN;
	event.data.fd = serv_sock;
	epoll_ctl(epfd, EPOLL_CTL_ADD, serv_sock, &event);
	while (true) {
		event_cnt = epoll_wait(epfd, all_events, EPOLL_EVENT_SIZE, 1000);
		if (event_cnt == -1) {
			printf("epoll_wait() error");
			break;
		}
		if (event_cnt == 0)continue;
		for (int i = 0; i < event_cnt; i++) {
			// 监听可读事件
			if (all_events[i].events & EPOLLIN) {
				// 当发生的事件为服务器时接收接收连接
				if (all_events[i].data.fd == serv_sock) {
					clnt_sock = accept(serv_sock, (struct sockaddr*)&clnt_adr, &client_sz);
					// TODO  修改缓存区，娜迦算法
					if (clnt_sock == -1) {
						printf("accept() error");
						continue;
					}
					event.events = EPOLLIN;
					event.data.fd = clnt_sock;
					epoll_ctl(epfd, EPOLL_CTL_ADD, clnt_sock, &event);
				}
				else
				{
					ssize_t len = read(all_events[i].data.fd, buf, sizeof(buf));
					if (len <= 0) {
						// 取消监听，关闭文件操作符，关闭客户端sock
						epoll_ctl(epfd, EPOLL_CTL_DEL, all_events[i].data.fd, NULL);
						close(fdMap[all_events[i].data.fd]);
						close(all_events[i].data.fd);
						fdMap.erase(all_events[i].data.fd);
						printf("client is close! %d\n", clnt_sock);
					}
					else
					{
						if (buf[0] == 0) {
							//首次接收上传文件请求，打开文件
							memset(filePath, 0, sizeof(filePath));
							//const char* PATH = "/root/projects/chatdata/";
							strcpy(filePath, PATH);
							strcat(filePath, buf + 1);
							printf("filePath %s\n", filePath);
							int fd = open(filePath, O_WRONLY | O_CREAT | O_APPEND, 0777);
							perror("open");
							fdMap[all_events[i].data.fd] = fd;
						}
						else if (buf[0] == 1)
						{
							// 没有考虑文件终止问题EOF
							write(fdMap[all_events[i].data.fd], buf + 1, len - sizeof(buf[0]));
						}
						else if (buf[0] == 2)
						{
							// 用户请求下载文件
							memset(filePath, 0, sizeof(filePath));
							//const char* PATH = "/root/projects/chatdata/";
							strcpy(filePath, PATH);
							strcat(filePath, buf + 1);
							int fd = open(filePath, O_RDONLY);
							printf("filePath %s\n", filePath);
							printf("int fd = open(filePath, O_RDONLY); %d\n", fd);
							perror("open");
							unsigned long fileSize = static_cast<unsigned long>(lseek(fd, 0, SEEK_END));
							printf("unsigned long fileSize = static_cast<unsigned long>(lseek(fd, 0, SEEK_END)); %d\n", fileSize);
							lseek(fd, 0, SEEK_SET);
							memset(&buf, 0, sizeof(buf));
							memcpy(buf, &fileSize, sizeof(fileSize));
							//printf("memset(&buf, 0, sizeof(buf)); %d\n", buf);
							fdMap[all_events[i].data.fd] = fd;
							write(all_events[i].data.fd, buf, sizeof(buf));
							//修改监听的事件
							clnt_sock = all_events[i].data.fd;
						    event.events = EPOLLOUT;
							event.data.fd = clnt_sock;
							epoll_ctl(epfd, EPOLL_CTL_MOD, clnt_sock, &event);
						}
					}
				}
			}

			// 监听可写事件
			if (all_events[i].events & EPOLLOUT) {
				//开写
				int len = read(fdMap[all_events[i].data.fd], buf, sizeof(buf));
				write(all_events[i].data.fd, buf, len);
				if (len < sizeof(buf)) {
					// 写完了
					epoll_ctl(epfd, EPOLL_CTL_DEL, all_events[i].data.fd, NULL);
					close(fdMap[all_events[i].data.fd]);
					close(all_events[i].data.fd);
					fdMap.erase(all_events[i].data.fd);
					printf("client is close! %d\n", clnt_sock);
				}
			}
		}
	}

	delete all_events;
	close(serv_sock);


	pthread_exit(0);
}

int main()
{

	pthread_t t_id;
	int thread_param = 5;
	//thread_param表示函数传参 ， thread_main表示线程函数
	if (pthread_create(&t_id, NULL, thread_main, (void*)&thread_param) != 0)
	{
		puts("pthread_create() error");
		return -1;
	};
	// TODO 其他的业务逻辑
	return 0;
}

http://www.niftyadmin.cn/n/5349576.html

相关文章

R语言【taxlist】——clean()：移除孤立的记录

R语言【taxlist】——clean()：移除孤立的记录

Package taxlist version 0.2.4 Description 对于 taxlist 类对象的操作可能会产生独立的条目。clean() 方法就是用来删除这样的条目&#xff0c;并恢复 taxlist 对象的一致性。 Usage clean(object, ...)## S4 method for signature taxlist clean(object, times 2, ...) A…
阅读更多...
Go切片扩容机制详解

Go切片扩容机制详解

本文对于切片扩容做了非常详细的说明和举例&#xff0c;篇幅较长&#xff0c;行文不易&#xff0c;一字一句纯手打创造&#xff0c;倾注了不少精力&#xff0c;感谢支持。 目录 切片扩容的理解 扩容机制源码分析 分配大小修正/cap调整 切片扩容的理解 关于切片的“扩容”&a…
阅读更多...
怎么用Python输出图片

怎么用Python输出图片

在Python中输出图片通常指的是将图片数据加载到内存中&#xff0c;并通过某种方式显示出来。最常见的方法是使用图形库&#xff0c;比如PIL&#xff08;Python Imaging Library&#xff0c;又名Pillow&#xff09;或者Matplotlib。以下是使用这些库来显示图片的基本步骤&#x…
阅读更多...
【Linux C | 网络编程】入门知识：TCP协议、TCP客户端、TCP服务端

【Linux C | 网络编程】入门知识：TCP协议、TCP客户端、TCP服务端

&#x1f601;博客主页&#x1f601;&#xff1a;&#x1f680;https://blog.csdn.net/wkd_007&#x1f680; &#x1f911;博客内容&#x1f911;&#xff1a;&#x1f36d;嵌入式开发、Linux、C语言、C、数据结构、音视频&#x1f36d; &#x1f923;本文内容&#x1f923;&a…
阅读更多...
华为机考入门python3--（0）模拟题3-计算字符串重新排列数

华为机考入门python3--（0）模拟题3-计算字符串重新排列数

分类&#xff1a;排列组合 知识点&#xff1a; 计算字符串中每个字符出现的次数 Counter(string) 计算列表中每个元素出现的次数 Counter(list) 阶乘 math.factorial(num) 排列去重 题目来自【华为招聘模拟考试】 先把每个字符当成唯一出现过一次&#xff0c;计算所有排列…
阅读更多...
国考省考行测：判断推理，形式逻辑，充分条件，必要条件，用箭头，找真假，找不定

国考省考行测：判断推理，形式逻辑，充分条件，必要条件，用箭头，找真假，找不定

国考省考行测&#xff1a;判断推理 2022找工作是学历、能力和运气的超强结合体! 公务员特招重点就是专业技能&#xff0c;附带行测和申论&#xff0c;而常规国考省考最重要的还是申论和行测&#xff0c;所以大家认真准备吧&#xff0c;我讲一起屡屡申论和行测的重要知识点 遇到…
阅读更多...
调用GPT3接口的一些参数

调用GPT3接口的一些参数

GPT3接口 官方文档 API Reference 调用 temperature 通过设置合适的 temperature 值和观察每个 token 的概率&#xff0c;判断输出的确定性和可靠性&#xff0c;避免与直觉不符的结果。 在实际应用中&#xff0c;这两个参数非常有价值。聊天应用可设置较高 temperature 值&…
阅读更多...
vue 样式隔离原理

vue 样式隔离原理

日常写单文件组件时&#xff0c;会在style添加scoped属性&#xff0c;如<style scoped>&#xff0c;目的是为了隔离组件与组件之间的样式&#xff0c;如下面的例子&#xff1a; <template><p class"foo">这是foo</p><p class"bar&q…
阅读更多...
最新文章

Copyright @ 2022~2023