资源简介
在.NET中基于Windows消息的IPC实现
一、什么是IPC
IPC（Inter process Communication）就是“进程间通讯”。我们都知道，在windows系统中，各个应用程序（进程）之间常常需要交换、传递数据，这就要解决进程间的数据通信问题。在最初的16位Windows3.x系统中，所有Windows应用程序共享单一地址，任何进程都能够对这一共享地址空间的数据进行读写操作。
随着Windwos98、Windows NT、Windows2000等32位的操作系统的出现，每个进程都有自己的地址空间，一个Windows进程不能存取另一个进程的私有数据，也就是说，虽然两个进程可以用具有相同值的指针寻址，但所读写的只是它们各自的数据，这样就减少了进程之间的相互干扰。
二、如何实现IPC
那么在windows当前系统下，如何实现进程通讯呢？其实有很多方法，如：
1、 剪贴板Clipboard
2、 DDE（动态数据交换）
3、 内存映像
4、 消息管道
5、 邮件槽
6、 Socket
7、 RPC
8、 串行/并行通信(Serial/Parallel Communication)
9、 COM/DCOM
10、Windows消息
三、基于Windows消息的IPC
现在让我们进入今天我们要讲的主题：“基于Windows消息的IPC实现”。
在这里，我假定大家对Windows消息机制都有很好的理解，所以我就不在这上面费太多的墨水了。我们直接看看Windows消息是怎么样实现进程间通讯的。我们首先看看Windows的消息常数：
WM_COPYDATA=0x004A// 当一个应用程序传递数据给另一个应用程序时发送此消息。
这就是我们要的。下面我们来看看如何利用它来实现IPC。
让我们先看看几个API函数，没有它们，我们没有办法将数据发送出去。
1、 PostMessage
函数功能：该函数将一个消息放入（寄送）到与指定窗口创建的线程相联系消息队列里，不等待线程处理消息就返回。消息队列里的消息通过调用GetMessage和PeekMessage取得。
函数原型：B00L PostMessage（HWND hWnd，UINT Msg，WPARAM wParam，LPARAM lParam）；
参数
hWnd：其窗口程序接收消息的窗口的句柄。可取有特定含义的两个值：
HWND.BROADCAST：消息被寄送到系统的所有顶层窗口，包括无效或不可见的非自身拥有的窗口、被覆盖的窗口和弹出式窗口。消息不被寄送到子窗口。
NULL：此函数的操作和调用参数dwThread设置为当前线程的标识符PostThreadMessage函数一样。
Msg：指定被寄送的消息。
wParam：指定附加的消息特定的信息。
IParam：指定附加的消息特定的信息。
返回值：如果函数调用成功，返回非零值：如果函数调用失败，返回值是零。若想获得更多的错误信息，请调用GetLastError函数。
2、 SendMessage
函数功能：该函数将指定的消息发送到一个或多个窗口。此函数为指定的窗口调用窗口程序，直到窗口程序处理完消息再返回。而函数PostMessage不同，将一个消息寄送到一个线程的消息队列后立即返回。
函数原型：LRESULT SendMessage（HWND hWnd，UINT Msg，WPARAM wParam，LPARAM IParam）；
参数：
hWnd：其窗口程序将接收消息的窗口的句柄。如果此参数为HWND_BROADCAST，则消息将被发送到系统中所有顶层窗口，包括无效或不可见的非自身拥有的窗口、被覆盖的窗口和弹出式窗口，但消息不被发送到子窗口。
Msg：指定被发送的消息。
wParam：指定附加的消息指定信息。
IParam：指定附加的消息指定信息。
返回值：返回值指定消息处理的结果，依赖于所发送的消息。
3、 RegisterWindowMessage
函数功能：RegisterWindowMessage函数定义一个新的窗口消息，该消息保证在整个系统范围内是唯一的。调用SendMessage或PostMessage函数时可以使用该函数返回的消息值。
函数原型：UINT RegisterWindowMessage(lpsz)
参数：
lpsz指向一个以NULL结束的字符串，该字符串指定待登记的消息。
返回值：若成功地登记了消息，返回值是一个消息标识符。该标识符值的范围在0XC000到0XFFFF之间，否则，返回值为0。
我们现在在C#中声明这些API函数:
[DllImport("user32")]
internal static extern int RegisterWindowMessage(string lpString);
[DllImport("user32")]
internal static extern int PostMessage(IntPtr hWnd, int Msg, int wParam, int lParam);
[DllImport("user32")]
internal static extern int PostMessage(IntPtr hwnd, int wMsg, IntPtr wParam, IntPtr lParam);
[DllImport("user32")]
internal static extern int SendMessage(IntPtr hWnd, int Msg, IntPtr wParam, ref COPYDATASTRUCT lParam);
internal static extern int RegisterWindowMessage(string lpString);
[DllImport("user32")]
internal static extern int PostMessage(IntPtr hWnd, int Msg, int wParam, int lParam);
[DllImport("user32")]
internal static extern int PostMessage(IntPtr hwnd, int wMsg, IntPtr wParam, IntPtr lParam);
[DllImport("user32")]
internal static extern int SendMessage(IntPtr hWnd, int Msg, IntPtr wParam, ref COPYDATASTRUCT lParam);
然后定义一些我们需要的常数：
internal const int WM_COPYDATA = 0x004A; //当一个应用程序传递数据给另一个应用程序时发送此消息
internal const int WM_DESTROY = 0x0002; //窗体被销毁
internal const int WM_CREATE = 0x0001; //应用程序创建一个窗口
internal const int WM_QUERYENDSESSION = 0x0011; //当用户选择结束对话框或程序自己调用ExitWindows函数
internal static readonly IntPtr HWND_BROADCAST = new IntPtr(0xFFFF);
internal const int WM_DESTROY = 0x0002; //窗体被销毁
internal const int WM_CREATE = 0x0001; //应用程序创建一个窗口
internal const int WM_QUERYENDSESSION = 0x0011; //当用户选择结束对话框或程序自己调用ExitWindows函数
internal static readonly IntPtr HWND_BROADCAST = new IntPtr(0xFFFF);
我们还需要一个传送数据的结构：
///<summary>
///发送WM_COPYDATA消息的数据结构
///</summary>
internal struct COPYDATASTRUCT
{
///<summary>
///用户自定义数据
///</summary>
internal IntPtr dwData;
///<summary>
///数据长度
///</summary>
internal int cbData;
///<summary>
///数据首地址指针
///</summary>
internal IntPtr lpData;
}
///发送WM_COPYDATA消息的数据结构
///</summary>
internal struct COPYDATASTRUCT
{
///<summary>
///用户自定义数据
///</summary>
internal IntPtr dwData;
///<summary>
///数据长度
///</summary>
internal int cbData;
///<summary>
///数据首地址指针
///</summary>
internal IntPtr lpData;
}
现在我们来看看具体如何实现：
1、 我们首先创建一个类，让它从Form类继承，因为我们需要一个窗体，然后对它的消息进行处理：
internal class WinMsg : Form
{
private string _messageString;
private List<IntPtr> _windowList;
private int _message;
private int _intHandler;
private bool _isConnected;
}
{
private string _messageString;
private List<IntPtr> _windowList;
private int _message;
private int _intHandler;
private bool _isConnected;
}
2、 然后定义构造函数，在构造函数里注册一个消息通道值，并发出一个广播通知其它在这个通道的窗口。
internal WinMsg(string messageString)
{
_messageString = messageString;
_isConnected = false;
_intHandler = Handle.ToInt32();
_windowList = new List<IntPtr>();
_message = Win32.RegisterWindowMessage(_messageString);//注册一个消息通道
int errCode = Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.CONNECTION, _intHandler);//向此通道内所有的窗口广播自己的句柄
if (errCode == 0)
{
throw new Win32Exception(errCode);//发生错误，抛出异常
}
else
{
_isConnected = true;
}
}
{
_messageString = messageString;
_isConnected = false;
_intHandler = Handle.ToInt32();
_windowList = new List<IntPtr>();
_message = Win32.RegisterWindowMessage(_messageString);//注册一个消息通道
int errCode = Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.CONNECTION, _intHandler);//向此通道内所有的窗口广播自己的句柄
if (errCode == 0)
{
throw new Win32Exception(errCode);//发生错误，抛出异常
}
else
{
_isConnected = true;
}
}
3、 重写基类的WndProc函数，处理接收到的消息：
protected override void WndProc(ref Message m)
{
if (m.Msg == _message)//接收到广播消息，进行处理
{
int LParam = m.LParam.ToInt32();
int WParam = m.WParam.ToInt32();
if (LParam != 0 && LParam != _intHandler)
{
if (WParam == Win32.DISCONNECTION)
{
_windowList.Remove(m.WParam);//将对方窗口的句柄从列表中删除
}
else
{
if (WParam==Win32.CONNECTION)
{
Win32.PostMessage(m.LParam, _message, Win32.REVERSION, _intHandler);
}
_windowList.Add(m.LParam);//将对方窗口的句柄存入列表中
}
}
return;
}
switch (m.Msg)
{
case Win32.WM_COPYDATA://接收到其它窗口发送过来的数据
{
COPYDATASTRUCT data = new COPYDATASTRUCT();
data = (COPYDATASTRUCT)m.GetLParam(data.GetType());
byte[] message = new byte[data.cbData];
Marshal.Copy(data.lpData, message, 0, data.cbData);//从非托管内存中将数据复制到我们的byte数组中。
Anyzler(m.WParam, message);//在这里处理接收到的数据。
}
break;
case Win32.WM_DESTROY:
case Win32.WM_QUERYENDSESSION://窗口被关闭，向其它窗口广播通知从队列中删除自己
Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.DISCONNECTION, _intHandler);
base.WndProc(ref m);//调用基类的消息处理函数。
break;
default:
base.WndProc(ref m); //调用基类的消息处理函数。
break;
}
}
{
if (m.Msg == _message)//接收到广播消息，进行处理
{
int LParam = m.LParam.ToInt32();
int WParam = m.WParam.ToInt32();
if (LParam != 0 && LParam != _intHandler)
{
if (WParam == Win32.DISCONNECTION)
{
_windowList.Remove(m.WParam);//将对方窗口的句柄从列表中删除
}
else
{
if (WParam==Win32.CONNECTION)
{
Win32.PostMessage(m.LParam, _message, Win32.REVERSION, _intHandler);
}
_windowList.Add(m.LParam);//将对方窗口的句柄存入列表中
}
}
return;
}
switch (m.Msg)
{
case Win32.WM_COPYDATA://接收到其它窗口发送过来的数据
{
COPYDATASTRUCT data = new COPYDATASTRUCT();
data = (COPYDATASTRUCT)m.GetLParam(data.GetType());
byte[] message = new byte[data.cbData];
Marshal.Copy(data.lpData, message, 0, data.cbData);//从非托管内存中将数据复制到我们的byte数组中。
Anyzler(m.WParam, message);//在这里处理接收到的数据。
}
break;
case Win32.WM_DESTROY:
case Win32.WM_QUERYENDSESSION://窗口被关闭，向其它窗口广播通知从队列中删除自己
Win32.PostMessage(Win32.HWND_BROADCAST, _message, Win32.DISCONNECTION, _intHandler);
base.WndProc(ref m);//调用基类的消息处理函数。
break;
default:
base.WndProc(ref m); //调用基类的消息处理函数。
break;
}
}
4、 定义发送消息的函数：
internal void Send(byte[] message)
{
if (_isConnected)
{
int length = message.Length;
IntPtr ptr = Marshal.AllocHGlobal(length);//申请一块非托管内存
Marshal.Copy(message, 0, ptr, length);//将要发送的数据封送到非托管内存
COPYDATASTRUCT data = new COPYDATASTRUCT();
data.dwData = IntPtr.Zero;//这里可以随意定义。
data.cbData = length;//传递要发送的数据的长度
data.lpData = ptr;//传递要发送的数据的地址指针
//向其它所有窗口发送数据，这里不能发广播消息。必须一个一个发送。
foreach (IntPtr window in _windowList)
{
Win32.SendMessage(window, Win32.WM_COPYDATA, this.Handle, ref data);
}
Marshal.FreeHGlobal(ptr);//释放这块非托管内存，这行一定要写上，不然会内存泄漏。
}
}
{
if (_isConnected)
{
int length = message.Length;
IntPtr ptr = Marshal.AllocHGlobal(length);//申请一块非托管内存
Marshal.Copy(message, 0, ptr, length);//将要发送的数据封送到非托管内存
COPYDATASTRUCT data = new COPYDATASTRUCT();
data.dwData = IntPtr.Zero;//这里可以随意定义。
data.cbData = length;//传递要发送的数据的长度
data.lpData = ptr;//传递要发送的数据的地址指针
//向其它所有窗口发送数据，这里不能发广播消息。必须一个一个发送。
foreach (IntPtr window in _windowList)
{
Win32.SendMessage(window, Win32.WM_COPYDATA, this.Handle, ref data);
}
Marshal.FreeHGlobal(ptr);//释放这块非托管内存，这行一定要写上，不然会内存泄漏。
}
}
代码片段和文件信息
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Runtime.InteropServices;
using System.Threading;
namespace WindowsApplication3
{
public partial class Form1 : Form
{
MyWindowsMessage msgData;
public Form1（）
{
InitializeComponent（）;
}
protected override void onload（EventArgs e）
{
msgData = new MyWindowsMessage（“testProject“）;
msgData.Parent = this;
msgData.StartMessage（）;
}
private void button1_Click（object sender EventArgs e）
{
msgData.SendMessage（Encoding.Default.GetBytes（textBox1.Text））;
属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
文件 24576 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\bin\Debug\WindowsApplication3.exe
文件 34304 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\bin\Debug\WindowsApplication3.pdb
文件 5632 2005-09-23 06:56 WindowsApplication3\WindowsApplication3\bin\Debug\WindowsApplication3.vshost.exe
文件 1656 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\Form1.cs
文件 4799 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\Form1.Designer.cs
文件 5814 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\Form1.resx
文件 842 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\obj\Debug\WindowsApplication3.csproj.GenerateResource.Cache
文件 24576 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\obj\Debug\WindowsApplication3.exe
文件 180 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\obj\Debug\WindowsApplication3.Form1.resources
文件 34304 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\obj\Debug\WindowsApplication3.pdb
文件 180 2007-04-28 13:01 WindowsApplication3\WindowsApplication3\obj\Debug\WindowsApplication3.Properties.Resources.resources
文件 352 2007-04-28 13:09 WindowsApplication3\WindowsApplication3\obj\WindowsApplication3.csproj.FileList.txt
文件 489 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Program.cs
文件 1308 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Properties\AssemblyInfo.cs
文件 2865 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Properties\Resources.Designer.cs
文件 5612 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Properties\Resources.resx
文件 1102 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Properties\Settings.Designer.cs
文件 249 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Properties\Settings.settings
文件 3335 2007-04-28 13:01 WindowsApplication3\WindowsApplication3\WindowsApplication3.csproj
文件 9053 2007-04-28 13:28 WindowsApplication3\WindowsApplication3\WindowsMessage.cs
文件 946 2007-04-24 17:21 WindowsApplication3\WindowsApplication3.sln
..A..H. 74752 2007-04-28 13:53 WindowsApplication3\WindowsApplication3.suo
目录 0 2007-04-25 11:41 WindowsApplication3\WindowsApplication3\obj\Debug\Refactor
目录 0 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\obj\Debug\TempPE
目录 0 2007-04-28 13:01 WindowsApplication3\WindowsApplication3\bin\Debug
目录 0 2007-04-28 13:08 WindowsApplication3\WindowsApplication3\obj\Debug
目录 0 2007-04-28 10:00 WindowsApplication3\WindowsApplication3\bin
目录 0 2007-04-26 17:16 WindowsApplication3\WindowsApplication3\obj
目录 0 2007-04-24 17:21 WindowsApplication3\WindowsApplication3\Properties
目录 0 2007-04-28 13:28 WindowsApplication3\WindowsApplication3
............此处省略4个文件信息
相关资源
- C#联通网络宽带测试 拨号
- C#百度指数抓取方法（2012年版本已失
- C# 隐藏某个磁盘分区
- C# 读取并编辑window系统的右键菜单
- C#自定义屏保（不断滚动的文字）
- C#winform打印指定区域 -控件拖动 -设置
- C#使用Hook进行改键
- 提供C#调用系统API函数弹出或收起光驱
- 通过C#自带的头文件（类）获取Windo
- C#获取电脑CPU以及内存使用率
- pop3lib类库 +（这个不错） 附完整
- 利用uu云打码平台的lib实现的c#打码平
- tf-idf一种计算方法
- C# pop3 邮件接收程序
- C# 邮件群发示例 源码下载18952
- 动态抓取IPC#实现
- XXTEA算法的C#实现和JS实现，可以互相
- C# 飞行棋 游戏源码（面向对象入门）
- 基于WinPcap的C# ARP欺骗软件（）.rar
- C#网络应用编程 矩阵并行计算练习
- 《C#版Ftp软件源码》
-
C# 播放铃声（AxWindowsMediaPla
yer）最新 - C# 把图片显示成椭圆形状
- C# 水平交错效果显示图像
- winform 浮雕效果的图像
- c# 底片效果显示图像就像旧式相机的
- 积木效果显示图像
- C# 隐形窗体 （没有边框，没有标题栏
- browerPhotoC#网页截图（不打开网页）
- C# 模拟时钟（自绘Graphics）
评论
共有 条评论