文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

C#.Net通信共享内存映射文件是什么

2023-06-30 11:08

关注

这篇文章主要讲解了“C#.Net通信共享内存映射文件是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“C#.Net通信共享内存映射文件是什么”吧!

节点通信存在两种模型:共享内存(Shared memory)和消息传递(Messages passing)。

内存映射文件对于托管世界的开发人员来说似乎很陌生,但它确实已经是很远古的技术了,而且在操作系统中地位相当。实际上,任何想要共享数据的通信模型都会在幕后使用它。

内存映射文件究竟是个什么?

内存映射文件允许你保留一块地址空间,然后将该物理存储映射到这块内存空间中进行操作。物理存储是文件管理,而内存映射文件是操作系统级内存管理。

C#.Net通信共享内存映射文件是什么

C#.Net通信共享内存映射文件是什么

优势:

访问磁盘文件上的数据不需执行I/O操作和缓存操作(当访问文件数据时,作用尤其显著);

让运行在同一台机器上的多个进程共享数据(单机多进程间数据通信效率最高);

利用文件与内存空间之间的映射,应用程序(包括多个进程)可以通过直接在内存中进行读写来修改文件。.NET Framework 4 用托管代码按照本机Windows函数访问内存映射文件的方式来访问内存映射文件,管理 Win32 中的内存映射文件。

有两种类型的内存映射文件:

持久文件是与磁盘上的源文件关联的内存映射文件。在最后一个进程使用完此文件后,数据将保存到磁盘上的源文件中。这些内存映射文件适合用来处理非常大的源文件。

非持久文件是未与磁盘上的源文件关联的内存映射文件。当最后一个进程使用完此文件后,数据将丢失,并且垃圾回收功能将回收此文件。这些文件适用于为进程间通信(IPC) 创建共享内存。

1)在多个进程之间进行共享(进程可通过使用由创建同一内存映射文件的进程所指派的公用名来映射到此文件)。

2)若要使用一个内存映射文件,则必须创建该内存映射文件的完整视图或部分视图。还可以创建内存映射文件的同一部分的多个视图,进而创建并发内存。为了使两个视图能够并发,必须基于同一内存映射文件创建这两个视图。

3)如果文件大于应用程序用于内存映射的逻辑内存空间(在 32 位计算机上为2GB),则还需要使用多个视图。

有两种类型的视图:流访问视图和随机访问视图。使用流访问视图可对文件进行顺序访问;在使用持久文件时,随机访问视图是首选方法。

.Net 共享内存 内存映射文件原理

通过操作系统的内存管理器访问的,因此会自动将此文件分隔为多个页,并根据需要对其进行访问。您不需要自行处理内存管理。如下图:

C#.Net通信共享内存映射文件是什么

C# .Net 共享内存 演示代码

   //持久内存映射文件:基于现有文件创建一个具有指定公用名的内存映射文件    using (var mmf = MemoryMappedFile.CreateFromFile(@"c:\内存映射文件.data", FileMode.Open, "公用名"))    {        //通过指定的 偏移量和大小 创建内存映射文件视图服务器        using (var accessor = mmf.CreateViewAccessor(offset, length)) //偏移量,可以控制数据存储的内存位置;大小,用来控制存储所占用的空间        {            //Marshal提供了一个方法集,这些方法用于分配非托管内存、复制非托管内存块、将托管类型转换为非托管类型,此外还提供了在与非托管代码交互时使用的其他杂项方法。            int size = Marshal.SizeOf(typeof(char));            //修改内存映射文件视图            for (long i = 0; i < length; i += size)            {                char c= accessor.ReadChar(i);                accessor.Write(i, ref c);            }        }    }    //另一个进程或线程可以,在系统内存中打开一个具有指定名称的现有内存映射文件    using (var mmf = MemoryMappedFile.OpenExisting("公用名"))    {        using (var accessor = mmf.CreateViewAccessor(4000000, 2000000))        {            int size = Marshal.SizeOf(typeof(char));            for (long i = 0; i < length; i += size)            {                char c = accessor.ReadChar(i);                accessor.Write(i, ref c);            }        }    }
//非持久内存映射文件:未映射到磁盘上的现有文件的内存映射文件    using (MemoryMappedFile mmf = MemoryMappedFile.CreateNew("testmap", 10000))    {        bool mutexCreated;        //进程间同步        Mutex mutex = newMutex(true, "testmapmutex", out mutexCreated);        using (var stream = mmf.CreateViewStream()) //创建文件内存视图流 基于流的操作        {            var writer = newBinaryWriter(stream);            writer.Write(1);        }        mutex.ReleaseMutex();        Console.WriteLine("Start Process B and press ENTER to continue.");        Console.ReadLine();        mutex.WaitOne();        using (MemoryMappedViewStream stream = mmf.CreateViewStream())        {            var reader = newBinaryReader(stream);            Console.WriteLine("Process A says: {0}", reader.ReadBoolean());            Console.WriteLine("Process B says: {0}", reader.ReadBoolean());        }        mutex.ReleaseMutex();    }    using (MemoryMappedFile mmf = MemoryMappedFile.OpenExisting("testmap"))    {         Mutex mutex = Mutex.OpenExisting("testmapmutex");        mutex.WaitOne();       using (var stream = mmf.CreateViewStream(1, 0))//注意这里的偏移量        {            var writer = newBinaryWriter(stream);            writer.Write(0);        }        mutex.ReleaseMutex();    }

