无需 FileSystemWatcher 即可监视目录中的新文件创建情况

Question

我必须创建一个 Windows 服务来监视指定文件夹中的新文件并对其进行处理并将其移动到其他位置。

我开始使用FileSystemWatcher。我的老板不喜欢 FileSystemWatcher，并希望我通过使用 Timer 或除 FileSystemWatcher 之外的任何其他机制来使用轮询。

如何使用 .NET 框架在不使用 FileSystemWatcher 的情况下监控目录？

Answer 1

实际上，根据我多年来的经验，FileWatcher 组件并不是 100% “稳定”。将足够多的文件放入文件夹中，您将丢失一些事件。如果您监视文件共享，即使增加缓冲区大小，情况尤其如此。

因此，出于所有实际原因，请将 FileWatcher 与计时器一起使用，以扫描文件夹中的更改，以获得最佳解决方案。

如果你用谷歌搜索的话，创建定时器代码的例子应该很多。如果您跟踪计时器运行时的最后一个 DateTime，则检查每个文件的修改日期，并将其与该日期进行比较。相当简单的逻辑。

计时器间隔取决于系统更改的紧急程度。但对于许多情况来说，每分钟检查一次应该没问题。

Answer 2

使用 @Petoj 的答案，我已经包含了一个完整的 Windows 服务，该服务每五分钟轮询一次是否有新文件。它受到限制，因此只有一个线程轮询，占用处理时间并支持暂停和及时停止。它还支持在 system.start 上轻松附加调试器

 public partial class Service : ServiceBase{


    List<string> fileList = new List<string>();

    System.Timers.Timer timer;


    public Service()
    {
        timer = new System.Timers.Timer();
        //When autoreset is True there are reentrancy problems.
        timer.AutoReset = false;

        timer.Elapsed += new System.Timers.ElapsedEventHandler(DoStuff);
    }


    private void DoStuff(object sender, System.Timers.ElapsedEventArgs e)
    {
       LastChecked = DateTime.Now;

       string[] files = System.IO.Directory.GetFiles("c:\\", "*", System.IO.SearchOption.AllDirectories);

       foreach (string file in files)
       {
           if (!fileList.Contains(file))
           {
               fileList.Add(file);

               do_some_processing();
           }
       }


       TimeSpan ts = DateTime.Now.Subtract(LastChecked);
       TimeSpan MaxWaitTime = TimeSpan.FromMinutes(5);

       if (MaxWaitTime.Subtract(ts).CompareTo(TimeSpan.Zero) > -1)
           timer.Interval = MaxWaitTime.Subtract(ts).TotalMilliseconds;
       else
           timer.Interval = 1;

       timer.Start();
    }

    protected override void OnPause()
    {
        base.OnPause();
        this.timer.Stop();
    }

    protected override void OnContinue()
    {
        base.OnContinue();
        this.timer.Interval = 1;
        this.timer.Start();
    }

    protected override void OnStop()
    {
        base.OnStop();
        this.timer.Stop();
    }

    protected override void OnStart(string[] args)
    {
       foreach (string arg in args)
       {
           if (arg == "DEBUG_SERVICE")
                   DebugMode();

       }

        #if DEBUG
            DebugMode();
        #endif

        timer.Interval = 1;
        timer.Start();
   }

   private static void DebugMode()
   {
       Debugger.Break();
   }

 }

Answer 3

在程序启动时，使用 Directory.GetFiles(path) 获取文件列表。

然后创建一个计时器，并在其已用事件中调用 hasNewFiles:

    static List<string> hasNewFiles(string path, List<string> lastKnownFiles)
    {
        List<string> files = Directory.GetFiles(path).ToList();
        List<string> newFiles = new List<string>();

        foreach (string s in files)
        {
            if (!lastKnownFiles.Contains(s))
                newFiles.Add(s);
        }

        return new List<string>();
    }

