10

ファイルが変更されたときにイベントをトリガーする filesystemwatcher があります。ロックが解除されたら、そのファイルから読み取りたいと思います。現時点では、イベントがトリガーされたらファイルを開こうとしています.大きなファイルがコピーされているとき、イベントが送信された後もしばらくの間ファイルロックがオンのままになり、ファイルが読み取りアクセスで開かれなくなります。

助言がありますか？

4

1 に答える 1

6

これは、私が最後に対処しなければならなかったときから問題領域が大幅に変更されていない限り、実際には少しおかしな話です。

最も簡単な方法は、単純にファイルを開いて結果をキャッチしIOException、ファイルがロックされている場合はキューに追加して後でチェックすることです。同じファイルに対して複数のイベントが生成されるあらゆる種類のケースがあるため、受信したすべてのファイルを処理しようとすることはできません。そのため、受信したイベントごとに再試行ループを設定すると、災害が発生する可能性があります。代わりにそれらをキューに入れ、定期的にキューをチェックする必要があります。

この問題を解決するのに役立つ基本的なクラス テンプレートを次に示します。

public class FileMonitor : IDisposable
{
    private const int PollInterval = 5000;

    private FileSystemWatcher watcher;
    private HashSet<string> filesToProcess = new HashSet<string>();
    private Timer fileTimer;  // System.Threading.Timer

    public FileMonitor(string path)
    {
        if (path == null)
            throw new ArgumentNullException("path");

        watcher = new FileSystemWatcher();
        watcher.Path = path;
        watcher.NotifyFilter = NotifyFilters.FileName;
        watcher.Created += new FileSystemEventHandler(FileCreated);
        watcher.EnableRaisingEvents = true;

        fileTimer = new Timer(new TimerCallback(ProcessFilesTimer),
            null, PollInterval, Timeout.Infinite);
    }

    public void Dispose()
    {
        fileTimer.Dispose();
        watcher.Dispose();
    }

    private void FileCreated(object source, FileSystemEventArgs e)
    {
        lock (filesToProcess)
        {
            filesToProcess.Add(e.FullPath);
        }
    }

    private void ProcessFile(FileStream fs)
    {
        // Your code here...
    }

    private void ProcessFilesTimer(object state)
    {
        string[] currentFiles;
        lock (filesToProcess)
        {
            currentFiles = filesToProcess.ToArray();
        }
        foreach (string fileName in currentFiles)
        {
            TryProcessFile(fileName);
        }
        fileTimer.Change(PollInterval, Timeout.Infinite);
    }

    private void TryProcessFile(string fileName)
    {
        FileStream fs = null;
        try
        {
            FileInfo fi = new FileInfo(fileName);
            fs = fi.OpenRead();
        }
        catch (IOException)
        {
            // Possibly log this error
            return;
        }

        using (fs)
        {
            ProcessFile(fs);
        }

        lock (filesToProcess)
        {
            filesToProcess.Remove(fileName);
        }
    }
}

(注 - 私はここでこれを記憶から思い出しているので、完璧ではないかもしれません - バグがある場合はお知らせください。)

于 2010-02-09T06:12:46.953 に答える