西西軟件園多重安全檢測(cè)下載網(wǎng)站、值得信賴的軟件下載站!
軟件
軟件
文章
搜索

首頁(yè)編程開(kāi)發(fā)C#.NET → C#編程中怎么對(duì)文件目錄進(jìn)行實(shí)時(shí)監(jiān)控

C#編程中怎么對(duì)文件目錄進(jìn)行實(shí)時(shí)監(jiān)控

相關(guān)軟件相關(guān)文章發(fā)表評(píng)論 來(lái)源:西西整理時(shí)間:2014/1/24 17:50:10字體大。A-A+

作者:西西點(diǎn)擊:367次評(píng)論:0次標(biāo)簽: 目錄監(jiān)控

  • 類型:系統(tǒng)其它大。1.2M語(yǔ)言:中文 評(píng)分:5.0
  • 標(biāo)簽:
立即下載

本文主要描述如何通過(guò)C#實(shí)現(xiàn)實(shí)時(shí)監(jiān)控文件目錄下的變化,包括文件和目錄的添加,刪除,修改和重命名等操作。

首先,我們需要對(duì).net提供的FileSystemWatcher類有所了解。我有些懶,找了MSDN對(duì)該類的描述。

FileSystemWatcher類偵聽(tīng)文件系統(tǒng)更改通知,并在目錄或目錄中的文件發(fā)生更改時(shí)引發(fā)事件。

使用 FileSystemWatcher 監(jiān)視指定目錄中的更改?杀O(jiān)視指定目錄中的文件或子目錄的更改?梢詣(chuàng)建一個(gè)組件來(lái)監(jiān)視本地計(jì)算機(jī)、網(wǎng)絡(luò)驅(qū)動(dòng)器或遠(yuǎn)程計(jì)算機(jī)上的文件。

若要監(jiān)視所有文件中的更改,請(qǐng)將 Filter 屬性設(shè)置為空字符串 ("") 或使用通配符(“*.*”)。若要監(jiān)視特定的文件,請(qǐng)將 Filter 屬性設(shè)置為該文件名。例如,若要監(jiān)視文件 MyDoc.txt 中的更改,請(qǐng)將 Filter 屬性設(shè)置為“MyDoc.txt”。也可以監(jiān)視特定類型文件中的更改。例如,若要監(jiān)視文本文件中的更改,請(qǐng)將 Filter 屬性設(shè)置為“*.txt”。

可監(jiān)視目錄或文件中的若干種更改。例如,可監(jiān)視文件或目錄的 Attributes、LastWrite 日期和時(shí)間或 Size 方面的更改。通過(guò)將 NotifyFilter 屬性設(shè)置為 NotifyFilters 值之一來(lái)達(dá)到此目的。有關(guān)可監(jiān)視的更改類型的更多信息,請(qǐng)參見(jiàn) NotifyFilters。

可監(jiān)視文件或目錄的重命名、刪除或創(chuàng)建。例如,若要監(jiān)視文本文件的重命名,請(qǐng)將 Filter 屬性設(shè)置為“*.txt”,并使用為其參數(shù)指定的 Renamed 來(lái)調(diào)用 WaitForChanged 方法。

Windows 操作系統(tǒng)在 FileSystemWatcher 創(chuàng)建的緩沖區(qū)中通知組件文件發(fā)生更改。如果短時(shí)間內(nèi)有很多更改,則緩沖區(qū)可能會(huì)溢出。這將導(dǎo)致組件失去對(duì)目錄更改的跟蹤,并且它將只提供一般性通知。使用 InternalBufferSize屬性來(lái)增加緩沖區(qū)大小的開(kāi)銷較大,因?yàn)樗鼇?lái)自無(wú)法換出到磁盤的非頁(yè)面內(nèi)存,所以應(yīng)確保緩沖區(qū)大小適中(盡量小,但也要有足夠大小以便不會(huì)丟失任何文件更改事件)。若要避免緩沖區(qū)溢出,請(qǐng)使用 NotifyFilter 和IncludeSubdirectories 屬性,以便可以篩選掉不想要的更改通知。

