Linux 用inotify监听文件和目录

日常应用中,常常会遇到以下场景,监控文件夹A,若文件夹中的B文件发生变化,则执行C命令。Linux下可以通过inotify完成该功能。

自从Linux kernel 2.6.13起,inotify以作为内核的一部份,同时需要glibc 2.4以上版本。

1. 相关函数

inotify_init() - 创建一个inotify实例

inotify_add_watch(int fd, const char *pathname, uint32_t mask) - 加入文件或目录到inotify进行监测

inotify_rm_watch(int fd, int wd) - 移除一个watcher

2. 相关结构

        struct inotify_event {

              int      wd;      /* Watch descriptor */

              uint32_t mask;    /* Mask of events */

              uint32_t cookie;  /* Unique cookie associating related

                                    events (for rename(2)) */

              uint32_t len;      /* Size of name field */

              char    name[];  /* Optional null-terminated name */

          };

3. Mask

适用于 inotify_add_watch mask 与 read 返回的inotify_event中mask

IN_ACCESS文件被访问

IN_ATTRIB文件属性发生变化

IN_CLOSE_WRITE以write方式打开文件并关闭

IN_CLOSE_NOWRITE以非write方式打开文件并关闭

IN_CREATE文件或目录被创建

IN_DELETE文件或目录被删除(被监测的文件夹A中B文件被删除)

IN_DELETE_SELF被监测的文件或目录被删除(被监测的文件夹A被删除)

IN_MODIFY文件被修改

IN_MOVE_SELF被监测的文件或目录移动

IN_MOVED_FROM文件移出被监测的目录

IN_MOVED_TO文件移入被监测的目录

IN_OPEN文件被打开

上述flag的集合

IN_ALL_EVENTS以上所有flag的集合

IN_MOVEIN_MOVED_TO|IN_MOVED_FROM

IN_CLOSEIN_CLOSE_WRITE|IN_CLOSE_NOWRITE

不常用的flag

IN_DONT_FOLLOW不follow符号链接 (since 2.6.15)

IN_EXCL_UNLINK当文件从监测目中unlink后,则不再报告该文件的相关event,比如监控/tmp使用 (since 2.6.36)

IN_MASK_ADD追打MASK到被监测的pathname

IN_ONESHOT只监测一次

IN_ONLYDIR只监测目录

仅由read返回

IN_IGNOREDinotify_rm_watch,文件被删除或者文件系统被umount

IN_ISDIR发生事件的是一个目录

IN_Q_OVERFLOWEvent队列溢出

IN_UNMOUNT文件系统unmount

4. 例子

用途:监测指定文件或目录(或不指定则为当前目录)的一切动作。

使用:inotify [文件或目录]

[cpp] view plain copy

#include   

#include   

#include   

#include   

#include   

#include   

#include   


#define ERROR(text) error(1, errno, "%s", text)  


struct EventMask {  

int        flag;  

const char *name;  


};  


int freadsome(void *dest, size_t remain, FILE *file)  

{  

char *offset = (char*)dest;  

while (remain) {  

int n = fread(offset, 1, remain, file);  

if (n == 0) {  

return -1;  

        }  


        remain -= n;  

        offset += n;  

    }  

return 0;  

}  

//http://www.ibm.com/developerworks/cn/linux/l-inotify/  

//http://www.jiangmiao.org/blog/2179.html  

int main(int argc, char *argv[])  

