快捷導(dǎo)航

c# 通過內(nèi)存映射實(shí)現(xiàn)文件共享內(nèi)存的示例代碼

更新時(shí)間：2021年04月24日 10:15:15 作者：zls365

這篇文章主要介紹了c# 通過內(nèi)存映射實(shí)現(xiàn)文件共享內(nèi)存的示例代碼，幫助大家更好的理解和學(xué)習(xí)使用c#，感興趣的朋友可以了解下

內(nèi)存映射文件是利用虛擬內(nèi)存把文件映射到進(jìn)程的地址空間中去，在此之后進(jìn)程操作文件，就像操作進(jìn)程空間里的地址一樣了，比如使用c語言的 memcpy等內(nèi)存操作的函數(shù)。這種方法能夠很好的應(yīng)用在需要頻繁處理一個(gè)文件或者是一個(gè)大文件的場合，這種方式處理IO效率比普通IO效率要高

共享內(nèi)存是內(nèi)存映射文件的一種特殊情況，內(nèi)存映射的是一塊內(nèi)存，而非磁盤上的文件。共享內(nèi)存的主語是進(jìn)程（Process），操作系統(tǒng)默認(rèn)會(huì)給每一個(gè)進(jìn)程分配一個(gè)內(nèi)存空間，每一個(gè)進(jìn)程只允許訪問操作系統(tǒng)分配給它的哪一段內(nèi)存，而不能訪問其他進(jìn)程的。而有時(shí)候需要在不同進(jìn)程之間訪問同一段內(nèi)存，怎么辦呢？操作系統(tǒng)給出了創(chuàng)建訪問共享內(nèi)存的API，需要共享內(nèi)存的進(jìn)程可以通過這一組定義好的API來訪問多個(gè)進(jìn)程之間共有的內(nèi)存，各個(gè)進(jìn)程訪問這一段內(nèi)存就像訪問一個(gè)硬盤上的文件一樣。而.Net 4.0中引入了System.IO. MemoryMappedFiles命名空間，這個(gè)命名空間的類對(duì)windows 共享內(nèi)存相關(guān)API做了封裝，使.Net程序員可以更方便的使用內(nèi)存映射文件。

在C#中使用共享內(nèi)存。以下App1的代碼讓用戶輸入一行文本到共享內(nèi)存中；App2不停的刷新控制臺(tái)，輸出最新的共享內(nèi)存內(nèi)容；App3實(shí)現(xiàn)的功能和App2相同，但讀取方法不同。

App1代碼：

using System;
using System.Collections.Generic;android從資源文件中讀取文件流顯示
using System.Linq;
using System.Text;

using System.IO;

//引用內(nèi)存映射文件命名空間
using System.IO.MemoryMappedFiles;

namespace App1
{
    class Program
    {
        static void Main(string[] args)
        {
            long capacity = 1<<10<<10;

            //創(chuàng)建或者打開共享內(nèi)存
            using (var mmf = MemoryMappedFile.CreateOrOpen("testMmf", capacity, MemoryMappedFileAccess.ReadWrite))
            {
                //通過MemoryMappedFile的CreateViewAccssor方法獲得共享內(nèi)存的訪問器
                var viewAccessor = mmf.CreateViewAccessor(0, capacity);
                //循環(huán)寫入，使在這個(gè)進(jìn)程中可以向共享內(nèi)存中寫入不同的字符串值
                while (true)
                {
                    Console.WriteLine("請(qǐng)輸入一行要寫入共享內(nèi)存的文字：");

                    string input = Console.ReadLine();

                    //向共享內(nèi)存開始位置寫入字符串的長度
                    viewAccessor.Write(0, input.Length);

                    //向共享內(nèi)存4位置寫入字符
                    viewAccessor.WriteArray<char>(4, input.ToArray(), 0, input.Length);
                }

            }
            
        }
    }
}

App2代碼：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

//引用使用內(nèi)存映射文件需要的命名空間
using System.IO.MemoryMappedFiles;

namespace App2
{
    class Program
    {
        static void Main(string[] args)
        {
              long capacity = 1<<10<<10;

              using (var mmf = MemoryMappedFile.OpenExisting("testMmf"))
              {
                  MemoryMappedViewAccessor viewAccessor = mmf.CreateViewAccessor(0, capacity);

                  //循環(huán)刷新共享內(nèi)存字符串的值
                  while (true)
                  {
                      //讀取字符長度
                      int strLength = viewAccessor.ReadInt32(0);                      
                      char[] charsInMMf = new char[strLength];
                      //讀取字符
                      viewAccessor.ReadArray<char>(4, charsInMMf, 0, strLength);
                      Console.Clear();
                      Console.Write(charsInMMf);
                      Console.Write("\r");
                      Thread.Sleep(200);
                  }
              }
        }
    }
}

App3代碼：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using System.IO.MemoryMappedFiles;
using System.IO;

namespace App3
{
    class Program
    {
        static void Main(string[] args)
        {
            long capacity = 1 << 10 << 10;
            //打開共享內(nèi)存
            using (var mmf = MemoryMappedFile.OpenExisting("testMmf"))
            {
                //使用CreateViewStream方法返回stream實(shí)例
                using (var mmViewStream = mmf.CreateViewStream(0, capacity))
                {
                    //這里要制定Unicode編碼否則會(huì)出問題
                    using (BinaryReader rdr = new BinaryReader(mmViewStream,Encoding.Unicode))
                    {
                        while (true)
                        {
                            mmViewStream.Seek(0, SeekOrigin.Begin);

                            int length = rdr.ReadInt32();

                            char[] chars = rdr.ReadChars(length);

                            Console.Write(chars);
                            Console.Write("\r");

                            System.Threading.Thread.Sleep(200);
                            Console.Clear();
                        }
                    }
                }
            }
        }
    }
}

在讀數(shù)據(jù)時(shí)用了2種方法。

因?yàn)樵谥昂苌贂?huì)用到進(jìn)程之間的通信，所以此方法只是想初步的認(rèn)識(shí)下。此程序?qū)懙倪^于簡陋，有很多東西都沒有去判斷。比如說是怎么創(chuàng)建了一個(gè)共享內(nèi)存怎么取刪除它等等。。。

以上就是c# 通過內(nèi)存映射實(shí)現(xiàn)文件共享內(nèi)存的示例代碼的詳細(xì)內(nèi)容，更多關(guān)于c# 實(shí)現(xiàn)文件共享內(nèi)存的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: