Использование MemoryMappedFile и FileSystemWatcher для обнаружения новых записей в файле журнала

Чтобы ответить на мой собственный вопрос, хитрость в чтении заблокированного файла заключается в создании FileStream со следующими флагами доступа:

FileStream fileStream = new System.IO.FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.Delete | FileShare.ReadWrite);

Теперь нужно либо выполнять опрос на основе интервалов, либо искать события изменения FileSystemWatcher для обнаружения изменений файлов.

Я не уверен, помогут ли вам MemoryMappedFiles. Взгляните на FileStream:

var stream = new FileStream(path, FileMode.Open, FileShare.Read);
stream.Seek(offset, SeekOrigin.Begin);

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

[Начало 2-го РЕДАКТИРОВАТЬ]

Еще одна идея...

Если стороннее приложение использует структуру ведения журналов, такую ​​как NLog, log4net или System.Diagnostics, вы все равно можете написать свой собственный Target/Appender/TraceListener и направить сообщения куда-нибудь, чтобы вы могли их просмотреть (например, файл, который не открыт исключительно для другого процесса и т. д.).

Если ваше стороннее приложение использует фреймворк ведения журналов, мы, вероятно, уже слышали об этом ;-)

[Конец 2-го РЕДАКТИРОВАТЬ]

[Начать РЕДАКТИРОВАНИЕ]

Я думаю, что неправильно понял вопрос. Сначала это звучало так, как будто вы используете стороннюю библиотеку, в которой реализовано ведение журнала, и вы хотели выполнить этот анализ из программы, которая генерировала ведение журнала. Перечитав свой вопрос, похоже, вы хотите «прослушать» файл журнала из-за пределов приложения. Если это так, мой ответ, вероятно, не поможет вам. Извиняюсь.

[Конец РЕДАКТИРОВАТЬ]

Мне нечего предложить по поводу MemoryMappedFiles, но мне интересно, сможете ли вы достичь того, что вам нужно, написав собственный прослушиватель/цель/аппендер для сторонней системы ведения журнала?

Например, если вы используете NLog, вы можете написать пользовательскую цель и направить туда все ваши сообщения журнала (а также направить их на «настоящую» цель(и)). Таким образом, вы получаете взлом каждого сообщения журнала по мере его регистрации (так что на самом деле это происходит в реальном времени, а не в реальном времени). Вы можете сделать то же самое с log4net и System.Diagnostics.

Обратите внимание, что NLog даже имеет цель «MethodCall». Чтобы использовать его, вам нужно только написать статический метод с правильной подписью. Я не знаю, есть ли у log4net аналогичная концепция.

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

Если файл «используется», с этим ничего нельзя поделать. Он действительно "используется". MemoryMappedFiles предназначены либо для чтения больших объемов данных с диска, либо для обмена данными с другими программами. Это не поможет обойти ограничение «в использовании».

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

var readerStream = новый FileStream(путь, FileMode.Open, FileAccess.Read, FileShare.ReadWrite);

var mmf = MemoryMappedFile.CreateFromFile(readerStream, null, 0, MemoryMappedFileAccess.Read, null, HandleInheritability.None, false);

Если какой-то другой процесс полностью заблокировал его даже при записи, вам не повезло, не уверен, что есть способ обойти это. Возможно, используйте какой-нибудь таймер, чтобы определить, когда процесс перестал писать в него.

Я сделал что-то подобное только для мониторинга файлов журнала на консоли (в отличие от обработки), но принципы те же. Как и вы, я использую FileSystemWatcher, и важная логика находится в моем обработчике событий OnChanged:

case WatcherChangeTypes.Changed:
{
    System.IO.FileInfo fi = new FileInfo(e.FullPath);

    long prevLength;

    if (lastPositions.TryGetValue(e.FullPath, out prevLength))
    {
        using (System.IO.FileStream fs = new FileStream(
           e.FullPath, FileMode.Open, FileAccess.Read))
        {
            fs.Seek(prevLength, SeekOrigin.Begin);
            DumpNewData(fs, (int)(fi.Length - prevLength));
            lastPositions[e.FullPath] = fs.Position;
        }
    }
    else
      lastPositions.Add(e.FullPath, fi.Length);

    break;
}

где lastPositions

Dictionary<string, Int64> lastPositions = new Dictionary<string, long>();

а DumpNewData просто

private static void DumpNewData(FileStream fs, int bytesToRead)
{
    byte[] bytesRead = new byte[bytesToRead];
    fs.Read(bytesRead, 0, bytesToRead);
    string s = System.Text.ASCIIEncoding.ASCII.GetString(bytesRead);
    Console.Write(s);
}