使用 FileSystemWatcher 類時(shí),請(qǐng)注意以下事項(xiàng)。

1) 對(duì)包括隱藏文件(夾)在內(nèi)的所有文件(夾)進(jìn)行監(jiān)控。

2) 您可以為 InternalBufferSize 屬性(用于監(jiān)視網(wǎng)絡(luò)上的目錄)設(shè)置的最大大小為 64 KB。

FileSystemWatcher的實(shí)例監(jiān)控到文件(夾)的變化后,會(huì)觸發(fā)相應(yīng)的事件,其中文件(夾)的添加,刪除和修改會(huì)分別觸發(fā)Created,Deleted,Changed事件,文件(夾)重命名時(shí)觸發(fā)OnRenamed事件。

然后,在熟悉了FileSystemWatcher類后,我們開(kāi)始自己的程序編寫(xiě)。

實(shí)例化FileSystemWatcher類,并傳入需要監(jiān)控的目錄路徑,以及是否制定監(jiān)控的文件類型(文章前面有所介紹)。

_watcher = new FileSystemWatcher(_path, _filter);

注冊(cè)監(jiān)聽(tīng)事件,以及編寫(xiě)事件觸發(fā)后相關(guān)的處理邏輯。

_watcher.Created += new FileSystemEventHandler(OnChanged);

_watcher.Changed += new FileSystemEventHandler(OnChanged);

_watcher.Deleted += new FileSystemEventHandler(OnChanged);

_watcher.Renamed += new RenamedEventHandler(OnRenamed);

_watcher.IncludeSubdirectories = true;

_watcher.EnableRaisingEvents = true;

在本程序中,專門定義了一個(gè)FileChangeInformation類來(lái)記錄文件變化信息,并定義了一個(gè)CustomQueue類,該類類似于Queue類,是一個(gè)數(shù)據(jù)先進(jìn)先出的集合,用來(lái)存儲(chǔ)所有的文件變化消息,并提供數(shù)據(jù)持久化功能。

