FileSystemWatcher对象Created事件处理有关问题-C#教程-爱易网页

FileSystemWatcher对象Created事件处理有关问题

日期：2014-05-18　浏览次数：21251 次

FileSystemWatcher对象Created事件处理问题
各位大侠：
我想做一个文件监控程序，当监控文件夹下有新的txt文件产生时，对文件进行读写操作，完成数据读取和相关计算后把该文件转存到其它目录，原文件删除。
我自己写的created事件是先获取监控文件下的所有文件，然后对文件列表中的文件进行逐个处理，最后转存txt文件。处理完成后监控文件夹应为空，等待下一时次资料的处理。
自己遇到的问题：
1、测试的时候，我往监控文件夹复制n个txt文件，结果产生了n次created事件，导致程序被重复处理了n次。
我想要的结果是：当有多个txt文件被创建时，在一个created事件中处理所有的文件。
或是每个created事件都处理相应产生的txt文件,但不知道怎样才能获取到产生created事件的相应文件的文件名。

网上还说，利用created事件对文件进行读写操作，会遇到一些异常，比如其他程序在使用，或是文件还在被创建的过程当中。网上说的解决方法也很复杂，都看不懂。我自己试了下，复制2个txt文件，在created事件中写读整个txt文件，运行正常。可能是我的txt文件比较小吧，但还是想在程序方面做相应处理。

C# code


namespace 文件监控入库
{
    class Program
    {
        static void Main(string[] args)
        {
            string MonitorPath;
            MonitorPath = System.Environment.CurrentDirectory+"\\待入库文件1";
            WatcherStrat(@MonitorPath , "*.txt");
            Console.ReadKey();
        }
        private static void WatcherStrat(string path, string filter)        
        {            
            FileSystemWatcher watcher = new FileSystemWatcher();
            watcher.Path = path; //不知道怎么设置监控多个目录
            watcher.Filter = filter;
            watcher.Created += new FileSystemEventHandler(OnCreated);
            watcher.EnableRaisingEvents = true;
        }            
          
        private static void OnCreated(object source, FileSystemEventArgs e)
        {             
        
            //获取程序当前路径和文件列表
            string filedir, filepath;
            string[] filelist;
            filedir = System.Environment.CurrentDirectory + "\\待入库文件1";

            DirectoryInfo dir = new DirectoryInfo(filedir); //实例化directoryInf类
            FileSystemInfo[] f = dir.GetFileSystemInfos(); //获取监控目录下的文件名称
            filelist = new string[f.Length];
            for (int i=0;i<f.Length ;i++) 
            {
                filelist[i] = filedir + "\\"+f[i].ToString () ;
                Console.WriteLine(filelist[i]);//输出文件名，调试用的，看正不正常
                RedData(filelist[i].ToString ());//相应文件读取函数
            }
   

        }
        
        public static void RedData(string filepath)
        {
            //读取单个文件  测试
            StreamReader sr = new StreamReader(filepath );
            while (sr.ReadLine ()!=null )
            {
                
                Console .WriteLine (sr.ReadLine ().ToString ());
            }
            sr.Close();
            //将读取的资料写入数据库
            //............
        }
        public static void CopyFile(string filepath)
        {
            //复制转移已入库报文
        }
    }
}

------解决方案--------------------
RedData 写法也不对，ReadLine 是立即返回的，不能 while 条件里调用一次，内部再调用一次，这样不仅漏掉一半，而且很可能条件里能返回，循环内就结束返回 null 了，这时再调用 ToString 就 NullReferenceException 异常，假如文件大，可能写的那边还没完，这边就开始读，出现“该进程无法访问该文件”，可以等待并重试一些次数

C# code

public static void RedData(string filepath)
{
    Stream stream;
    int index = 0;
    while (true)
    {
        try
        {
            stream = File.Open(filepath, FileMode.Open, FileAccess.Read, FileShare.None);
            break;
        }
        catch (Exception)
        {
            if (index++ > 5)
            {
                throw;
            }
            else
            {
                Thread.Sleep(1000);
            }
        }
    }

    //读取单个文件  测试
    StreamReader sr = new StreamReader(stream);
    string tr = null;
    while ((tr = sr.ReadLine()) != null)
    {
        Console.WriteLine(tr);
    }
    sr.Close();
    stream.Dispose();
    //将读取的资料写入数据库
    //............
}

免责声明： 本文仅代表作者个人观点，与爱易网无关。其原创性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。

FileSystemWatcher对象Created事件处理有关问题

相关资料更多>

推荐阅读更多>