本文主要描述如何通過C#實現(xiàn)實時監(jiān)控文件目錄下的變化,包括文件和目錄的添加,刪除,修改和重命名等操作。
首先,我們需要對.net提供的FileSystemWatcher類有所了解。我有些懶,找了MSDN對該類的描述。
FileSystemWatcher類偵聽文件系統(tǒng)更改通知,并在目錄或目錄中的文件發(fā)生更改時引發(fā)事件。
使用 FileSystemWatcher 監(jiān)視指定目錄中的更改。可監(jiān)視指定目錄中的文件或子目錄的更改。可以創(chuàng)建一個組件來監(jiān)視本地計算機、網(wǎng)絡驅(qū)動器或遠程計算機上的文件。
若要監(jiān)視所有文件中的更改,請將 Filter 屬性設置為空字符串 ("") 或使用通配符(“*.*”)。若要監(jiān)視特定的文件,請將 Filter 屬性設置為該文件名。例如,若要監(jiān)視文件 MyDoc.txt 中的更改,請將 Filter 屬性設置為“MyDoc.txt”。也可以監(jiān)視特定類型文件中的更改。例如,若要監(jiān)視文本文件中的更改,請將 Filter 屬性設置為“*.txt”。
可監(jiān)視目錄或文件中的若干種更改。例如,可監(jiān)視文件或目錄的 Attributes、LastWrite 日期和時間或 Size 方面的更改。通過將 NotifyFilter 屬性設置為 NotifyFilters 值之一來達到此目的。有關可監(jiān)視的更改類型的更多信息,請參見 NotifyFilters。
可監(jiān)視文件或目錄的重命名、刪除或創(chuàng)建。例如,若要監(jiān)視文本文件的重命名,請將 Filter 屬性設置為“*.txt”,并使用為其參數(shù)指定的 Renamed 來調(diào)用 WaitForChanged 方法。
Windows 操作系統(tǒng)在 FileSystemWatcher 創(chuàng)建的緩沖區(qū)中通知組件文件發(fā)生更改。如果短時間內(nèi)有很多更改,則緩沖區(qū)可能會溢出。這將導致組件失去對目錄更改的跟蹤,并且它將只提供一般性通知。使用 InternalBufferSize 屬性來增加緩沖區(qū)大小的開銷較大,因為它來自無法換出到磁盤的非頁面內(nèi)存,所以應確保緩沖區(qū)大小適中(盡量小,但也要有足夠大小以便不會丟失任何文件更改事件)。若要避免緩沖區(qū)溢出,請使用 NotifyFilter 和 IncludeSubdirectories 屬性,以便可以篩選掉不想要的更改通知。
使用 FileSystemWatcher 類時,請注意以下事項。
1) 對包括隱藏文件(夾)在內(nèi)的所有文件(夾)進行監(jiān)控。
2) 您可以為 InternalBufferSize 屬性(用于監(jiān)視網(wǎng)絡上的目錄)設置的最大大小為 64 KB。
FileSystemWatcher的實例監(jiān)控到文件(夾)的變化后,會觸發(fā)相應的事件,其中文件(夾)的添加,刪除和修改會分別觸發(fā)Created,Deleted,Changed事件,文件(夾)重命名時觸發(fā)OnRenamed事件。
然后,在熟悉了FileSystemWatcher類后,我們開始自己的程序編寫。
實例化FileSystemWatcher類,并傳入需要監(jiān)控的目錄路徑,以及是否制定監(jiān)控的文件類型(文章前面有所介紹)。
_watcher = new FileSystemWatcher(_path, _filter);
注冊監(jiān)聽事件,以及編寫事件觸發(fā)后相關的處理邏輯。
_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;
在本程序中,專門定義了一個FileChangeInformation類來記錄文件變化信息,并定義了一個CustomQueue類,該類類似于Queue類,是一個數(shù)據(jù)先進先出的集合,用來存儲所有的文件變化消息,并提供數(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)控是否正在運行 14 /// </summary> 15 public bool IsWatch 16 { 17 get 18 { 19 return _isWatch; 20 } 21 } 22 23 /// <summary> 24 /// 文件變更信息隊列 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 /// 打開文件監(jiān)聽器 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 //注冊監(jiān)聽事件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 /// 關閉監(jiān)聽器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)聽事件觸發(fā)的方法142 /// </summary>143 /// <param name="sender"></param>144 /// <param name="e"></param>145 private void OnProcess(object sender, FileSystemEventArgs e)146 {147 try148 {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 else157 {158 changeType = FileChangeType.NewFile;159 }160 }161 else if (e.ChangeType == WatcherChangeTypes.Changed)162 {163 //部分
新聞熱點
疑難解答