监控多个文件目录

jiangf

我现在要开发一个程序，程序的功能是监控30个目录。一旦该目录下有新文件就对新文件作处理，但这30个目录产生新文件的时间都不统一。我想用多线程的方式去监控处理这些目录，一个线程监控一个，如果这个目录下没有文件，该线程就休眠。但领导的意思是用单线程的方式来监控，这样会在维护上比较好控制。

大家看看有哪种办法更可靠方便，或者有啥更好的想法呢

ubuntuer

inotify

flw

你需要考虑四个问题：
1，启动的时候，对启动前已经存在的目录和文件如何处理；
2，运行的过程中，如果目录被删除了如何处理。
3，对性能的要求
4，对实时性的要求


可以用 inotify(7) 做，但是要考虑必要性，因为这会让程序变得复杂。

koolcoy

如果采用轮询的方式，一个线程监控30个目录跟一个线程监控1个目录有多大的区别？

lenky0401

FAM
lighttpd里用的这个来监控web资源文件是否被修改，lz可以参考一下。

http://oss.sgi.com/projects/fam/index.html
http://www.gnome.org/~veillard/gamin/index.html

@sky

还是inotify吧

albcamus

tripwire

ubuntuer

1. 
   
2. #include <stdio.h>
   
3. #include <unistd.h>
   
4. #include <sys/select.h>
   
5. #include <errno.h>
   
6. #include <sys/inotify.h>
   
7. 
   
8. typedef struct wd_name {
   
9.         int wd;
   
10.         char * name;
    
11. }WD;
    
12. 
    
13. #define MONITOR_NUM  3
    
14. char* files[MONITOR_NUM] = {
    
15.         "./a",
    
16.         "./b",
    
17.         "./c"
    
18. };
    
19. 
    
20. WD wd_array[MONITOR_NUM];
    
21. 
    
22. static void inotify_event_handler(struct inotify_event *event)
    
23. {  
    
24.         int i = 0;
    
25.         if (event->mask & IN_ISDIR)
    
26.          printf("Object type: %s\n", "Direcotory");
    
27.         else
    
28.         printf("Object type: %s\n", "file");
    
29.        
    
30.         for (i=0; i<MONITOR_NUM; i++)
    
31.          {
    
32.                 if (event->wd != wd_array[i].wd)
    
33.                         continue;
    
34.                 printf("Object name: %s\n", wd_array[i].name);
    
35.                 break;
    
36.          }
    
37.        
    
38.          if ( event->mask & IN_CREATE )
    
39.                  {
    
40.      if ( event->mask & IN_ISDIR )
    
41.       printf( "The directory %s was created.\n", event->name );      
    
42.      else
    
43.       printf( "The file %s was created.\n", event->name );
    
44.     }
    
45.    else if ( event->mask & IN_DELETE )
    
46.     {
    
47.      if ( event->mask & IN_ISDIR )
    
48.        printf( "The directory %s was deleted.\n", event->name );      
    
49.      else
    
50.        printf( "The file %s was deleted.\n", event->name );
    
51.     }
    
52.    else if ( event->mask & IN_MODIFY )
    
53.            {
    
54.      if ( event->mask & IN_ISDIR )
    
55.        printf( "The directory %s was modified.\n", event->name );
    
56.      else
    
57.        printf( "The file %s was modified.\n", event->name );
    
58.     }
    
59. }
    
60. 
    
61. int main(int argc, char **argv)
    
62. {  
    
63. int fd = 0;
    
64. int wd = 0;
    
65. int i = 0;
    
66. int len = 0;
    
67. int index = 0;  
    
68.        
    
69. unsigned char buf[1024] = {0};  
    
70. struct inotify_event *event = {0};  
    
71. 
    
72. fd = inotify_init();
    
73. if (fd < 0) {
    
74.                 printf("Fail to initialize inotify.\n");
    
75.                 return -1;
    
76.         }
    
77.        
    
78. for (i=0; i<MONITOR_NUM; i++) {
    
79.                 wd_array[i].name = files[i];
    
80.                 wd = inotify_add_watch(fd, wd_array[i].name, IN_CREATE | IN_MODIFY | IN_DELETE);
    
81.                 if (wd < 0) {
    
82.                         printf("Can't add watch for %s.\n", wd_array[i].name);
    
83.                         return -1;
    
84.                 }
    
85.                 wd_array[i].wd = wd;
    
86.         }
    
87.        
    
88. 
    
89. for (;;)
    
90. {   
    
91.         index = 0;
    
92.         len = 0;
    
93.         while (((len = read(fd, &buf, sizeof(buf))) < 0) && (errno == EINTR));     
    
94.   
    
95.   while (index < len)
    
96.                   {        
    
97.                           event = (struct inotify_event *)(buf + index);      
    
98.                           inotify_event_handler(event);        
    
99.                           index += sizeof(struct inotify_event) + event->len;      
    
100.                   }   
     
101.         }          
     
102.   
     
103. 
     
104. for (i=0; i<MONITOR_NUM; i++)
     
105.         inotify_rm_watch(fd, wd_array[i].wd);
     
106. 
     
107. close(fd);
     
108. 
     
109. return 0;
     
110. }
     
111. 
     

复制代码

我以前写的一个玩的inotify程序

ubuntuer

你这种情况只用IN_CREATE就可以了