Сканер каталогов Windows Service с помощью FileSystemWatcher

Question

Я пытаюсь создать службу Windows, которая будет захватывать новые файлы, загруженные в каталог, редактировать их и перемещать в другой каталог.Кажется, я могу скопировать их, но не MOVE.Почему это так?

using System;
using System.ServiceProcess;
using System.Threading;
using System.IO;

namespace ImportService
{
    public class ImportServer : ServiceBase
    {        
        private System.Diagnostics.EventLog eventLog1;
        private FileSystemWatcher watcher;

        public ImportServer()
        {
            this.ServiceName = "ImportService";

            this.CanHandlePowerEvent = true;
            this.CanHandleSessionChangeEvent = true;
            this.CanPauseAndContinue = true;
            this.CanShutdown = true;
            this.CanStop = true;
            this.AutoLog = true;           

            InitializeComponent();
            if (!System.Diagnostics.EventLog.SourceExists("ImportServiceLogSource"))
                System.Diagnostics.EventLog.CreateEventSource("ImportServiceLogSource", "ImportServiceLog");
            eventLog1.Source = "ImportServiceLogSource";
            eventLog1.Log = "ImportServiceLog";
        }

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

        protected override void OnStart(string[] args)
        {
            //base.OnStart(args);

            eventLog1.WriteEntry("service started");

            watcher = new FileSystemWatcher();
            watcher.Path = "C:\\INPUT\\";
            watcher.Filter = "*.jpg";
            watcher.EnableRaisingEvents = true;
            watcher.Created += new FileSystemEventHandler(OnCreated);            
        }

        private void OnCreated(object sender, FileSystemEventArgs e)
        {
            String output_dir = "C:\\OUTPUT\\";
            String output_file = Path.Combine(output_dir, e.Name);
            File.Move(e.FullPath, output_file);
            // File.Copy() works here
            eventLog1.WriteEntry("moving file to " + output_file);
        }

        protected override void OnStop()
        {            
            eventLog1.WriteEntry("service stopped");
            base.OnStop();
        }

        protected override void OnContinue()
        {
            base.OnContinue();
        }

        protected override void OnPause()
        {
            base.OnPause();
        }

        private void InitializeComponent()
        {
            this.eventLog1 = new System.Diagnostics.EventLog();
            ((System.ComponentModel.ISupportInitialize)(this.eventLog1)).BeginInit();
            ((System.ComponentModel.ISupportInitialize)(this.eventLog1)).EndInit();

        }
    }
}

Также я должен сохранить base.OnStart(); и т. Д. Что он действительно делает?

ОБНОВЛЕНИЕ: Как переместить созданный файлв наблюдаемом каталоге? Файл уже используется Проблема исключения.

Answer 1

Вам нужно будет перехватить IOException и несколько раз перевести нить в спящий режим, а затем повторить попытку.

private void OnCreated(object sender, FileSystemEventArgs e)
{
    String output_dir = "C:\\OUTPUT\\";
    String output_file = Path.Combine(output_dir, e.Name);
    while (true)
    {
        try
        {
            File.Move(e.FullPath, output_file);
            break;
        }
        catch (IOException)
        {
            //sleep for 100 ms
            System.Threading.Thread.Sleep(100);
        }
    }        
    eventLog1.WriteEntry("moving file to " + output_file);
}

При этом существует множество проблем с этим.Вам будет лучше иметь событие таймера, которое вызывается каждые несколько секунд и ищет файлы в папке.Если вы получаете IOException, вы просто идете дальше.Файл все еще будет там для обработки на следующей итерации (при условии, что загрузка завершена).Могу привести пример, если то, о чем я говорю, если нужно.

Answer 2

Как я понимаю, вам нужно подождать, пока передача файла не завершится и файл не закроется, и только после этого вы сможете переместить файл.

Это уже обсуждалось на SO несколько раз. Например. здесь и здесь .

Answer 3

Ваша реализация OnCreated должна обрабатывать исключения, если вы хотите избежать сбоя службы. Многие вещи могут работать неправильно при обработке файла, и ваша служба должна корректно восстанавливаться после этого.

Одна из возможностей здесь заключается в том, что событие OnCreated может сработать до того, как процесс записи нового файла завершит его запись, и поэтому ваша попытка переместить файл вызывает исключение.