【.Net 学习系列】-- FileSystemWatcher 监控文件夹新生成文件，并在确认文件没有被其他程序占用后将其移动到指定文件夹

监控文件夹测试程序：

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace FileSystemWatcherTest
{
    class Program
    {
        static void Main(string[] args)
        {
            FileSystemWatcher watcher = new FileSystemWatcher("C:\FileSystemWatcher", "*.txt");
            watcher.NotifyFilter = NotifyFilters.FileName;
            watcher.Created += new FileSystemEventHandler(FileCreated);
            watcher.EnableRaisingEvents = true;

            Console.ReadLine();
        }

        private static void FileCreated(object sender, FileSystemEventArgs e)
        {
            if (!File.Exists(e.FullPath))
            {
                return;
            }
            Console.WriteLine("Created: {0: HH:mm:ss}", DateTime.Now);

            while (!IsFileReady(e.FullPath))
            {
                Console.WriteLine("Used: {0: HH:mm:ss}", DateTime.Now);
            }
            //在这里进行文件处理。。。  
            Console.WriteLine("Ready: {0: HH:mm:ss}", DateTime.Now);

            Thread.Sleep(1000 * 5);
            FileInfo fs = new FileInfo(e.FullPath);

            var moveToPath = @"\testServerShares" + fs.Name;
            fs.MoveTo(moveToPath);

            if (!File.Exists(moveToPath))
            {
                Console.WriteLine("Move Faild: {0: HH:mm:ss}", DateTime.Now);
            }
            Console.WriteLine("Move Success: {0: HH:mm:ss}", DateTime.Now);
        }

        static bool IsFileReady(string filename)
        {
            FileInfo fi = new FileInfo(filename);
            FileStream fs = null;
            try
            {
                fs = fi.Open(FileMode.Open, FileAccess.ReadWrite,FileShare.None);
                return true;
            }

            catch (IOException)
            {
                return false;
            }

            finally
            {
                if (fs != null)
                    fs.Close();
            }
        }
    }
}

文件生成测试程序：

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace GenerateFileTest
{
    class Program
    {
        static void Main(string[] args)
        {
            FileStream fs = new FileStream("C:\FileSystemWatcher\Test.txt", FileMode.Create);
            StreamWriter sw = new StreamWriter(fs);

            var currDateTime = DateTime.Now;
            var maxDateTime = currDateTime.AddSeconds(10);

            Console.WriteLine("Log begin: {0}", DateTime.Now.ToString("HH:mm:ss"));
            while (currDateTime < maxDateTime)
            {
                sw.WriteLine(DateTime.Now.ToString());
                currDateTime = DateTime.Now;
            }

            //清空缓冲区
            sw.Flush();
            //关闭流
            sw.Close();
            fs.Close();

            Console.WriteLine("Log end: {0}", DateTime.Now.ToString("HH:mm:ss"));
            Console.ReadLine();
        }
    }
}

运行结果：