c#使用filesystemwatcher實(shí)時(shí)監(jiān)控文件目錄的添加和刪除
首先，我們需要對(duì).net提供的FileSystemWatcher類有所了解。我有些懶，找了MSDN對(duì)該類的描述。
FileSystemWatcher類偵聽文件系統(tǒng)更改通知，并在目錄或目錄中的文件發(fā)生更改時(shí)引發(fā)事件。
使用 FileSystemWatcher 監(jiān)視指定目錄中的更改?？杀O(jiān)視指定目錄中的文件或子目錄的更改?？梢詣?chuàng)建一個(gè)組件來監(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 方面的更改。通過將 NotifyFilter 屬性設(shè)置為 NotifyFilters 值之一來達(dá)到此目的。有關(guān)可監(jiān)視的更改類型的更多信息，請(qǐng)參見 NotifyFilters。
可監(jiān)視文件或目錄的重命名、刪除或創(chuàng)建。例如，若要監(jiān)視文本文件的重命名，請(qǐng)將 Filter 屬性設(shè)置為“*.txt”，并使用為其參數(shù)指定的 Renamed 來調(diào)用 WaitForChanged 方法。
Windows 操作系統(tǒng)在 FileSystemWatcher 創(chuàng)建的緩沖區(qū)中通知組件文件發(fā)生更改。如果短時(shí)間內(nèi)有很多更改，則緩沖區(qū)可能會(huì)溢出。這將導(dǎo)致組件失去對(duì)目錄更改的跟蹤，并且它將只提供一般性通知。使用 InternalBufferSize 屬性來增加緩沖區(qū)大小的開銷較大，因?yàn)樗鼇碜詿o法換出到磁盤的非頁面內(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類后，我們開始自己的程序編寫。
實(shí)例化FileSystemWatcher類，并傳入需要監(jiān)控的目錄路徑，以及是否制定監(jiān)控的文件類型（文章前面有所介紹）。
_watcher = new FileSystemWatcher(_path, _filter);
注冊(cè)監(jiān)聽事件，以及編寫事件觸發(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類來記錄文件變化信息，并定義了一個(gè)CustomQueue類，該類類似于Queue類，是一個(gè)數(shù)據(jù)先進(jìn)先出的集合，用來存儲(chǔ)所有的文件變化消息，并提供數(shù)據(jù)持久化功能。
監(jiān)控類 - FileWatcher，代碼如下：
/// <summary>
/// 文件監(jiān)控類，用于監(jiān)控指定目錄下文件以及文件夾的變化
/// </summary>
public class FileWatcher
{
private FileSystemWatcher _watcher = null;
private string _path = string.Empty;
private string _filter = string.Empty;
private bool _isWatch = false;
private CustomQueue<FileChangeInformation> _queue = null;
/// <summary>
/// 監(jiān)控是否正在運(yùn)行
/// </summary>
public bool IsWatch
{
get
{
return _isWatch;
}
}
/// <summary>
/// 文件變更信息隊(duì)列
/// </summary>
public CustomQueue<FileChangeInformation> FileChangeQueue
{
get
{
return _queue;
}
}
/// <summary>
/// 初始化FileWatcher類
/// </summary>
/// <param name="path">監(jiān)控路徑</param>
public FileWatcher(string path)
{
_path = path;
_queue = new CustomQueue<FileChangeInformation>();
}
/// <summary>
/// 初始化FileWatcher類，并指定是否持久化文件變更消息
/// </summary>
/// <param name="path">監(jiān)控路徑</param>
/// <param name="isPersistence">是否持久化變更消息</param>
/// <param name="persistenceFilePath">持久化保存路徑</param>
public FileWatcher(string path, bool isPersistence, string persistenceFilePath)
{
_path = path;
_queue = new CustomQueue<FileChangeInformation>(isPersistence, persistenceFilePath);
}
/// <summary>
/// 初始化FileWatcher類，并指定是否監(jiān)控指定類型文件
/// </summary>
/// <param name="path">監(jiān)控路徑</param>
/// <param name="filter">指定類型文件，格式如:*.txt,*.doc,*.rar</param>
public FileWatcher(string path, string filter)
{
_path = path;
_filter = filter;
_queue = new CustomQueue<FileChangeInformation>();
}
/// <summary>
/// 初始化FileWatcher類，并指定是否監(jiān)控指定類型文件，是否持久化文件變更消息
/// </summary>
/// <param name="path">監(jiān)控路徑</param>
/// <param name="filter">指定類型文件，格式如:*.txt,*.doc,*.rar</param>
/// <param name="isPersistence">是否持久化變更消息</param>
/// <param name="persistenceFilePath">持久化保存路徑</param>
public FileWatcher(string path, string filter, bool isPersistence, string persistenceFilePath)
{
_path = path;
_filter = filter;
_queue = new CustomQueue<FileChangeInformation>(isPersistence, persistenceFilePath);
}
/// <summary>
/// 打開文件監(jiān)聽器
/// </summary>
public void Open()
{
if (!Directory.Exists(_path))
{
Directory.CreateDirectory(_path);
}
if (string.IsNullOrEmpty(_filter))
{
_watcher = new FileSystemWatcher(_path);
}
else
{
_watcher = new FileSystemWatcher(_path, _filter);
}
//注冊(cè)監(jiān)聽事件
_watcher.Created += new FileSystemEventHandler(OnProcess);
_watcher.Changed += new FileSystemEventHandler(OnProcess);
_watcher.Deleted += new FileSystemEventHandler(OnProcess);
_watcher.Renamed += new RenamedEventHandler(OnFileRenamed);
_watcher.IncludeSubdirectories = true;
_watcher.EnableRaisingEvents = true;
_isWatch = true;
}
/// <summary>
/// 關(guān)閉監(jiān)聽器
/// </summary>
public void Close()
{
_isWatch = false;
_watcher.Created -= new FileSystemEventHandler(OnProcess);
_watcher.Changed -= new FileSystemEventHandler(OnProcess);
_watcher.Deleted -= new FileSystemEventHandler(OnProcess);
_watcher.Renamed -= new RenamedEventHandler(OnFileRenamed);
_watcher.EnableRaisingEvents = false;
_watcher = null;
}
/// <summary>
/// 獲取一條文件變更消息
/// </summary>
/// <returns></returns>
public FileChangeInformation Get()
{
FileChangeInformation info = null;
if (_queue.Count > 0)
{
lock (_queue)
{
info = _queue.Dequeue();
}
}
return info;
}
/// <summary>
/// 監(jiān)聽事件觸發(fā)的方法
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void OnProcess(object sender, FileSystemEventArgs e)
{
try
{
FileChangeType changeType = FileChangeType.Unknow;
if (e.ChangeType == WatcherChangeTypes.Created)
{
if (File.GetAttributes(e.FullPath) == FileAttributes.Directory)
{
changeType = FileChangeType.NewFolder;
}
else
{
changeType = FileChangeType.NewFile;
}
}
else if (e.ChangeType == WatcherChangeTypes.Changed)
{
//部分文件創(chuàng)建時(shí)同樣觸發(fā)文件變化事件，此時(shí)記錄變化操作沒有意義
//如果
if (_queue.SelectAll(
delegate(FileChangeInformation fcm)
{
return fcm.NewPath == e.FullPath && fcm.ChangeType == FileChangeType.Change;
}).Count<FileChangeInformation>() > 0)
{
return;
}
//文件夾的變化，只針對(duì)創(chuàng)建，重命名和刪除動(dòng)作，修改不做任何操作。
//因?yàn)槲募A下任何變化同樣會(huì)觸發(fā)文件的修改操作，沒有任何意義.
if (File.GetAttributes(e.FullPath) == FileAttributes.Directory)
{
return;
}
changeType = FileChangeType.Change;
}
else if (e.ChangeType == WatcherChangeTypes.Deleted)
{
changeType = FileChangeType.Delete;
}
//創(chuàng)建消息，并壓入隊(duì)列中
FileChangeInformation info = new FileChangeInformation(Guid.NewGuid().ToString(), changeType, e.FullPath, e.FullPath, e.Name, e.Name);
_queue.Enqueue(info);
}
catch
{
Close();
}
}
/// <summary>
/// 文件或目錄重命名時(shí)觸發(fā)的事件
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void OnFileRenamed(object sender, RenamedEventArgs e)
{
try
{
//創(chuàng)建消息，并壓入隊(duì)列中
FileChangeInformation info = new FileChangeInformation(Guid.NewGuid().ToString(), FileChangeType.Rename, e.OldFullPath, e.FullPath, e.OldName, e.Name);
_queue.Enqueue(info);
}
catch
{
Close();
}
}
}
最后，功能調(diào)用如下：
//初始化監(jiān)控器
FileWatcher watcher = new FileWatcher(@"D:\");
watcher.Open();
FileChangeInformation fci = null;
//獲取消息
while (true)
{
//如果IsWatch為False，則可能監(jiān)控內(nèi)部發(fā)生異常終止了監(jiān)控，需要重新開啟監(jiān)控
if (watcher.IsWatch)
{
//隊(duì)列頂端的變更消息
fci = watcher.Get();
//處理消息的代碼
//Print(fci);
}
else
{
watcher.Open();
}
Thread.Sleep(1000);
}
該程序?qū)崿F(xiàn)了對(duì)文件目錄下所有子目錄和子文件的變化進(jìn)行監(jiān)控，并可通過FileChangeQueue屬性訪問文件變更消息，同時(shí)也可以設(shè)置其是否需要將數(shù)據(jù)持久化到磁盤文件中。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了Unity使用ScrollRect制作搖桿，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-04-04
這篇文章主要為大家詳細(xì)介紹了C#實(shí)現(xiàn)FTP客戶端的小案例，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-07-07
本篇文章是對(duì).Net中System.IO之Stream的使用進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-05-05
這篇文章主要介紹了C#畫圖之餅圖折線圖的實(shí)現(xiàn)方法,以實(shí)例形式講述了C#畫圖的完整實(shí)現(xiàn)過程,是非常實(shí)用的技巧,有不錯(cuò)的借鑒價(jià)值,需要的朋友可以參考下2014-09-09
這篇文章主要介紹了C#列出所有物理網(wǎng)絡(luò)適配器的方法,實(shí)例分析了C#操作網(wǎng)絡(luò)設(shè)備的技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-04-04
本文主要介紹了C#集合查詢Linq在項(xiàng)目中使用詳解，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05
這篇文章主要為大家詳細(xì)介紹了C#的并發(fā)機(jī)制，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-02-02
深入理解c# checked unchecked 關(guān)鍵字
本篇文章是對(duì)c#中的checked unchecked 關(guān)鍵字進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-05-05
這篇文章主要介紹了詳解C#多線程編程之進(jìn)程與線程的的相關(guān)資料，文中講解非常細(xì)致，代碼幫助大家更好的理解和學(xué)習(xí)，感興趣的朋友可以了解下2020-06-06
這篇文章介紹了C#單例模式與多線程的用法，文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-03-03