您的位置: 首页  >  文章  >  .Net中封装Windows 消息实现进程间通讯

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

分类: 文章 • 2024-11-28 14:09:28

.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)就可以了。使用方便。
效果图：

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

相关推荐