专栏首页跟着阿笨一起玩NET使用延迟的FileSystemWatcher来避免重复触发事件

使用延迟的FileSystemWatcher来避免重复触发事件

问题:

  程序里需要监视某个目录下的文件变化情况: 一旦目录中出现新文件或者旧的文件被覆盖,程序需要读取文件内容并进行处理;但在实际处理中发现当一个文件产生变化时,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;
            }
        }

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 使用FileSystemWatcher监视文件变化

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

    跟着阿笨一起玩NET
  • C# 中参数验证方式的演变

    一般在写方法的时候,第一步就是进行参数验证,这也体现了编码者的细心和缜密,但是在很多时候这个过程很枯燥和乏味,比如在拿到一个API设计文档的时候,通常会规定类型...

    跟着阿笨一起玩NET
  • 通过内存盘提高MSMQ的消息吞吐能力

    转载:http://www.ikende.com/blog/00f2634be4704b79a3e22439edeb1343

    跟着阿笨一起玩NET
  • Redis笔记(五):Redis发布订阅

    Redis 发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息。

    朝雨忆轻尘
  • 通过腾讯云活动购买了云服务器,如何购买和挂载数据盘到服务器上

    现在很多用户在购买腾讯云服务器的时候,大多都会选择通过腾讯云的最新优惠活动去购买,毕竟腾讯云针对云服务器提供的活动众多,且折扣力度都挺大的,例如腾讯云秒杀活动、...

    tengxunyun8点com
  • Linux基础之文件系统 原

    Linux kernel自2.6.28开始正式支持新的文件系统Ext4,Ext4是Ext3的改进版,修改了Ext3中部分重要的数据结构。Ext3对Ext2,只是...

    云飞扬
  • 响铃:Vine陨落,秒拍崛起,谁在主导这场生死游戏?

    10 月 27 日,Twitter 发布公告称,未来将不再继续开发 Vine,包括网站和App都将暂停更新,用户可以继续浏览,但无法上传,这就意味着短视频社交“...

    曾响铃
  • 快速学习Shiro-Shiro安全框架

    Apache Shiro是一个强大且易用的Java安全框架,执行身份验证、授权、密码和会话管理。使用Shiro的易于理解的API,您可以快速、轻松地获得任何应用...

    cwl_java
  • Shell脚本中字符串的一些常用操作

    ${string:position:length} 在${string}中, 从位置${position}开始提取长度为${length}的子串

    卡尔曼和玻尔兹曼谁曼
  • 高并发系统的限流算法与实现

    限流是限制系统的输入和输出流量,以达到保护系统的目的,而限流的实现主要是依靠限流算法,限流算法主要有4种:

    全菜工程师小辉

扫码关注云+社区

领取腾讯云代金券