谈谈C#监控对象FileSystemWatcher使用感受.docx

谈谈C#文件监控对象FileSystemWatcher使用感受 最近在项目中有这么个需求，就是得去实时获取某个在无规律改变的文本文件中的内容。首先想到的是用程序定期去访问这个文件，因为对实时性要求很高，间隔不能超过1S，而且每次获取到文本内容都要去分发给WEB服务器做别的操作，而那个文本的写入有时候会频繁，1秒可能多次，但是也有可能在相当长一段时间内是没有任何写入的。这样一来如果每秒都去访问文件的话，一个是IO问题，还有就是每次操作都会引起后端一系列程序的反应，文本在长时间内无写入的话，一秒一次的触发一系列徒劳的事情太不可取了。最终发现了c#中的FileSystemWatcher对象，在应用FileSystemWatcher之前，首先了解一下这个对象的基本属性和事件，首先普及一下FileSystemWatcher基本知识。FileSystemWatcher基础属性： Path这个属性告诉FileSystemWatcher它需要监控哪条路径。例如，如果我们将这个属性设为“C:test”，对象就监控test目录下所有文件发生的所有改变（包括删除，修改，创建，重命名）。 IncludeSubDirectories这个属性说明FileSystemWatcher对象是否应该监控子目录中（所有文件）发生的改变。 Filter这个属性允许你过滤掉某些类型的文件发生的变化。例如，如果我们只希望在TXT文件被修改/新建/删除时提交通知，可以将这个属性设为“*txt”。在处理高流量或大型目录时，使用这个属性非常方便。NotifyFilter获取或设置要监视的更改类型。可以进一步的过滤要监控的更改类型，如watcher.NotifyFilter = NotifyFilters.LastAccess | NotifyFilters.LastWrite | NotifyFilters.FileName | NotifyFilters.DirectoryName;事件： Changed当被监控的目录中有一个文件被修改时，就提交这个事件。值得注意的是，这个事件可能会被提交多次，即使文件的内容仅仅发生一项改变。这是由于在保存文件时，文件的其它属性也发生了改变。 Created当被监控的目录新建一个文件时，就提交这个事件。如果你计划用这个事件移动新建的事件，你必须在事件处理器中写入一些错误处理代码，它能处理当前文件被其它进程使用的情况。之所以要这样做，是因为Created事件可能在建立文件的进程释放文件之前就被提交。如果你没有准备正确处理这种情况的代码，就可能出现异常。 Deleted当被监控的目录中有一个文件被删除，就提交这个事件。 Renamed当被监控的目录中有一个文件被重命名，就提交这个事件。 注：如果你没有将EnableRaisingEvents设为真，系统不会提交任何一个事件。如果有时FileSystemWatcher对象似乎无法工作，请首先检查EnableRaisingEvents，确保它被设为真。事件处理当FileSystemWatcher调用一个事件处理器时，它包含两个自变量一个叫做“sender”的对象和一个叫做“e”的 FileSystemEventArgs对象。我们感兴趣的自变量为FileSystemEventArgs自变量。这个对象中包含有提交事件的原因。以下是FileSystemEventArgs对象的一些属性：属性： Name这个属性中使事件被提交的文件的名称。其中并不包含文件的路径只包含使用事件被提交的文件或目录名称。 ChangeType这是一个WatcherChangeTypes，它指出要提交哪个类型的事件。其有效值包括： Changed Created Deleted Renamed FullPath这个属性中包含使事件被提交的文件的完整路径，包括文件名和目录名。 注意：FileSystemEventArgs对象是监控文件夹下有文件创建、删除、修改时的自变量，如果是重命名的话为RenamedEventArgs对象此时除了FileSystemEventArgs对象的属性值，多了一个OldFullPath，为重命名之前的文件名。以上为FileSystemEventArgs的基本知识，大部分是从网上搜找的然后自己稍微整理了一下。下面为简单用法：using System;using System.IO;namespace test class Program static void Main(string args) WatcherStrat(C:test, *.txt); /由于是控制台程序，加个输入避免主线程执行完毕，看不到监控效果 Console.ReadKey(); private static void WatcherStrat(string path, string filter) FileSystemWatcher watcher = new FileSystemWatcher(); watcher.Path = path; watcher.Filter = filter; watcher.Changed += new FileSystemEventHandler(OnProcess); watcher.Created += new FileSystemEventHandler(OnProcess); watcher.Deleted += new FileSystemEventHandler(OnProcess); watcher.Renamed += new RenamedEventHandler(OnRenamed); watcher.EnableRaisingEvents = true; private static void OnProcess(object source, FileSystemEventArgs e) if (e.ChangeType = WatcherChangeTypes.Created) OnCreated(source, e); else if (e.ChangeType = WatcherChangeTypes.Changed) OnChanged(source, e); else if (e.ChangeType = WatcherChangeTypes.Deleted) OnDeleted(source, e); private static void OnCreated(object source, FileSystemEventArgs e) Console.WriteLine(文件新建事件处理逻辑); private static void OnChanged(object source, FileSystemEventArgs e) Console.WriteLine(文件改变事件处理逻辑); private static void OnDeleted(object source, FileSystemEventArgs e) Console.WriteLine(文件删除事件处理逻辑); private static void OnRenamed(object source, RenamedEventArgs e) Console.WriteLine(文件重命名事件处理逻辑); 用上面的方法会发现，在一次文本文件变化的时候OnChanged事件会触发两次，这是因为除了文本内容变化之外还有文件其他的属性也变化了例如修改时间。 为了解决这问题，也便于项目当中实际使用，写了下面几个类来实际使用：主方法：using System;using System.IO;namespace test class Program static void Main(string args) MyFileSystemWather myWather = new MyFileSystemWather(C:test, *.txt); myWather.OnChanged += new FileSystemEventHandler(OnChanged); myWather.OnCreated += new FileSystemEventHandler(OnCreated); myWather.OnRenamed += new RenamedEventHandler(OnRenamed); myWather.OnDeleted += new FileSystemEventHandler(OnDeleted); myWather.Start(); /由于是控制台程序，加个输入避免主线程执行完毕，看不到监控效果 Console.ReadKey(); private static void OnCreated(object source, FileSystemEventArgs e) Console.WriteLine(文件新建事件处理逻辑); private static void OnChanged(object source, FileSystemEventArgs e) Console.WriteLine(文件改变事件处理逻辑); private static void OnDeleted(object source, FileSystemEventArgs e) Console.WriteLine(文件删除事件处理逻辑); private static void OnRenamed(object source, RenamedEventArgs e) Console.WriteLine(文件重命名事件处理逻辑); WatcherProcess类：using System.IO;namespace test public class WatcherProcess private object sender; private object eParam; public event RenamedEventHandler OnRenamed; public event FileSystemEventHandler OnChanged; public event FileSystemEventHandler OnCreated; public event FileSystemEventHandler OnDeleted; public event Completed OnCompleted; public WatcherProcess(object sender, object eParam) this.sender = sender; this.eParam = eParam; public void Process() if (eParam.GetType() = typeof(RenamedEventArgs) OnRenamed(sender, (RenamedEventArgs)eParam); OnCompleted(RenamedEventArgs)eParam).FullPath); else FileSystemEventArgs e = (FileSystemEventArgs)eParam; if (e.ChangeType = WatcherChangeTypes.Created) OnCreated(sender, e); OnCompleted(e.FullPath); else if (e.ChangeType = WatcherChangeTypes.Changed) OnChanged(sender, e); OnCompleted(e.FullPath); else if (e.ChangeType = WatcherChangeTypes.Deleted) OnDeleted(sender, e); OnCompleted(e.FullPath); else OnCompleted(e.FullPath); MyFileSystemWather类： using System;using System.Collections;using System.IO;using System.Threading;namespace test public delegate void Completed(string key); public class MyFileSystemWather private FileSystemWatcher fsWather; private Hashtable hstbWather; public event RenamedEventHandler OnRenamed; public event FileSystemEventHandler OnChanged; public event FileSystemEventHandler OnCreated; public event FileSystemEventHandler OnDeleted; / / 构造函数 / / 要监控的路径 public MyFileSystemWather(string path, string filter) if (!Directory.Exists(path) throw new Exception(找不到路径： + path); hstbWather = new Hashtable(); fsWather = new FileSystemWatcher(path); / 是否监控子目录 fsWather.IncludeSubdirectories = false; fsWather.Filter = filter; fsWather.Renamed += new RenamedEventHandler(fsWather_Renamed); fsWather.Changed += new FileSystemEventHandler(fsWather_Changed); fsWather.Created += new FileSystemEventHandler(fsWather_Created); fsWather.Deleted += new FileSystemEventHandler(fsWather_Deleted); / / 开始监控 / public void Start() fsWather.EnableRaisingEvents = true; / / 停止监控 / public void Stop() fsWather.EnableRaisingEvents = false; / / filesystemWatcher 本身的事件通知处理过程 / / / private void fsWather_Renamed(object sender, RenamedEventArgs e) lock (hstbWather) hstbWather.Add(e.FullPath, e); WatcherProcess watcherProcess = new WatcherProcess(sender, e); watcherProcess.OnCompleted += new Completed(WatcherProcess_OnCompleted); watcherProcess.OnRenamed += new RenamedEventHandler(WatcherProcess_OnRenamed); Thread thread = new Thread(watcherProcess.Process); thread.Start(); private void WatcherProcess_OnRenamed(object sender, RenamedEventArgs e) OnRenamed(sender, e); private void fsWather_Created(object sender, FileSystemEventArgs e) lock (hstbWather) hstbWather.Add(e.FullPath, e); WatcherProcess watcherProcess = new WatcherProcess(sender, e); watcherProcess.OnCompleted += new Completed(WatcherProcess_OnCompleted); watcherProcess.OnCreated += new FileSystemEventHandler(WatcherProcess_OnCreated); Thread threadDeal = new Thread(watcherProcess.Process); threadDeal.Start(); private void WatcherProcess_OnCreated(object sender, FileSystemEventArgs e) OnCreated(sender, e); private void fsWather_Deleted(object sender, FileSystemEventArgs e) lock (hstbWather) hstbWather.Add(e.FullPath, e); WatcherProcess watcherProcess = new WatcherProcess(sender, e); watcherProcess.OnCompleted += new Completed(WatcherProcess_OnCompleted); watcherProcess.OnDeleted += new FileSystemEventHandler(WatcherProcess_OnDeleted); Thread tdDeal = new Thread(watcherProcess.Process); tdDeal.Start(); private void WatcherProcess_OnDeleted(object sender, FileSystemEventArgs e) OnDeleted(sender, e); private void fsWather_Changed(object sender, FileSystemEventArgs e) if (e.ChangeType = WatcherChangeTypes.Changed) if (hstbWather.ContainsKey(e.FullPath) WatcherChangeTypes oldType = (FileSystemEventArgs)hstbWathere.FullPath).ChangeType; if (oldType = WatcherChangeTypes.Created | oldType = WatcherChangeTypes.Changed) return; lock (hstbWather) hstbWathe