監(jiān)控類 - FileWatcher,代碼如下:

 1  /// <summary>

  2     /// 文件監(jiān)控類,用于監(jiān)控指定目錄下文件以及文件夾的變化

  3     /// </summary>

  4     public class FileWatcher

  5     {

  6         private FileSystemWatcher _watcher = null;

  7         private string _path = string.Empty;

  8         private string _filter = string.Empty;

  9         private bool _isWatch = false;

 10         private CustomQueue<FileChangeInformation> _queue = null;

 11 

 12         /// <summary>

 13         /// 監(jiān)控是否正在運(yùn)行

 14         /// </summary>

 15         public bool IsWatch

 16         {

 17             get

 18             {

 19                 return _isWatch;

 20             }

 21         }

 22 

 23         /// <summary>

 24         /// 文件變更信息隊(duì)列

 25         /// </summary>

 26         public CustomQueue<FileChangeInformation> FileChangeQueue

 27         {

 28             get

 29             {

 30                 return _queue;

 31             }

 32         }

 33 

 34         /// <summary>

 35         /// 初始化FileWatcher類

 36         /// </summary>

 37         /// <param name="path">監(jiān)控路徑</param>

 38         public FileWatcher(string path)

 39         {

 40             _path = path;

 41             _queue = new CustomQueue<FileChangeInformation>();

 42         }

 43         /// <summary>

 44         /// 初始化FileWatcher類,并指定是否持久化文件變更消息

 45         /// </summary>

 46         /// <param name="path">監(jiān)控路徑</param>

 47         /// <param name="isPersistence">是否持久化變更消息</param>

 48         /// <param name="persistenceFilePath">持久化保存路徑</param>

 49         public FileWatcher(string path, bool isPersistence, string persistenceFilePath)

 50         {

 51             _path = path;

 52             _queue = new CustomQueue<FileChangeInformation>(isPersistence, persistenceFilePath);

 53         }

 54 

 55         /// <summary>

 56         /// 初始化FileWatcher類,并指定是否監(jiān)控指定類型文件

 57         /// </summary>

 58         /// <param name="path">監(jiān)控路徑</param>

 59         /// <param name="filter">指定類型文件,格式如:*.txt,*.doc,*.rar</param>

 60         public FileWatcher(string path, string filter)

 61         {

 62             _path = path;

 63             _filter = filter;

 64             _queue = new CustomQueue<FileChangeInformation>();

 65         }

 66 

 67         /// <summary>

 68         /// 初始化FileWatcher類,并指定是否監(jiān)控指定類型文件,是否持久化文件變更消息

 69         /// </summary>

 70         /// <param name="path">監(jiān)控路徑</param>

 71         /// <param name="filter">指定類型文件,格式如:*.txt,*.doc,*.rar</param>

 72         /// <param name="isPersistence">是否持久化變更消息</param>

 73         /// <param name="persistenceFilePath">持久化保存路徑</param>

 74         public FileWatcher(string path, string filter, bool isPersistence, string persistenceFilePath)

 75         {

 76             _path = path;

 77             _filter = filter;

 78             _queue = new CustomQueue<FileChangeInformation>(isPersistence, persistenceFilePath);

 79         }

 80 

 81         /// <summary>

 82         /// 打開(kāi)文件監(jiān)聽(tīng)器

 83         /// </summary>

 84         public void Open()

 85         {

 86             if (!Directory.Exists(_path))

 87             {

 88                 Directory.CreateDirectory(_path);

 89             }

 90 

 91             if (string.IsNullOrEmpty(_filter))

 92             {

 93                 _watcher = new FileSystemWatcher(_path);

 94             }

 95             else

 96             {

 97                 _watcher = new FileSystemWatcher(_path, _filter);

 98             }

 99             //注冊(cè)監(jiān)聽(tīng)事件

100             _watcher.Created += new FileSystemEventHandler(OnProcess);

101             _watcher.Changed += new FileSystemEventHandler(OnProcess);

102             _watcher.Deleted += new FileSystemEventHandler(OnProcess);

103             _watcher.Renamed += new RenamedEventHandler(OnFileRenamed);

104             _watcher.IncludeSubdirectories = true;

105             _watcher.EnableRaisingEvents = true;

106             _isWatch = true;

107         }

108 

109         /// <summary>

110         /// 關(guān)閉監(jiān)聽(tīng)器

111         /// </summary>

112         public void Close()

113         {

114             _isWatch = false;

115             _watcher.Created -= new FileSystemEventHandler(OnProcess);

116             _watcher.Changed -= new FileSystemEventHandler(OnProcess);

117             _watcher.Deleted -= new FileSystemEventHandler(OnProcess);

118             _watcher.Renamed -= new RenamedEventHandler(OnFileRenamed);

119             _watcher.EnableRaisingEvents = false;

120             _watcher = null;

121         }

122 

123         /// <summary>

124         /// 獲取一條文件變更消息

125         /// </summary>

126         /// <returns></returns>

127         public FileChangeInformation Get()

128         {

129             FileChangeInformation info = null;

130             if (_queue.Count > 0)

131             {

132                 lock (_queue)

133                 {

134                     info = _queue.Dequeue();

135                 }

136             }

137             return info;

138         }

139 

140         /// <summary>

141         /// 監(jiān)聽(tīng)事件觸發(fā)的方法

142         /// </summary>

143         /// <param name="sender"></param>

144         /// <param name="e"></param>

145         private void OnProcess(object sender, FileSystemEventArgs e)

146         {

147             try

148             {

149                 FileChangeType changeType = FileChangeType.Unknow;

150                 if (e.ChangeType == WatcherChangeTypes.Created)

151                 {

152                     if (File.GetAttributes(e.FullPath) == FileAttributes.Directory)

153                     {

154                         changeType = FileChangeType.NewFolder;

155                     }

156                     else

157                     {

158                         changeType = FileChangeType.NewFile;

159                     }

160                 }

161                 else if (e.ChangeType == WatcherChangeTypes.Changed)

162                 {

163                     //部分文件創(chuàng)建時(shí)同樣觸發(fā)文件變化事件,此時(shí)記錄變化操作沒(méi)有意義

164                     //如果

165                     if (_queue.SelectAll(

166                         delegate(FileChangeInformation fcm)

167                         {

168                             return fcm.NewPath == e.FullPath && fcm.ChangeType == FileChangeType.Change;

169                         }).Count<FileChangeInformation>() > 0)

170                     {

171                         return;

172                     }

173 

174                     //文件夾的變化,只針對(duì)創(chuàng)建,重命名和刪除動(dòng)作,修改不做任何操作。

175                     //因?yàn)槲募䦅A下任何變化同樣會(huì)觸發(fā)文件的修改操作,沒(méi)有任何意義.

176                     if (File.GetAttributes(e.FullPath) == FileAttributes.Directory)

177                     {

178                         return;

179                     }

180 

181                     changeType = FileChangeType.Change;

182                 }

183                 else if (e.ChangeType == WatcherChangeTypes.Deleted)

184                 {

185                     changeType = FileChangeType.Delete;

186                 }

187 

188                 //創(chuàng)建消息,并壓入隊(duì)列中

189                 FileChangeInformation info = new FileChangeInformation(Guid.NewGuid().ToString(), changeType, e.FullPath, e.FullPath, e.Name, e.Name);

190                 _queue.Enqueue(info);

191             }

192             catch

193             {

194                 Close();

195             }

196         }

197 

198         /// <summary>

199         /// 文件或目錄重命名時(shí)觸發(fā)的事件

200         /// </summary>

201         /// <param name="sender"></param>

202         /// <param name="e"></param>

203         private void OnFileRenamed(object sender, RenamedEventArgs e)

204         {

205             try

206             {

207                 //創(chuàng)建消息,并壓入隊(duì)列中

208                 FileChangeInformation info = new FileChangeInformation(Guid.NewGuid().ToString(), FileChangeType.Rename, e.OldFullPath, e.FullPath, e.OldName, e.Name);

209                 _queue.Enqueue(info);

210             }

211             catch

212             {

213                 Close();

214             }

215         }

216     }

