C#使用文件监控对象FileSystemWatcher 实现数据

系统 2718 0

在C#使用文件监控对象FileSystemWatcher 实现数据同步

2013-12-12 18:24 by 幕三少,  352  阅读,  3  评论,  收藏 编辑

       最近在项目中有这么个需求,就是得去实时获取某个在无规律改变的文本文件中的内容。首先想到的是用程序定期去访问这个文件,因为对实时性要求很高,间隔不能超过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.Collections.Generic;


          
          
            using
          
          
             System.IO;


          
          
            using
          
          
             System.Linq;


          
          
            using
          
          
             System.Text;


          
          
            using
          
          
             System.Windows;


          
          
            using
          
          
             System.Windows.Controls;


          
          
            using
          
          
             System.Windows.Data;


          
          
            using
          
          
             System.Windows.Documents;


          
          
            using
          
          
             System.Windows.Input;


          
          
            using
          
          
             System.Windows.Media;


          
          
            using
          
          
             System.Windows.Media.Imaging;


          
          
            using
          
          
             System.Windows.Navigation;


          
          
            using
          
          
             System.Windows.Shapes;




          
          
            namespace
          
          
             WpfApplication1

{

    
          
          
            ///
          
          
            <summary>
          
          
            ///
          
          
             MainWindow.xaml 的交互逻辑

    
          
          
            ///
          
          
            </summary>
          
          
            public
          
          
            partial
          
          
            class
          
          
             MainWindow : Window

    {

        
          
          
            public
          
          
             MainWindow()

        {

            InitializeComponent();

            

        }



        
          
          
            private
          
          
            void
          
           button1_Click(
          
            object
          
          
             sender, RoutedEventArgs e)

        {

            FileSystemWatcher watcher 
          
          = 
          
            new
          
          
             FileSystemWatcher();

            watcher.Path 
          
          = 
          
            @"
          
          
            C:\test
          
          
            "
          
          
            ;

            watcher.IncludeSubdirectories 
          
          = 
          
            true
          
          
            ;

            watcher.NotifyFilter 
          
          = NotifyFilters.LastAccess |
          
             NotifyFilters.LastWrite

                                   
          
          | NotifyFilters.FileName |
          
             NotifyFilters.DirectoryName;

            watcher.Filter 
          
          = 
          
            "
          
          
            *.txt
          
          
            "
          
          
            ;



            watcher.Changed 
          
          += (s,e1)=> 
          
            this
          
          .Dispatcher.Invoke(
          
            new
          
           Action(() =>
          
            

            {

                label1.Content 
          
          = e1.Name + 
          
            "
          
          
            被修改!
          
          
            "
          
          
            ;

            }));

            watcher.Created 
          
          += (s, e1) =>  
          
            this
          
          .Dispatcher.Invoke(
          
            new
          
           Action(() => { label1.Content = e1.Name + 
          
            "
          
          
            被添加!
          
          
            "
          
          
            ; }));

            watcher.Deleted 
          
          += (s, e1) =>  
          
            this
          
          .Dispatcher.Invoke(
          
            new
          
           Action(() => { label1.Content = e1.Name + 
          
            "
          
          
            被删除!
          
          
            "
          
          
            ; }));

            watcher.Renamed 
          
          += (s, e1) =>  
          
            this
          
          .Dispatcher.Invoke(
          
            new
          
           Action(() =>
          
            

            {

                label1.Content 
          
          = e1.OldName + 
          
            "
          
          
            被重命名为:
          
          
            "
          
          +
          
            e1.Name;

            }));



            
          
          
            //
          
          
            开始监视
          
          

            watcher.EnableRaisingEvents = 
          
            true
          
          
            ;

        }

    }

}
          
        

 

C#使用文件监控对象FileSystemWatcher 实现数据同步


更多文章、技术交流、商务合作、联系博主

微信扫码或搜索:z360901061

微信扫一扫加我为好友

QQ号联系: 360901061

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描下面二维码支持博主2元、5元、10元、20元等您想捐的金额吧,狠狠点击下面给点支持吧,站长非常感激您!手机微信长按不能支付解决办法:请将微信支付二维码保存到相册,切换到微信,然后点击微信右上角扫一扫功能,选择支付二维码完成支付。

【本文对您有帮助就好】

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描上面二维码支持博主2元、5元、10元、自定义金额等您想捐的金额吧,站长会非常 感谢您的哦!!!

发表我的评论
最新评论 总共0条评论