欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

c#实现数据同步的方法(使用文件监控对象filesystemwatcher)

程序员文章站 2024-02-23 13:46:22
最近在项目中有这么个需求,就是得去实时获取某个在无规律改变的文本文件中的内容。首先想到的是用程序定期去访问这个文件,因为对实时性要求很高,间隔不能超过1s,而且每次获取到文...

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