接收端

      using System;
      using System.Collections.Generic;
      using System.ComponentModel;
      using System.Data;
      using System.Drawing;
      using System.Linq;
      using System.Runtime.InteropServices;
      using System.Text;
      using System.Threading;
      using System.Threading.Tasks;
      using System.Windows.Forms;
      namespace WindowsFormsApp1
      {
         public partial class Form1 : Form
          {
             const int INVALID_HANDLE_VALUE = -1;
             const int PAGE_READWRITE = 0x04;
              [DllImport("User32.dll")]
             private static extern bool ShowWindowAsync(IntPtr hWnd, int cmdShow);
              [DllImport("User32.dll")]
             private static extern bool SetForegroundWindow(IntPtr hWnd);
             //共享内存
              [DllImport("Kernel32.dll", EntryPoint = "CreateFileMapping")]
             private static extern IntPtr CreateFileMapping(IntPtr hFile, //HANDLE hFile,
       UInt32 lpAttributes,//LPSECURITY_ATTRIBUTES lpAttributes, //0
       UInt32 flProtect,//DWORD flProtect
       UInt32 dwMaximumSizeHigh,//DWORD dwMaximumSizeHigh,
       UInt32 dwMaximumSizeLow,//DWORD dwMaximumSizeLow,
       string lpName//LPCTSTR lpName
       );
              [DllImport("Kernel32.dll", EntryPoint = "OpenFileMapping")]
             private static extern IntPtr OpenFileMapping(
               UInt32 dwDesiredAccess,//DWORD dwDesiredAccess,
              int bInheritHandle,//BOOL bInheritHandle,
              string lpName//LPCTSTR lpName
               );
             const int FILE_MAP_ALL_ACCESS = 0x0002;
             const int FILE_MAP_WRITE = 0x0002;
              [DllImport("Kernel32.dll", EntryPoint = "MapViewOfFile")]
             private static extern IntPtr MapViewOfFile(
       IntPtr hFileMappingObject,//HANDLE hFileMappingObject,
       UInt32 dwDesiredAccess,//DWORD dwDesiredAccess
       UInt32 dwFileOffsetHight,//DWORD dwFileOffsetHigh,
       UInt32 dwFileOffsetLow,//DWORD dwFileOffsetLow,
       UInt32 dwNumberOfBytesToMap//SIZE_T dwNumberOfBytesToMap
       );
              [DllImport("Kernel32.dll", EntryPoint = "UnmapViewOfFile")]
             private static extern int UnmapViewOfFile(IntPtr lpBaseAddress);
              [DllImport("Kernel32.dll", EntryPoint = "CloseHandle")]
             private static extern int CloseHandle(IntPtr hObject);
             private Semaphore m_Write;  //可写的信号
             private Semaphore m_Read;  //可读的信号
             private IntPtr handle;     //文件句柄
             private IntPtr addr;       //共享内存地址
             uint mapLength;            //共享内存长
             //线程用来读取数据
              Thread threadRed;
             public Form1()
              {
                  InitializeComponent();
                 init();
              }
             ///<summary>/// 初始化共享内存数据 创建一个共享内存
             ///</summary>
             private void init()
              {
                  m_Write = new Semaphore(1, 1, "WriteMap");//开始的时候有一个可以写
                  m_Read = new Semaphore(0, 1, "ReadMap");//没有数据可读
                  mapLength = 1024;
                  IntPtr hFile = new IntPtr(INVALID_HANDLE_VALUE);
                  handle = CreateFileMapping(hFile, 0, PAGE_READWRITE, 0, mapLength, "shareMemory");
                  addr = MapViewOfFile(handle, FILE_MAP_ALL_ACCESS, 0, 0, 0);
                  threadRed = new Thread(new ThreadStart(ThreadReceive));
                  threadRed.Start();
              }
             /// <summary>
             /// 线程启动从共享内存中获取数据信息 
             /// </summary>
             private void ThreadReceive()
              {
                 while (true)
                  {
                     try
                      {
                         //读取共享内存中的数据：
                         //是否有数据写过来
                          m_Read.WaitOne();
                         //IntPtr m_Sender = MapViewOfFile(handle, FILE_MAP_ALL_ACCESS, 0, 0, 0);
                         byte[] byteStr = new byte[100];
                          byteCopy(byteStr, addr);
                         string str = Encoding.Default.GetString(byteStr, 0, byteStr.Length);
                         this.Invoke((MethodInvoker)(delegate ()
                          { textBox1.Text = str.Trim(); })
                              );
                          /调用数据处理方法 处理读取到的数据
                          m_Write.Release();
                      }
                     catch (WaitHandleCannotBeOpenedException)
                      {
                         continue;
                         //Thread.Sleep(0);
                      }
                  }
              }
             //不安全的代码在项目生成的选项中选中允许不安全代码
             static unsafe void byteCopy(byte[] dst, IntPtr src)
              {
                 fixed (byte* pDst = dst)
                  {
                     byte* pdst = pDst;
                     byte* psrc = (byte*)src;
                     while ((*pdst++ = *psrc++) != '\0')
                          ;
                  }
              }
          }
      }
  
 