最后,功能調(diào)用如下:

1 //初始化監(jiān)控器

 2                 FileWatcher watcher = new FileWatcher(@"D:\");

 3                 watcher.Open();

 4 

 5                 FileChangeInformation fci = null;

 6                 //獲取消息

 7                 while (true)

 8                 {

 9                     //如果IsWatch為False,則可能監(jiān)控內(nèi)部發(fā)生異常終止了監(jiān)控,需要重新開(kāi)啟監(jiān)控

10                     if (watcher.IsWatch)

11                     {

12                         //隊(duì)列頂端的變更消息

13                         fci = watcher.Get();

14                         //處理消息的代碼

15                         //Print(fci);

16                     }

17                     else

18                     {

19                         watcher.Open();

20                     }

21                     Thread.Sleep(1000);

22                 }

該程序?qū)崿F(xiàn)了對(duì)文件目錄下所有子目錄和子文件的變化進(jìn)行監(jiān)控,并可通過(guò)FileChangeQueue屬性訪問(wèn)文件變更消息,同時(shí)也可以設(shè)置其是否需要將數(shù)據(jù)持久化到磁盤文件中。

需要源碼的M我:GavinLeeChang@126.com

    相關(guān)評(píng)論

    閱讀本文后您有什么感想? 已有人給出評(píng)價(jià)!

    • 8 喜歡喜歡
    • 3 頂
    • 1 難過(guò)難過(guò)
    • 5 囧
    • 3 圍觀圍觀
    • 2 無(wú)聊無(wú)聊

    熱門評(píng)論

    最新評(píng)論

    發(fā)表評(píng)論 查看所有評(píng)論(0)

    昵稱:
    表情: 高興 可 汗 我不要 害羞 好 下下下 送花 屎 親親
    字?jǐn)?shù): 0/500 (您的評(píng)論需要經(jīng)過(guò)審核才能顯示)