Чтение содержания файла изменяется в.NET
В Linux много IPC сделано путем добавления в файл в 1 процессе и чтения нового содержания из другого процесса.
Я хочу сделать вышеупомянутое в Windows/.NET (Слишком грязный для использования нормального IPC, такого как каналы). Я добавляю в файл от процесса Python, и я хочу считать изменения и ТОЛЬКО изменения каждый раз, когда FileSystemWatcher сообщает о событии. Я не хочу читать все содержание файла в память каждый раз, когда я ищу изменения (файл будет огромен),
Каждый добавляет операцию, добавляет строку данных, которые запускаются с уникального счетчика постепенного увеличения (timestamp+key) и заканчиваются новой строкой.
2 ответа
using (FileStream fs = new FileStream
(fileName, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
{
using (StreamReader sr = new StreamReader(fs))
{
while (someCondition)
{
while (!sr.EndOfStream)
ProcessLinr(sr.ReadLine());
while (sr.EndOfStream)
Thread.Sleep(100);
ProcessLinr(sr.ReadLine());
}
}
}
это поможет вам читать только добавленные строки
Вы можете сохранить смещение последней операции чтения и искать файл с этим смещением, когда вы получите уведомление об изменении файла. Пример:
Основной метод:
public static void Main(string[] args)
{
File.WriteAllLines("test.txt", new string[] { });
new Thread(() => ReadFromFile()).Start();
WriteToFile();
}
Метод чтения из файла:
private static void ReadFromFile()
{
long offset = 0;
FileSystemWatcher fsw = new FileSystemWatcher
{
Path = Environment.CurrentDirectory,
Filter = "test.txt"
};
FileStream file = File.Open(
"test.txt",
FileMode.Open,
FileAccess.Read,
FileShare.Write);
StreamReader reader = new StreamReader(file);
while (true)
{
fsw.WaitForChanged(WatcherChangeTypes.Changed);
file.Seek(offset, SeekOrigin.Begin);
if (!reader.EndOfStream)
{
do
{
Console.WriteLine(reader.ReadLine());
} while (!reader.EndOfStream);
offset = file.Position;
}
}
}
Метод записи в файл:
private static void WriteToFile()
{
for (int i = 0; i < 100; i++)
{
FileStream writeFile = File.Open(
"test.txt",
FileMode.Append,
FileAccess.Write,
FileShare.Read);
using (FileStream file = writeFile)
{
using (StreamWriter sw = new StreamWriter(file))
{
sw.WriteLine(i);
Thread.Sleep(100);
}
}
}
}