監(jiān)控多個文件目錄

jiangf

我現(xiàn)在要開發(fā)一個程序，程序的功能是監(jiān)控30個目錄。一旦該目錄下有新文件就對新文件作處理，但這30個目錄產(chǎn)生新文件的時間都不統(tǒng)一。我想用多線程的方式去監(jiān)控處理這些目錄，一個線程監(jiān)控一個，如果這個目錄下沒有文件，該線程就休眠。但領(lǐng)導(dǎo)的意思是用單線程的方式來監(jiān)控，這樣會在維護上比較好控制。

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

ubuntuer

inotify

flw

你需要考慮四個問題：
1，啟動的時候，對啟動前已經(jīng)存在的目錄和文件如何處理；
2，運行的過程中，如果目錄被刪除了如何處理。
3，對性能的要求
4，對實時性的要求


可以用 inotify(7) 做，但是要考慮必要性，因為這會讓程序變得復(fù)雜。

koolcoy

如果采用輪詢的方式，一個線程監(jiān)控30個目錄跟一個線程監(jiān)控1個目錄有多大的區(qū)別？

lenky0401

FAM
lighttpd里用的這個來監(jiān)控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. 
     

復(fù)制代碼

我以前寫的一個玩的inotify程序

ubuntuer

你這種情況只用IN_CREATE就可以了