使用FileSystemWatcher监视文件变化

简介: 本文转载:http://www.cnblogs.com/zanxiaofeng/archive/2011/01/08/1930583.html FileSystemWatcher基础 属性:     Path——这个属性告诉FileSystemWatcher它需要监控哪条路径。

本文转载:http://www.cnblogs.com/zanxiaofeng/archive/2011/01/08/1930583.html

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,确保它被设为真。

问题:

  程序里需要监视某个目录下的文件变化情况: 一旦目录中出现新文件或者旧的文件被覆盖,程序需要读取文件内容并进行处理;但在实际处理中发现当一个文件产生变化时,Change事件被反复触发了好几次。这样可能的结果是造成同一文件的重复处理。
解决方法:

  针对上面的问题,于是写了一个可以延迟FileSystemWatcher发出的事件的Class DelayFileSystemWatcher。

复制代码
using System;
using System.Collections.Generic;
using System.IO;
using System.Threading;

namespace Utility
{
public class DelayFileSystemWatcher
{
private readonly Timer m_Timer;
private readonly Int32 m_TimerInterval;
private readonly FileSystemWatcher m_FileSystemWatcher;
private readonly FileSystemEventHandler m_FileSystemEventHandler;
private readonly Dictionary<String, FileSystemEventArgs> m_ChangedFiles = new Dictionary<string, FileSystemEventArgs>();

public DelayFileSystemWatcher(string path, string filter, FileSystemEventHandler watchHandler, int timerInterval)
{
m_Timer = new Timer(OnTimer, null, Timeout.Infinite, Timeout.Infinite);
m_FileSystemWatcher = new FileSystemWatcher(path, filter);
m_FileSystemWatcher.NotifyFilter = NotifyFilters.FileName | NotifyFilters.LastWrite | NotifyFilters.CreationTime;
m_FileSystemWatcher.Created += fileSystemWatcher_Changed;
m_FileSystemWatcher.Changed += fileSystemWatcher_Changed;
m_FileSystemWatcher.Deleted += fileSystemWatcher_Changed;
m_FileSystemWatcher.Renamed += fileSystemWatcher_Changed;
m_FileSystemWatcher.EnableRaisingEvents = true;
m_FileSystemEventHandler = watchHandler;
m_TimerInterval = timerInterval;
}

public void fileSystemWatcher_Changed(object sender, FileSystemEventArgs e)
{
lock (m_ChangedFiles)
{
if (!m_ChangedFiles.ContainsKey(e.Name))
{
m_ChangedFiles.Add(e.Name, e);
}
}
m_Timer.Change(m_TimerInterval, Timeout.Infinite);
}

private void OnTimer(object state)
{
Dictionary<String, FileSystemEventArgs> tempChangedFiles = new Dictionary<String, FileSystemEventArgs>();

lock (m_ChangedFiles)
{
foreach (KeyValuePair<string, FileSystemEventArgs> changedFile in m_ChangedFiles)
{
tempChangedFiles.Add(changedFile.Key, changedFile.Value);
}
m_ChangedFiles.Clear();
}

foreach (KeyValuePair<string, FileSystemEventArgs> changedFile in tempChangedFiles)
{
m_FileSystemEventHandler(this, changedFile.Value);
}
}
}
}
复制代码

使用方式如下:

复制代码
        s_DelayFileSystemWatcher = new DelayFileSystemWatcher(@"C:\Temp", "*.xml", fileSystemWatcher_Changed, 1500);

private static void fileSystemWatcher_Changed(object sender, FileSystemEventArgs e)
{
switch (e.ChangeType)
{
case WatcherChangeTypes.Created:
//TODO
break;
case WatcherChangeTypes.Deleted:
//TODO
break;
case WatcherChangeTypes.Changed:
//TODO
break;
default:
break;
}
}
复制代码
目录
相关文章
|
监控 API C++
一个更好的文件监控类,基于 DotNet 官方提供的 FileSystemWatcher
一个更好的文件监控类,基于 DotNet 官方提供的 FileSystemWatcher
|
存储 SQL 分布式计算
Flink - 读取 Parquet 文件 By Scala / Java
parquet 文件常见与 Flink、Spark、Hive、Streamin、MapReduce 等大数据场景,通过列式存储和元数据存储的方式实现了高效的数据存储与检索,下面介绍 Flink 场景下如何读取 Parquet。
2204 0
Flink - 读取 Parquet 文件 By Scala / Java
|
2月前
|
算法 Java Sentinel
高可用架构核心:限流熔断降级全解,Sentinel 与 Resilience4j 原理 + 落地实战
本文深入解析分布式系统高可用三大核心手段——限流、熔断、降级的本质与边界,对比剖析Sentinel(全链路流量治理)与Resilience4j(轻量函数式容错)的底层原理、实战配置及选型策略,并提供生产环境最佳实践与避坑指南。
653 1
|
监控 安全 C#
使用C#如何监控选定文件夹中文件的变动情况?
使用C#如何监控选定文件夹中文件的变动情况?
492 19
|
Linux 数据库
解决linux中无法使用RPM命令
解决linux中无法使用RPM命令
697 0
|
XML 数据格式
Karl_Albright:Rougamo、Fody 实现静态Aop
4. Fody 有很多其他的“插件”,大家可以多试试 AutoProperties.Fody: 这个外接程序为您提供了对自动属性的扩展控制,比如直接访问backing字段或拦截getter和setter。 PropertyChanged.Fody: 将属性通知添加到实现INotifyPropertyChanged的所有类。 InlineIL.Fody: 在编译时注入任意IL代码。 MethodDecorator.Fody:通过IL重写编译时间装饰器模式。 NullGuard.Fody: 将空参数检查添加到程序集。
293 4
|
应用服务中间件 Apache nginx
【独家揭秘】502 Bad Gateway不再神秘!五大绝招教你快速定位并解决,从此告别网络烦恼!
【8月更文挑战第19天】遇到502 &quot;Bad Gateway&quot;错误让不少开发者头疼。此错误指示Web服务器作为代理收到无效响应。本文将分步骤指导如何排查与解决502问题:首先检查服务器日志文件寻找线索;接着验证后端服务器状态及连通性;然后审查Web服务器配置确保代理设置无误;再检测后端服务器响应时间避免超时;最后利用抓包工具深入分析网络通信。遵循这些步骤,可助你高效定位并解决502错误。
10983 0
|
SQL 前端开发 NoSQL
关于幂等:大厂如何解决幂等问题?
为确保分布式系统中接口的幂等性,防止重复下单及更新数据时出现ABA问题,可采取以下措施:首先,每个请求需具备唯一标识符,如订单ID,确保同一订单ID仅能成功处理一次。其次,处理请求后需记录状态标识,如在数据库中记录支付流水。接收请求时检查是否已处理,利用数据库的唯一性约束防止重复操作。例如,支付前插入支付流水记录,若订单ID已存在,则阻止重复支付。此外,为解决ABA问题,可在订单表中增加版本号字段,更新数据时需验证版本号一致性并同步递增版本号,确保数据正确性及更新操作的幂等性。
|
存储 NoSQL 搜索推荐
详解:图数据库 GDB五大应用场景
图数据库GDB针对高度互联数据的存储和查询场景进行设计,并在内核层面进行了大量优化,非常适合社交网络、欺诈检测、推荐引擎、知识图谱、网络/IT运营等高密互连数据集的场景。
3730 0