在调用代码中，如果

    List<string> newFiles = hasNewFiles(path, lastKnownFiles);
    if (newFiles.Count > 0)
    {
        processFiles(newFiles);
        lastKnownFiles = newFiles;
    }

：编辑：如果您想要更 linqy 的解决方案，您将拥有新文件：

    static IEnumerable<string> hasNewFiles(string path, List<string> lastKnownFiles)
    {
        return from f in Directory.GetFiles(path) 
               where !lastKnownFiles.Contains(f) 
               select f;
    }

    List<string> newFiles = hasNewFiles(path, lastKnownFiles); 
    if (newFiles.Count() > 0) 
    { 
        processFiles(newFiles); 
        lastKnownFiles = newFiles; 
    } 

Answer 4

您可以使用 Directory.GetFiles() ：

using System.IO;

var fileList = new List<string>();

foreach (var file in Directory.GetFiles(@"c:\", "*", SearchOption.AllDirectories))
{
    if (!fileList.Contains(file))
    {
        fileList.Add(file);
        //do something
    }
}

请注意，这仅检查新文件而不是更改的文件，如果您需要使用 FileInfo

Answer 5

我想问为什么不使用 FileSystemWatcher。它向操作系统注册，并在文件系统中的事件完成时立即收到通知。

如果你确实需要轮询，那么只需创建一个System.Timers.Timer，创建一个供其调用的方法，并在该方法中检查文件。

Answer 6

是的，您可以创建一个计时器，并将一个处理程序插入到 Elapsed 事件中，该事件将为您正在监视的目录实例化一个 DirectoryInfo 类，并调用 GetFiles() 或 EnumerateFiles()。 GetFiles() 返回一个 FileInfo[] 数组，而 EnumerateFiles() 返回一个“流式”IEnumerable。如果您在查看时希望该文件夹中存在大量文件，则 EnumerateFiles() 会更有效；您可以在该方法检索到所有 FileInfo 之前开始使用 IEnumerable，而 GetFiles 会让您等待。

至于为什么这实际上可能比 FileWatcher 更好，这取决于幕后的架构。以基本的提取/转换/验证/加载工作流程为例。首先，这样的工作流程可能必须创建昂贵的对象实例（数据库连接、规则引擎实例等）。如果工作流的结构能够一次性处理可用的所有内容，那么这种一次性开销就会显着减轻。其次，FileWatcher 要求事件处理程序调用的任何内容（例如此工作流程）都是线程安全的，因为如果文件不断流入，则可以同时运行许多事件。如果这不可行，则可以非常轻松地配置计时器将系统限制为一个正在运行的工作流程，方法是让事件处理程序检查线程安全的“进程正在运行”标志，并在另一个处理程序线程已设置该标志但尚未完成时终止。此时文件夹中的文件将在下次计时器触发时被拾取，这与 FileWatcher 不同，如果终止处理程序，有关该文件存在的信息就会丢失。

Answer 7

1) 听起来你的老板是个白痴
2）您必须使用 Directory.GetFiles、File.GetLastAccessTime 等函数并将其保存在内存中以检查它是否更改。

Answer 8

有点奇怪的是，您不能使用 FileSystemWatcher 或任何执行相同操作的 Win32 API，但此时这是无关紧要的。轮询方法可能如下所示。

public class WorseFileSystemWatcher : IDisposable
{
  private ManaulResetEvent m_Stop = new ManaulResetEvent(false);

  public event EventHandler Change;

  public WorseFileSystemWatcher(TimeSpan pollingInterval)
  {
    var thread = new Thread(
      () =>
      {
        while (!m_Stop.WaitOne(pollingInterval))
        {
          // Add your code to check for changes here.
          if (/* change detected */)
          {
            if (Change != null)
            {
              Change(this, new EventArgs())
            }
          }
        }
      });
    thread.Start();
  }

  public void Dispose()
  {
    m_Stop.Set();
  }
}