inotify和epoll结合使用的小例子

2024-03-23 01:38

本文主要是介绍inotify和epoll结合使用的小例子,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

个人能力有限,文中有不当和错误给您带来的不便还请谅解。

用inotify可以检测文件系统中文件和目录发生的变化,而epoll可以同时检测多个文件。这里将epoll和inotify结合起来使用,测试这样一种情况:指定相应目录,当目录中有文件创建或者删除时有相应的通知信息并把文件添加或者移除epoll的检测机制,当文件可读时,通过epoll机制将指定的文件的内容读取出来。

基于这个功能实现的例子如下所示:

#include <stdio.h>
#include <sys/inotify.h>
#include <sys/epoll.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>#define BUFFER_SIZE		512		// 定义缓冲区的大小
#define ARRAY_LENGTH	128		// 定义数组的长度
#define NAME_LENGTH		128		// 定义文件名长度的限制/* 定义epoll最大监听的文件数量 */
#define EPOLL_MAX_EVENTS	32/* 定义一个结构体用来存放一个文件对应的文件描述符和文件名 */
struct file_name_fd_desc {int fd;							// 文件的描述符char name[32];					// 文件名char base_name[NAME_LENGTH];	// 带绝对路径的文件名
};/* 定义一个epoll事件的数组,用来存放监听文件的信息 */
static struct epoll_event g_PendingEventItems[EPOLL_MAX_EVENTS];/* 定义一个数组用来存放对应文件的文件描述符和文件名 */
static struct file_name_fd_desc g_file_name_fd_desc[ARRAY_LENGTH];
static int array_index = 0;/* 定义一个存放基目录册指针 */
static char *base_dir;/**	向epoll当中添加一个要监视的文件*/
static int add_to_epoll(int epoll_fd, int fd)
{int result;struct epoll_event eventItem;memset(&eventItem, 0, sizeof(eventItem));eventItem.events 	= EPOLLIN;		// epoll检测相应的文件的读操作将被唤醒eventItem.data.fd 	= fd;result = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd, &eventItem);return result;
}/*	*	将指定文件从epoll中删除*/
static void remove_from_epoll(int epoll_fd, int fd)
{epoll_ctl(epoll_fd, EPOLL_CTL_DEL, fd, NULL);
}/**	通过文件描述符获得文件名*/
static int get_name_from_fd(int fd, char **name)
{int i;/* 对整个数组进行遍历 */for(i = 0; i < ARRAY_LENGTH; i++){if(fd == g_file_name_fd_desc[i].fd){*name = g_file_name_fd_desc[i].name;return 0;}}return -1;
}/*	inotify 监听事件的消息处理机制:*		a、当创建一个文件时,把这个文件添加到epoll的监测文件当中*		b、当删除一个文件时,把这个文件从epoll的监测文件当中移除*/
static int inotify_ctl_info(int inotify_fd, int epoll_fd)
{char event_buf[BUFFER_SIZE];int event_pos = 0;int event_size;struct inotify_event *event;int result;int tmp_fd;int i;/* 读取inotify的监视事件的信息 */memset(event_buf, 0, BUFFER_SIZE);result = read(inotify_fd, event_buf, sizeof(event_buf));if(result < (int)sizeof(*event)) {printf("could not get event!\n");return -1;}/* 将获得的inotify信息打印出来 */while(result >= (int)sizeof(*event)) {event = (struct inotify_event *)(event_buf + event_pos);if(event->len) {if(event->mask & IN_CREATE) // 创建一个文件时{/* 将文件名name关联起来 */sprintf(g_file_name_fd_desc[array_index].name, "%s", event->name);sprintf(g_file_name_fd_desc[array_index].base_name, "%s/%s", base_dir, event->name);tmp_fd = open(g_file_name_fd_desc[array_index].base_name, O_RDWR);if(-1 == tmp_fd){printf("inotify_ctl_info open error!\n");return -1;}add_to_epoll(epoll_fd, tmp_fd);		// 将创建的文件加入到epoll当中/* 将文件描述符fd关联起来 */g_file_name_fd_desc[array_index].fd = tmp_fd;if(ARRAY_LENGTH == array_index){array_index = 0;}array_index += 1;printf("add file to epoll : %s\n", event->name);} else 	// 删除一个文件时{for(i = 0; i < ARRAY_LENGTH; i++){if(!strcmp(g_file_name_fd_desc[i].name, event->name)){remove_from_epoll(epoll_fd, g_file_name_fd_desc[i].fd);	 // 将指定的文件从epoll中删除/* 将数组中指定的文件名和文件描述符清空 */g_file_name_fd_desc[i].fd = 0;memset(g_file_name_fd_desc[i].name, 0, sizeof(g_file_name_fd_desc[i].name));memset(g_file_name_fd_desc[i].base_name, 0, sizeof(g_file_name_fd_desc[i].base_name));printf("remove file from epoll : %s\n", event->name);break;}}}}/* 更新位置信息,以便获得下一个 inotify_event 对象的首地址*/event_size = sizeof(*event) + event->len;result -= event_size;event_pos += event_size;}return 0;
}/*	检测指定目录 : 有文件被创建或者删除,有文件可以读出数据*		a. 当在指定目录下创建文件时, 会立刻监测到,并且使用epoll监测该文件*		b. 当文件有数据时,读出数据*		c. 当指定目录下文件被删除时,会立刻监测到,并且把它从epoll中移除不再监测*	Usage : inotify_epoll <dir>*/
int main(int argc, char *argv[])
{int inotify_fd;int epoll_fd;int result;int i;char readbuf[BUFFER_SIZE];int readlen;char *tmp_name;	if(2 != argc){printf("Usage : %s <dir>\n", argv[0]);return -1;}/* 将传入的参数作为基目录 */base_dir = argv[1];/* 打开一个epoll文件的文件描述符 */epoll_fd = epoll_create(1);		// 传入的参数可以随意,只要大于0即可,没有什么具体意思if(-1 == epoll_fd){printf("epoll_create error!\n");return -1;}/* 初始化一个inotify的实例,获得一个该实例的文件描述符 */inotify_fd = inotify_init();/* 添加一个用于监视的目录:主要监视该目录中文件的添加和移除 */result = inotify_add_watch(inotify_fd, base_dir, IN_DELETE | IN_CREATE);if(-1 == result){printf("inotify_add_watch error!\n");return -1;}/* 将inotify_fd将入到epoll当中 */add_to_epoll(epoll_fd, inotify_fd);/* 通过循环来处理不同情况 */while(1){/* 调用epoll_wait来监听事件 */result = epoll_wait(epoll_fd, g_PendingEventItems, EPOLL_MAX_EVENTS, -1);	if(-1 == result)	// 发生错误{printf("epoll wait error!\n");return -1;}else{for(i = 0; i < result; i++)	// 对监听到的事件进行遍历{if(g_PendingEventItems[i].data.fd == inotify_fd) // inotify事件发生的情况下{if(-1 == inotify_ctl_info(inotify_fd, epoll_fd)){printf("inotify_ctl_info error!\n");return -1;}}else  // 非inotify事件,则把文件的内容读取出来{if(!get_name_from_fd(g_PendingEventItems[i].data.fd, &tmp_name)){readlen = read(g_PendingEventItems[i].data.fd, readbuf, BUFFER_SIZE);readbuf[readlen] = '\0';printf("read data from %s : %s\n", tmp_name, readbuf);	}}}}}return 0;
}
编译并运行,测试结果如下:












这篇关于inotify和epoll结合使用的小例子的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/836734

相关文章

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

java使用protobuf-maven-plugin的插件编译proto文件详解

《java使用protobuf-maven-plugin的插件编译proto文件详解》:本文主要介绍java使用protobuf-maven-plugin的插件编译proto文件,具有很好的参考价... 目录protobuf文件作为数据传输和存储的协议主要介绍在Java使用maven编译proto文件的插件

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

C++ Log4cpp跨平台日志库的使用小结

《C++Log4cpp跨平台日志库的使用小结》Log4cpp是c++类库,本文详细介绍了C++日志库log4cpp的使用方法,及设置日志输出格式和优先级,具有一定的参考价值,感兴趣的可以了解一下... 目录一、介绍1. log4cpp的日志方式2.设置日志输出的格式3. 设置日志的输出优先级二、Window

Ubuntu如何分配​​未使用的空间

《Ubuntu如何分配​​未使用的空间》Ubuntu磁盘空间不足,实际未分配空间8.2G因LVM卷组名称格式差异(双破折号误写)导致无法扩展,确认正确卷组名后,使用lvextend和resize2fs... 目录1:原因2:操作3:报错5:解决问题:确认卷组名称​6:再次操作7:验证扩展是否成功8:问题已解

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构

使用Docker构建Python Flask程序的详细教程

《使用Docker构建PythonFlask程序的详细教程》在当今的软件开发领域,容器化技术正变得越来越流行,而Docker无疑是其中的佼佼者,本文我们就来聊聊如何使用Docker构建一个简单的Py... 目录引言一、准备工作二、创建 Flask 应用程序三、创建 dockerfile四、构建 Docker

Python使用vllm处理多模态数据的预处理技巧

《Python使用vllm处理多模态数据的预处理技巧》本文深入探讨了在Python环境下使用vLLM处理多模态数据的预处理技巧,我们将从基础概念出发,详细讲解文本、图像、音频等多模态数据的预处理方法,... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

Conda与Python venv虚拟环境的区别与使用方法详解

《Conda与Pythonvenv虚拟环境的区别与使用方法详解》随着Python社区的成长,虚拟环境的概念和技术也在不断发展,:本文主要介绍Conda与Pythonvenv虚拟环境的区别与使用... 目录前言一、Conda 与 python venv 的核心区别1. Conda 的特点2. Python v