{  

const char *target;  

if (argc == 1) {  

target =".";  

    }  

else {  

        target = argv[1];  

    }  


struct EventMask event_masks[] = {  

{ IN_ACCESS,"IN_ACCESS" },    

{ IN_ATTRIB,"IN_ATTRIB" },    

{ IN_CLOSE_WRITE,"IN_CLOSE_WRITE" },    

{ IN_CLOSE_NOWRITE,"IN_CLOSE_NOWRITE" },    

{ IN_CREATE,"IN_CREATE" },    

{ IN_DELETE,"IN_DELETE" },    

{ IN_DELETE_SELF,"IN_DELETE_SELF" },    

{ IN_MODIFY,"IN_MODIFY" },    

{ IN_MOVE_SELF,"IN_MOVE_SELF" },    

{ IN_MOVED_FROM,"IN_MOVED_FROM" },    

{ IN_MOVED_TO,"IN_MOVED_TO" },    

{ IN_OPEN,"IN_OPEN" },    


{ IN_DONT_FOLLOW,"IN_DONT_FOLLOW" },    

//{ IN_EXCL_UNLINK, "IN_EXCL_UNLINK" },    

{ IN_MASK_ADD,"IN_MASK_ADD" },    

{ IN_ONESHOT,"IN_ONESHOT" },    

{ IN_ONLYDIR,"IN_ONLYDIR" },    


{ IN_IGNORED,"IN_IGNORED" },    

{ IN_ISDIR,"IN_ISDIR" },    

{ IN_Q_OVERFLOW,"IN_Q_OVERFLOW" },    

{ IN_UNMOUNT,"IN_UNMOUNT" },    

    };  


int monitor = inotify_init();  

if (-1 == monitor) {  

ERROR("monitor");  

    }  


int watcher = inotify_add_watch(monitor, target, IN_ALL_EVENTS);  

if (-1 == watcher) {  

ERROR("inotify_add_watch error");  

    }  


FILE *monitor_file = fdopen(monitor, "r");  

char last_name[1024];  

char name[1024];  


/* event:inotify_event -> name:char[event.len] */  

while (true) {  

struct inotify_event event;  

if (-1 == freadsome(&event, sizeof(event), monitor_file)) {  

ERROR("freadsome error");  

        }  

if (event.len) {  

            freadsome(name, event.len, monitor_file);  

        }  

else {  

sprintf(name,"FD: %d\n", event.wd);  

        }  


if (strcmp(name, last_name) != 0) {  

            puts(name);  

            strcpy(last_name, name);  

        }  


/* 显示event的mask的含义 */  

int i = 0;  

for (i = 0; i < sizeof(event_masks) / sizeof(struct EventMask); ++i) {  

if (event.mask & event_masks[i].flag) {  


printf("\t%s\n", event_masks[i].name);  

            }  

        }  

    }  

return 0;  

}  



Linux系统中提供了一套intotify的机制来监视文件系统的事件,比如创建文件,打开,关闭等等。利用这一机制,我们可以很容易写出监控目录变化的工具。更何况更有了一个inotify_tools的开源工程呢。inotify_tools对inotify的API做了进一步的封装,更加方便使用。

下面的例子来源于inotify_tools的示例代码,但是做了一些改进。inotify_tools监视一个目录时,可以得到该目录变化的信息。但是在该目录下,创建一个子目录后,子目录中的变化,inotify_tools不能获取。所以我添加了动态监控目录的代码。

#include 

#include 

#include 

#include 

enum {

ACTION_NULL_WD,

ACTION_ADD_WD,

ACTION_DEL_WD,

};

int main(int argc, const char **argv)

{

int err = 0;

if (!inotifytools_initialize()) {

printf("inotifytools_initialize failedn");

goto error;

}

inotifytools_initialize_stats();

const char *monitor_path = ".";

if (argc > 1) {

monitor_path = argv[1];

}

printf("Monitor dir(%s)n", monitor_path);

if (!inotifytools_watch_recursively(monitor_path, IN_ALL_EVENTS)) {

printf("inotifytools_watch_recursively failedn");

goto error;

}

inotifytools_set_printf_timefmt("%F %T");

struct inotify_event * event = inotifytools_next_event(-1);

char path[256];

while (event) {

inotifytools_printf( event, "%T %w%f %en" );

if (IN_ISDIR&event->mask) {

int action = ACTION_NULL_WD;

if ((IN_DELETE|IN_DELETE_SELF|IN_MOVED_FROM)&event->mask) {

action = ACTION_DEL_WD;

snprintf(path, sizeof(path), "%s%s",

inotifytools_filename_from_wd(event->wd),

event->name);

printf("Remove path(%s) from wdn", path);

} else if (((IN_CREATE|IN_MOVED_TO)&event->mask) && (IN_ISDIR&event->mask)) {

action = ACTION_ADD_WD;

snprintf(path, sizeof(path), "%s%s",

inotifytools_filename_from_wd(event->wd),

event->name);

printf("Add path(%s) into wdn", path);

}

if (ACTION_ADD_WD == action) {

if (!inotifytools_watch_recursively(path, IN_ALL_EVENTS)) {

printf("inotifytools_watch_recursively failedn");

goto error;

}

} else if (ACTION_DEL_WD == action) {

if (!inotifytools_remove_watch_by_wd(event->wd)) {

printf("inotifytools_remove_watch_by_wd failed. event->wd(%d)n", event->wd);

goto error;

}

}

}

event = inotifytools_next_event(-1);

}

printf("Exitn");

return 0;

error:

err = inotifytools_error();

printf("Error(%d)n", err);

return -1;

}

代码很简单。就是在获得事件以后,检查是否为目录。如果是目录,则需要进行动态监控的检查。如果是创建动作,那么就添加新的监控。如果是删除动作,就去掉已有的监控wd。

上一篇:MySQL之数据类型


下一篇:redis数据库持久化问题处理