C# .Net 进程间通信共享内存

完整示例:C#共享内存非持久化方式通讯的例子,通讯时的线程和进程控制也没有问题。

IMServer_Message.exe 代码

using System;using System.IO;using System.IO.MemoryMappedFiles;using System.Runtime.InteropServices;using System.Threading;namespace IMServer_Message{    /// <summary>    /// 用于共享内存方式通信的 值类型 结构体    /// </summary>    public struct ServiceMsg    {        public int Id;        public long NowTime;    }    internal class Program    {        private static void Main(string[] args)        {            Console.Write("请输入共享内存公用名(默认:testmap):");            string shareName = Console.ReadLine();            if (string.IsNullOrEmpty(shareName))                shareName = "testmap";            using (MemoryMappedFile mmf = MemoryMappedFile.CreateOrOpen(shareName, 1024000,MemoryMappedFileAccess.ReadWrite))            {                bool mutexCreated;                //进程间同步                var mutex = new Mutex(true, "testmapmutex", out mutexCreated);                using (MemoryMappedViewStream stream = mmf.CreateViewStream()) //创建文件内存视图流                {                    var writer = new BinaryWriter(stream);                    for (int i = 0; i < 5; i++)                    {                        writer.Write(i);                        Console.WriteLine("{0}位置写入流:{0}", i);                    }                }                mutex.ReleaseMutex();                Console.WriteLine("启动状态服务,按【回车】读取共享内存数据");                Console.ReadLine();                mutex.WaitOne();                using (MemoryMappedViewStream stream = mmf.CreateViewStream())                {                    var reader = new BinaryReader(stream);                    for (int i = 0; i < 10; i++)                    {                        Console.WriteLine("{1}位置:{0}", reader.ReadInt32(), i);                    }                }                using (MemoryMappedViewAccessor accessor = mmf.CreateViewAccessor(1024, 10240))                {                    int colorSize = Marshal.SizeOf(typeof (ServiceMsg));                    ServiceMsg color;                    for (int i = 0; i < 50; i += colorSize)                    {                        accessor.Read(i, out color);                        Console.WriteLine("{1}\tNowTime:{0}", new DateTime(color.NowTime), color.Id);                    }                }                mutex.ReleaseMutex();            }            Console.WriteLine("测试: 我是 即时通讯 - 消息服务 我启动啦!!!");            Console.ReadKey();        }    }}

IMServer_State.exe代码

using System;using System.IO;using System.IO.MemoryMappedFiles;using System.Runtime.InteropServices;using System.Threading;namespace IMServer_State{    /// <summary>    /// 用于共享内存方式通信的 值类型 结构体    /// </summary>    public struct ServiceMsg    {        public int Id;        public long NowTime;    }    internal class Program    {        private static void Main(string[] args)        {            Console.Write("请输入共享内存公用名(默认:testmap):");            string shareName = Console.ReadLine();            if (string.IsNullOrEmpty(shareName))                shareName = "testmap";            using (MemoryMappedFile mmf = MemoryMappedFile.CreateOrOpen(shareName, 1024000,MemoryMappedFileAccess.ReadWrite))            {                Mutex mutex = Mutex.OpenExisting("testmapmutex");                mutex.WaitOne();                using (MemoryMappedViewStream stream = mmf.CreateViewStream(20, 0)) //注意这里的偏移量                {                    var writer = new BinaryWriter(stream);                    for (int i = 5; i < 10; i++)                    {                        writer.Write(i);                        Console.WriteLine("{0}位置写入流:{0}", i);                    }                }                using (MemoryMappedViewAccessor accessor = mmf.CreateViewAccessor(1024, 10240))                {                    int colorSize = Marshal.SizeOf(typeof (ServiceMsg));                    var color = new ServiceMsg();                    for (int i = 0; i < colorSize*5; i += colorSize)                    {                        color.Id = i;                        color.NowTime = DateTime.Now.Ticks;                        //accessor.Read(i, out color);                        accessor.Write(i, ref color);                        Console.WriteLine("{1}\tNowTime:{0}", new DateTime(color.NowTime), color.Id);                        Thread.Sleep(1000);                    }                }                Thread.Sleep(5000);                mutex.ReleaseMutex();            }            Console.WriteLine("测试: 我是 即时通讯 - 状态服务 我启动啦!!!");            Console.ReadKey();        }    }}

感谢各位的阅读,以上就是“C#.Net通信共享内存映射文件是什么”的内容了,经过本文的学习后,相信大家对C#.Net通信共享内存映射文件是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