从FileSystemWatcher捕获丢失事件C＃

Question

我想创建一个简单的应用程序，什么将所有文件writed到一些目录到其他目录。这是我的问题：如果我一次在我的目录中写入超过10000个文件（超过1KB的小型.txt文件） - 其中一些文件无法在输出目录上移动。我正在使用FileSystemWatcher事件处理程序来解决此问题。这里是我的代码示例：

Class MyProgramm 
{ 
    void Process(Object o, FileSystemEventArgs e) 
    { 
     //do something with e.Name file 
    } 
    void main() 
    { 
     var FSW = New FileSystemWatcher{Path = "C:\\InputDir"}; 
     FSW.Created += Process; 
     FSW.EnableRisingEvents = true; 
     Thread.Sleep(Timeout.Infinite); 
    } 
} 

最后，我们得到了一些文件处理，但有些书面文件撑未处理.. 有什么建议？

Answer 1

我有类似的问题与FileSystemWatcher。它似乎很经常地“放下球”。我通过扩展“ServiceBase”来寻求替代解决方案，自从它作为一个Windows服务上线以来，它始终如一地运行。希望这有助于：

public partial class FileMonitor : ServiceBase 
    { 
     private Timer timer; 
     private long interval; 
     private const string ACCEPTED_FILE_TYPE = "*.csv"; 

     public FileMonitor() 
     {   
      this.ServiceName = "Service"; 
      this.CanStop = true; 
      this.CanPauseAndContinue = true; 
      this.AutoLog = true; 
      this.interval = long.Parse(1000); 
     } 

     public static void Main() 
     { 
      ServiceBase.Run(new FileMonitor()); 
     } 

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

     protected override void OnStart(string[] args) 
     { 
      AutoResetEvent autoEvent = new AutoResetEvent(false); 
      this.timer = new Timer(new TimerCallback(ProcessNewFiles), autoEvent, interval, Timeout.Infinite); 
     } 

     private void ProcessNewFiles(Object stateInfo) 
     { 
      DateTime start = DateTime.Now; 
      DateTime complete = DateTime.Now; 

      try 
      { 
       string directoryToMonitor = "c:\mydirectory"; 
       DirectoryInfo feedDir = new DirectoryInfo(directoryToMonitor); 
       FileInfo[] feeds = feedDir.GetFiles(ACCEPTED_FILE_TYPE, SearchOption.TopDirectoryOnly);    

       foreach (FileInfo feed in feeds.OrderBy(m => m.LastWriteTime)) 
       { 
        // Do whatever you want to do with the file here 
       } 
      } 
      finally 
      { 
       TimeSpan t = complete.Subtract(start); 
       long calculatedInterval = interval - t.Milliseconds < 0 ? 0 : interval - t.Milliseconds; 
       this.timer.Change(calculatedInterval, Timeout.Infinite); 
      } 
     }  
    }