Błąd dostępu do plików przy użyciu FileSystemWatcher, gdy do katalogu dodawanych jest wiele plików

Zostawiłbym komentarz powyżej, ale nie mam jeszcze wystarczająco punktów.

Najlepiej oceniana odpowiedź na to pytanie ma blok kodu, który wygląda tak:

using (Stream stream = System.IO.File.Open(fileName, FileMode.Open, FileAccess.ReadWrite, FileShare.ReadWrite))
{
    if (stream != null)
    {
        System.Diagnostics.Trace.WriteLine(string.Format("Output file {0} ready.", fileName));
        break;
    }
}

Problem z używaniem ustawienia FileShare.ReadWrite polega na tym, że żąda dostępu do pliku w zasadzie mówiąc "chcę czytać/zapisywać do tego pliku, ale inni mogą również odczytywać/zapisywać do niego.- Takie podejście zawiodło w naszej sytuacji. Proces, który odbierał zdalny transfer, nie zablokował pliku, ale był aktywnie piszę do niego. Nasz dalszy kod (SharpZipLib) nie powiódł się z wyjątkiem "file in use", ponieważ próbował otworzyć plik za pomocą FileShare.Read ("chcę plik do odczytu i pozwól innym procesom również czytać"). Ponieważ proces, który miał otwarty plik, już do niego zapisywał, to żądanie nie powiodło się.

Jednak kod w powyższej odpowiedzi jest zbyt luźny. Używając FileShare.ReadWrite, udało mu się uzyskać dostęp do pliku (ponieważ prosiło o ograniczenie udziału które można było uhonorować), ale dalsza rozmowa nadal nie powiodła się.

Ustawienie udziału w wywołaniu do File.Open powinno być FileShare.Read lub FileShare.None, a Nie FileShare.ReadWrite.

Kiedy otwierasz plik w metodzie OnChanged, określasz FileShare.None, co zgodnie z dokumentacją spowoduje, że wszelkie inne próby otwarcia pliku nie powiodą się, gdy go otworzysz. Ponieważ ty (i twój obserwator) tylko czytasz, spróbuj użyć FileShare.Read.

Prostym rozwiązaniem byłoby pozbycie się filesystemwatcher po otrzymaniu powiadomienia. przed skopiowaniem pliku spraw, aby bieżący wątek poczekał, aż otrzyma usunięte Zdarzenie filesystemwatcher. następnie możesz kontynuować kopiowanie zmienionego pliku bez problemów z dostępem. Miałem ten sam wymóg i zrobiłem to dokładnie tak, jak wspomniałem. zadziałało.

Przykładowy Kod:

public void TestWatcher()
{
    using (var fileWatcher = new FileSystemWatcher())
    {

        string path = @"C:\sv";
        string file = "pos.csv";

        fileWatcher.Path = path;
        fileWatcher.NotifyFilter = NotifyFilters.CreationTime | NotifyFilters.LastWrite;
        fileWatcher.Filter = file;

        System.EventHandler onDisposed = (sender,args) =>
        {
           eve.Set();
        };

        FileSystemEventHandler onFile = (sender, fileChange) =>
        {
           fileWatcher.EnableRaisingEvents = false;
           Thread t = new Thread(new ParameterizedThreadStart(CopyFile));
           t.Start(fileChange.FullPath);
           if (fileWatcher != null)
           {
               fileWatcher.Dispose();
           }
           proceed = false;
        };

        fileWatcher.Changed += onFile;
        fileWatcher.Created += onFile;
        fileWatcher.Disposed+= onDisposed;
        fileWatcher.EnableRaisingEvents = true;

        while (proceed)
        {
            if (!proceed)
            {
                break;
            }
        }
    }
}

public void CopyFile(object sourcePath)
{
    eve.WaitOne();
    var destinationFilePath = @"C:\sv\Co";
    if (!string.IsNullOrEmpty(destinationFilePath))
    {
        if (!Directory.Exists(destinationFilePath))
        {
            Directory.CreateDirectory(destinationFilePath);
        }
        destinationFilePath = Path.Combine(destinationFilePath, "pos.csv");
    }           

    File.Copy((string)sourcePath, destinationFilePath);
}

FileSystemWatcher uruchamia watchera.Utworzone Zdarzenie dwa razy dla każdego utworzenia pliku 1ce po rozpoczęciu kopiowania pliku i 2. po zakończeniu kopiowania pliku. Wszystko, co musisz zrobić, to zignorować Zdarzenie 1st i przetworzyć zdarzenie po raz drugi.

Prosty przykład obsługi zdarzeń:

private bool _fileCreated = false;
private void FileSystemWatcher_FileCreated(object sender, FileSystemEventArgs e)
{
    if (_fileCreated)
    {
        ReadFromFile();//just an example method call to access the new file
    }

    _fileCreated = !_fileCreated;
}

Uważam, że dobrym przykładem tego, czego chcesz, jest ConfigureAndWatchHandler w log4net. Używają timera do odpalenia zdarzenia obsługi plików. Wydaje mi się, że kończy się to czystszą implementacją pętli while w poście 0xa3. Dla tych z was, którzy nie chcą używać dotPeek do sprawdzania pliku postaram się dać wam fragment kodu oparty na kodzie OP:

private System.Threading.Timer _timer;    

public void Run() {
  //setup filewatcher
  _timer = new System.Threading.Timer(new TimerCallback(OnFileChange), (object) null, -1, -1);
}

private void OnFileChange(object state)
{
    try 
    {
    //handle files
    }
    catch (Exception ex) 
    {
        //log exception
        _timer.Change(500, -1);
    }
}

Miałem podobny problem. To tylko z powodu FileSystemWatcher. I just used
Nić.Sleep ();

I teraz działa dobrze. Gdy plik wchodzi do katalogu, wywołuje on onCreated dwukrotnie. więc raz, gdy plik jest kopiowany.i drugi raz po zakończeniu kopiowania. Do tego użyłem wątku.Sleep (); więc będzie czekać zanim wywołam ReadFile ();

private static void OnCreated(object source, FileSystemEventArgs e)
    {
        try
        {
            Thread.Sleep(5000);
            var data = new FileData();
            data.ReadFile(e.FullPath);                
        }
        catch (Exception ex)
        {
            WriteLogforError(ex.Message, String.Empty, filepath);
        }
    }

Miałem ten sam problem w DFS. Moja rozdzielczość została osiągnięta przez dodanie dwóch pustych linii do każdego pliku. Następnie Mój kod czeka na dwie puste linie w pliku. Wtedy mam pewność, aby odczytać całe dane z pliku.

public static BitmapSource LoadImageNoLock(string path)
{
    while (true)
    {
        try
        {
            var memStream = new MemoryStream(File.ReadAllBytes(path));
            var img = new BitmapImage();
            img.BeginInit();
            img.StreamSource = memStream;
            img.EndInit();
            return img;
            break;
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }
}