.Net中封装Windows 消息实现进程间通讯

.NET Framework 中对进程间的通讯支持不多，不过Windows API 已经为我们提供了丰富的进程间通讯的特性。我们可以使用Windows API SendMessage、PostMessage来实现windows 窗体之间的通讯。本文就是将SendMessage封装在一个窗体基类WinMsgData中，把它变成类中的一个方法以方便调用，而接收其他窗体的消息则封装成事件通知的形式提供。其中还对接收到的消息做队列处理，避免对消息发送方造成阻塞。所以只要程序中的WinForm从这个基类继承，就可以很方便的与其他的窗体进行通讯了。

下面看看具体的实现吧。
首先在窗体的构造函数中，我使用RegisterWindowMessage为希望通讯的窗体在系统中注册一个消息值。然后执行一个“Connect”的动作，就是使用PostMessage做广播，看看是否有“志同道合”者。代码如下：

1. publiceventWindowsMessageHandlerOnMessage;
2. publicdelegatevoidWindowsMessageHandler(objectsender,
3. WindowsMessageEventArgse);
5. privateconststringDefaultAttachWindowMessage
6. ="Peanut.DefaultAttachWinMsgString";
7. privateboolconnected=false;
8. privateintattachMessage;
9. privateintthisHandle;
10. privatestringattachMessageString;
11. privateList<IntPtr>AttachWindows;
12. privateQueue<WindowsMessageEventArgs>incomingMessageQueue
13. =newQueue<WindowsMessageEventArgs>();
14. publicWinMsgData():this(DefaultAttachWindowMessage){}
16. publicWinMsgData(stringattachMessageString)
17. {
18. this.thisHandle=this.Handle.ToInt32();
19. AttachWindows=newList<IntPtr>();
20. this.attachMessageString=attachMessageString;
21. this.attachMessage=User32.RegisterWindowMessage(attachMessageString);
22. Connect();//“连接”
23. }
25. privatevoidConnect()
26. {
27. if(User32.PostMessage(User32.HWND_BROADCAST,
28. attachMessage,thisHandle,1)==0)//连接
29. thrownewException("PostMessagefailed.");
30. else
31. connected=true;
32. }

调用到Windows API代码如下：
具体如何调用Windows的API请看Calling Win32 DLLs in C# with P/Invoke。

1. publicstructCOPYDATASTRUCT
2. {
3. publicIntPtrdwData;
4. publicintcbData;
5. [MarshalAs(UnmanagedType.LPStr)]
6. publicstringlpData;
7. }
9. publicclassUser32
10. {
11. publicconstintWM_COPYDATA=0x4A;
12. publicconstintWM_DESTROY=0x0002;
13. publicconstintWM_QUERYENDSESSION=0x0011;
14. publicconstintWM_QUEUE_NOTIFY=0x401;
16. [DllImport("user32")]
17. publicstaticexternintPostMessage(IntPtrhwnd,intwMsg,intwParam,intlParam);
18. [DllImport("user32")]
19. publicstaticexternintRegisterWindowMessage(stringlpString);
20. [DllImport("user32")]
21. publicstaticexternintSendMessage(IntPtrhWnd,intMsg,
22. intwParam,refCOPYDATASTRUCTlParam);
24. publicstaticIntPtrHWND_BROADCAST
25. {
26. get{return(IntPtr)0xFFFF;}
27. }
28. }

然后就要重写WndProc来接收处理窗体消息了：