发送端

      using System;
      using System.Collections.Generic;
      using System.ComponentModel;
      using System.Data;
      using System.Drawing;
      using System.Linq;
      using System.Runtime.InteropServices;
      using System.Text;
      using System.Threading;
      using System.Threading.Tasks;
      using System.Windows.Forms;
      namespace WindowsFormsApp2
      {
         public partial class Form1 : Form
          {
             const int INVALID_HANDLE_VALUE = -1;
             const int PAGE_READWRITE = 0x04;
             //共享内存
              [DllImport("Kernel32.dll", EntryPoint = "CreateFileMapping")]
             private static extern IntPtr CreateFileMapping(IntPtr hFile, //HANDLE hFile,
       UInt32 lpAttributes,//LPSECURITY_ATTRIBUTES lpAttributes, //0
       UInt32 flProtect,//DWORD flProtect
       UInt32 dwMaximumSizeHigh,//DWORD dwMaximumSizeHigh,
       UInt32 dwMaximumSizeLow,//DWORD dwMaximumSizeLow,
       string lpName//LPCTSTR lpName
       );
              [DllImport("Kernel32.dll", EntryPoint = "OpenFileMapping")]
             private static extern IntPtr OpenFileMapping(
               UInt32 dwDesiredAccess,//DWORD dwDesiredAccess,
              int bInheritHandle,//BOOL bInheritHandle,
              string lpName//LPCTSTR lpName
               );
             const int FILE_MAP_ALL_ACCESS = 0x0002;
             const int FILE_MAP_WRITE = 0x0002;
              [DllImport("Kernel32.dll", EntryPoint = "MapViewOfFile")]
             private static extern IntPtr MapViewOfFile(
       IntPtr hFileMappingObject,//HANDLE hFileMappingObject,
       UInt32 dwDesiredAccess,//DWORD dwDesiredAccess
       UInt32 dwFileOffsetHight,//DWORD dwFileOffsetHigh,
       UInt32 dwFileOffsetLow,//DWORD dwFileOffsetLow,
       UInt32 dwNumberOfBytesToMap//SIZE_T dwNumberOfBytesToMap
       );
              [DllImport("Kernel32.dll", EntryPoint = "UnmapViewOfFile")]
             private static extern int UnmapViewOfFile(IntPtr lpBaseAddress);
              [DllImport("Kernel32.dll", EntryPoint = "CloseHandle")]
             private static extern int CloseHandle(IntPtr hObject);
             private Semaphore m_Write;  //可写的信号
             private Semaphore m_Read;  //可读的信号
             private IntPtr handle;     //文件句柄
             private IntPtr addr;       //共享内存地址
             uint mapLength;            //共享内存长
              Thread threadRed;
             public Form1()
              {
                  InitializeComponent();
                 //threadRed = new Thread(new ThreadStart(init));
                 //threadRed.Start();
                  mapLength = 1024;
              }
             private void button1_Click(object sender, EventArgs e)
              {
                 try
                  {
                      m_Write = Semaphore.OpenExisting("WriteMap");
                      m_Read = Semaphore.OpenExisting("ReadMap");
                      handle = OpenFileMapping(FILE_MAP_WRITE, 0, "shareMemory");
                      addr = MapViewOfFile(handle, FILE_MAP_ALL_ACCESS, 0, 0, 0);
                      m_Write.WaitOne();
                     byte[] sendStr = Encoding.Default.GetBytes(textBox1.Text.ToString() + '\0');
                     //如果要是超长的话，应另外处理，最好是分配足够的内存
                     if (sendStr.Length < mapLength)
                          Copy(sendStr, addr);
                      m_Read.Release();
                  }
                 catch (WaitHandleCannotBeOpenedException)
                  {
                      MessageBox.Show("不存在系统信号量!");
                     return;
                  }
              }
             static unsafe void Copy(byte[] byteSrc, IntPtr dst)
              {
                 fixed (byte* pSrc = byteSrc)
                  {
                     byte* pDst = (byte*)dst;
                     byte* psrc = pSrc;
                     for (int i = 0; i < byteSrc.Length; i++)
                      {
                          *pDst = *psrc;
                          pDst++;
                          psrc++;
                      }
                  }
              }
          }
      }
  
 

文章来源: wanghao.blog.csdn.net，作者：AI浩，版权归原作者所有，如需转载，请联系作者。

原文链接：wanghao.blog.csdn.net/article/details/112003475