快捷導(dǎo)航

C#操作非持久化內(nèi)存映射文件詳解

更新時(shí)間：2023年12月28日 08:45:05 作者：rjcql

多個(gè)進(jìn)程之間,通過(guò)操作未映射到磁盤(pán)上現(xiàn)有文件的內(nèi)存映射文件,可以實(shí)現(xiàn)數(shù)據(jù)共享和類(lèi)似進(jìn)程間通訊的功能,下面我們就來(lái)學(xué)習(xí)一下C#如何操作非持久化內(nèi)存映射文件的吧

寫(xiě)在前面

多個(gè)進(jìn)程之間，通過(guò)操作未映射到磁盤(pán)上現(xiàn)有文件的內(nèi)存映射文件，可以實(shí)現(xiàn)數(shù)據(jù)共享和類(lèi)似進(jìn)程間通訊的功能。以下示例展示了使用三個(gè)獨(dú)立進(jìn)程，先各自將布爾值寫(xiě)入內(nèi)存映射文件，然后再由其中一個(gè)全部讀取出來(lái)的功能；示例代碼主要來(lái)自微軟官方教程。

代碼實(shí)現(xiàn)

進(jìn)程A

using System.IO.MemoryMappedFiles;
 
Console.WriteLine("我是獨(dú)立進(jìn)程A");
 
using MemoryMappedFile mmf = MemoryMappedFile.CreateNew("test_mem_map_file", 10000);
 
bool mutexCreated;
Mutex mutex = new Mutex(true, "testmapmutex", out mutexCreated);
using (MemoryMappedViewStream stream = mmf.CreateViewStream())
{
    BinaryWriter writer = new BinaryWriter(stream);
    writer.Write(1);
}
mutex.ReleaseMutex();
 
Console.WriteLine("請(qǐng)啟動(dòng)進(jìn)程 B 并按下確認(rèn)鍵以繼續(xù)運(yùn)行.");
Console.ReadLine();
 
Console.WriteLine("請(qǐng)啟動(dòng)進(jìn)程 C 并按下確認(rèn)鍵以繼續(xù)運(yùn)行.");
Console.ReadLine();
 
mutex.WaitOne();
using (MemoryMappedViewStream stream = mmf.CreateViewStream())
{
    BinaryReader reader = new BinaryReader(stream);
    Console.WriteLine("進(jìn)程 A 寫(xiě)入的內(nèi)容: {0}", reader.ReadBoolean());
    Console.WriteLine("進(jìn)程 B 寫(xiě)入的內(nèi)容: {0}", reader.ReadBoolean());
    Console.WriteLine("進(jìn)程 C 寫(xiě)入的內(nèi)容: {0}", reader.ReadBoolean());
}
mutex.ReleaseMutex();
 
 
Console.ReadLine();

進(jìn)程B

using System.IO.MemoryMappedFiles;
 
Console.WriteLine("我是獨(dú)立進(jìn)程B");
 
try
{
    using MemoryMappedFile mmf = MemoryMappedFile.OpenExisting("test_mem_map_file");
    Mutex mutex = Mutex.OpenExisting("testmapmutex");
    mutex.WaitOne();
 
    using (MemoryMappedViewStream stream = mmf.CreateViewStream(1, 0))
    {
        BinaryWriter writer = new BinaryWriter(stream);
        writer.Write(0);
    }
    mutex.ReleaseMutex();
}
catch (FileNotFoundException)
{
    Console.WriteLine("內(nèi)存映射文件不存在. 請(qǐng)先運(yùn)行進(jìn)程A.");
}

進(jìn)程C

using System.IO.MemoryMappedFiles;
 
Console.WriteLine("我是獨(dú)立進(jìn)程C");
 
try
{
    using MemoryMappedFile mmf = MemoryMappedFile.OpenExisting("test_mem_map_file");
    Mutex mutex = Mutex.OpenExisting("testmapmutex");
    mutex.WaitOne();
 
    using (MemoryMappedViewStream stream = mmf.CreateViewStream(2, 0))
    {
        BinaryWriter writer = new BinaryWriter(stream);
        writer.Write(0);
    }
    mutex.ReleaseMutex();
}
catch (FileNotFoundException)
{
    Console.WriteLine("內(nèi)存映射文件不存在. 請(qǐng)先運(yùn)行進(jìn)程A,再運(yùn)行進(jìn)程B.");
}