1. protectedoverridevoidWndProc(refMessagem)
2. {
3. if(m.Msg==attachMessage&
4. m.WParam.ToInt32()!=0&
5. m.WParam.ToInt32()!=thisHandle)
6. {
7. if(m.LParam.ToInt32()==1)
8. User32.PostMessage(m.WParam,attachMessage,thisHandle,0);//回复
10. if(m.LParam.ToInt32()==-1)
11. AttachWindows.Remove(m.WParam);//删除窗体句柄
12. else//0，1
13. AttachWindows.Add(m.WParam);//保存窗体句柄
14. }
15. switch(m.Msg)
16. {
17. caseUser32.WM_COPYDATA:
18. COPYDATASTRUCTcopyData=newCOPYDATASTRUCT();
19. copyData=(COPYDATASTRUCT)m.GetLParam(copyData.GetType());
20. MessageNotify(m.WParam.ToInt32(),copyData.lpData);
21. break;
22. caseUser32.WM_QUEUE_NOTIFY:
23. if(incomingMessageQueue.Count==0)
24. break;
26. WindowsMessageEventArgstempArgs=incomingMessageQueue.Dequeue();
27. if(OnMessage!=null)
28. OnMessage(thisHandle,tempArgs);
30. if(incomingMessageQueue.Count>0)
31. User32.PostMessage(this.Handle,User32.WM_QUEUE_NOTIFY,0,0);//下一个
32. break;
33. caseUser32.WM_QUERYENDSESSION:
34. caseUser32.WM_DESTROY:
35. User32.PostMessage(User32.HWND_BROADCAST,
36. attachMessage,thisHandle,-1);//让其他人删除别再给我发消息
37. break;
38. }
39. base.WndProc(refm);
40. }

假如已经有窗体进程已经在运行，那么它就会收到新窗体起来时是所发送的“Connect”消息。上面的代码中第一个if就时处理这个消息的。首先会给消息发送者一个响应。然后会将发送者(窗体的句柄)保存到的列表AttachWindows中。
窗体后面部分就是真正处理通讯消息的部分了。MessageNotify方法首先将消息入队，接着给自己发送一个PostMessage通知自己处理，然后就马上返回。大家可能已经注意到WM_QUEUE_NOTIFY了，不错，这个就是通知自己处理消息的。“处理消息”的就是从消息队列中取出一个消息，将消息作为事件参数触发事件。子窗体只要订阅这个事件，并做处理即可。

上面已经把处理消息的过程讲完了，但还没看到发送消息的部分。下面马上给出。
还是先看代码吧，下面的代码是上面提到的MessageNotify方法及发送消息的方法SendMessage();

1. privatevoidMessageNotify(inttarget,stringmessage)
2. {
3. incomingMessageQueue.Enqueue(newWindowsMessageEventArgs(target,message));
4. User32.PostMessage(this.Handle,User32.WM_QUEUE_NOTIFY,0,0);
5. }
7. publicvoidSendMessage(inttarWin,stringmessage)
8. {
9. if(!connected)
10. thrownewException("notconnected!");
12. byte[]bytes=System.Text.Encoding.UTF8.GetBytes(message);
13. intlength=bytes.Length;
15. COPYDATASTRUCTcopyData=newCOPYDATASTRUCT();
16. copyData.dwData=(IntPtr)1;
17. copyData.lpData=message;
18. copyData.cbData=length+1;
20. System.Threading.Thread.Sleep(100);
21. try
22. {
23. User32.SendMessage((IntPtr)tarWin,User32.WM_COPYDATA,thisHandle,refcopyData);
24. }
25. catch(Exceptione)
26. {
27. thrownewException("windowssendmessageerror",e);
28. }
29. }

还有消息的参数类：

1. publicclassWindowsMessageEventArgs:EventArgs
2. {
3. [====Fields====]#region[====Fields====]
4. privateinttargetWinHandle;
5. privatestringdata;
7. #endregion
9. publicWindowsMessageEventArgs(inttargetWinHandle,stringdata)
10. {
11. this.targetWinHandle=targetWinHandle;
12. this.data=data;
13. }
15. [====Properties====]#region[====Properties====]
16. /**////<summary>
17. ///消息发送者窗体句柄值
18. ///</summary>
19. publicintTargetWinHandle
20. {
21. get{returntargetWinHandle;}
22. }
24. publicstringData
25. {
26. get{returndata;}
27. }
29. #endregion

子窗体只要从WinMsgData继承，并订阅消息事件：
base.OnMessage += new WinMsgData.WindowsMessageHandler(HandleMyMessage);
要发送消息的时候调用base.SendMessage(yourMessageToSend)就可以了。使用方便。
效果图：