C#进程通信 进程之间通讯的几种方法: 在Windows程序中，各个进程之间常常需要交换数据，进行数据通讯。常用的方法有 使用内存映射文件 通过共享内存DLL共享内存 使用SendMessage向另一进程发送WM_COPYDATA消息 比起前两种的复杂实现来,WM_COPYDATA消息无疑是一种经济实惠的一中方法.（ZT） WM_COPYDATA消息的主要目的是允许在进程间传递只读数据。Windows在通过WM_COPYDATA消息传递期间，不提供继承同步方式。SDK文档推荐用户使用SendMessage函数，接受方在数据拷贝完成前不返回，这样发送方就不可能删除和修改数据： 这个函数的原型及其要用到的结构如下: SendMessage(hwnd,WM_COPYDATA,wParam,lParam); 其中,WM_COPYDATA对应的十六进制数为0x004A wParam设置为包含数据的窗口的句柄。lParam指向一个COPYDATASTRUCT的结构： typedef struct tagCOPYDATASTRUCT{ DWORD dwData;//用户定义数据 DWORD cbData;//数据大小 PVOID lpData;//指向数据的指针 }COPYDATASTRUCT; 该结构用来定义用户数据。 具体过程如下:   首先,在发送方,用FindWindow找到接受方的句柄,然后向接受方发送WM_COPYDATA消息. 接受方在DefWndProc事件中,来处理这条消息.由于中文编码是两个字节,所以传递中文时候字节长度要搞清楚. 体代码如下: //--------------------------------------------------- //发送方: using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Runtime.InteropServices;   namespace WindowsFormsApplication1 {     public partial class Form1 : Form     {         const int WM_COPYDATA = 0x004A;           public Form1()         {             InitializeComponent();         }           private void Form1_Load(object sender, EventArgs e)         {           }           [DllImport("User32.dll",EntryPoint="SendMessage")]          private static extern int SendMessage(          int hWnd, // handle to destination window          int Msg, // message          int wParam, // first message parameter          ref COPYDATASTRUCT lParam // second message parameter         );          [DllImport("User32.dll",EntryPoint="FindWindow")]        private static extern int FindWindow(string lpClassName,string        lpWindowName);             private void button1_Click(object sender, EventArgs e)         {             int WINDOW_HANDLER = FindWindow(null,@"欲发送程序窗口的标题");             if(WINDOW_HANDLER != 0)             {               byte[] sarr = System.Text.Encoding.Default.GetBytes(this.textBox1.Text);               int len = sarr.Length;               COPYDATASTRUCT cds;               cds.dwData = (IntPtr) 100;               cds.lpData = this.textBox1.Text;               cds.cbData = len + 1;               SendMessage(WINDOW_HANDLER, WM_COPYDATA, 0, ref cds);}             }         }          public struct COPYDATASTRUCT        {           public IntPtr dwData;           public int cbData;           [MarshalAs(UnmanagedType.LPStr)]            public string lpData;        } }   //--------------------------------------------------- //接受方 //--------------------------------------------------- using System; using System.Drawing; using System.Collections; using System.ComponentModel; using System.Windows.Forms; using System.Data; using System.Runtime.InteropServices; namespace WindowsFormGetMsg { public class Form1 : System.Windows.Forms.Form { private System.Windows.Forms.TextBox textBox1; private System.ComponentModel.Container components = null; const int WM_COPYDATA = 0x004A; public Form1() { InitializeComponent(); } protected override void Dispose( bool disposing ) { if( disposing ) { if (components != null) { components.Dispose(); } } base.Dispose( disposing ); } private void InitializeComponent() { this.textBox1 = new System.Windows.Forms.TextBox(); this.SuspendLayout(); // // textBox1 // this.textBox1.Location = new System.Drawing.Point(176, 32); this.textBox1.Name = "textBox1"; this.textBox1.Size = new System.Drawing.Size(160, 21); this.textBox1.TabIndex = 0; this.textBox1.Text = "textBox1"; // // Form1 // this.AutoScaleBaseSize = new System.Drawing.Size(6, 14); this.ClientSize = new System.Drawing.Size(432, 266); this.Controls.AddRange(new System.Windows.Forms.Control[] { this.textBox1}); this.Name = "Form1"; this.Text = "接收方窗体"; this.ResumeLayout(false); } static void Main() { Application.Run(new Form1()); } protected override void DefWndProc(ref System.Windows.Forms.Message m) { switch(m.Msg) { case WM_COPYDATA: COPYDATASTRUCT mystr = new COPYDATASTRUCT(); Type mytype = mystr.GetType(); mystr =(COPYDATASTRUCT)m.GetLParam(mytype); this.textBox1.Text =mystr.lpData; break; default: base.DefWndProc(ref m); break; } } } public struct COPYDATASTRUCT { public IntPtr dwData; public int cbData; [MarshalAs(UnmanagedType.LPStr)] public string lpData; } }       使用微软消息队列实现C#进程间通信 Posted on 2008-09-12 15:29 chen eric 阅读(165) 评论(0) 编辑 收藏     使用微软消息队列实现C#进程间通信 开发者在线 Builder.com.cn 更新时间:2007-04-05作者：builder.com.cn 来源: 本文关键词： Zach Smith 消息队列 CSHARP csharp C# c# C#  顾名思义，微软消息队列（MSMQ）是一种给队列发送消息以便稍后进行处理的方法。消息由一个“Producer”（生产者）应用程序发送出去，再由一个“Consumer”（消费者）应用程序返回。   这两个应用程序可以在同一台机器上，在整个网络中，或甚至是位于并不总是连接在一起的不同机器上。MSMQ具有故障保险特性，因为如果第一次传送失败，它会重新发送消息。这样可保证你的应用程序消息到达它们的目的地。   我将应用一个叫做“TechRepublic”的队列。当你运行本文下载版本中的样本实例时，如果这个队列不存在，它会自动建立。   在前面的一篇文章中，Zach Smith说明了如何使用IPC通道在同一台机器上的两个进程间通信。他将在本文中说明如何在同一台机器或网络上的应用程序间实现进程间通信。   访问MSMQ   通过.NET访问队列由System.Messaging.MessageQueue对象完成。列表A说明了如何在一台名为“SRV-MESSAGING”的计算机上访问TechRepublic队列。   列表A   MessageQueue queue =    new MessageQueue("SRV-MESSAGINGTechRepublic");   注：要应用这个对象，你必须在你的项目中添加一个参考。   现在我们有了一个MessageQueue对象，这个对象为你提供与队列交互需要的所有功能。   如果队列不存在，你可以调用MessageQueue对象的静态Create方法编程建立队列。列表B中的代码说明如何检查队列是否存在，建立队列或给队列添加一个参考。   列表B   MessageQueue queue = null;   string queueName = "SRV-MESSAGINGTechRepublic";   if (MessageQueue.Exists(queueName))   queue = newMessageQueue(queueName);   else   queue = MessageQueue.Create(queueName, false);   改写队列   改写队列时，用到MessageQueue.Send方法。列表C举例说明如何向TechRepublic队列发送一条消息。   列表C   queue.Send("My message body", "Message Label");   在这个例子中，我们给TechRepublic队列发送一条正文为“My message body”的消息，并对这个消息应用了一个“Message Label”标签。消息标签允许你不需阅读消息正文就可以分割消息。如果从计算机管理控制台中查看队列，还可在“队列消息”部分看到这些标签。   读取队列   可以使用几种方法从队列中读取消息。最常见的情况是从队列中取出所有消息，然后一次性处理它们。这时要调用MessageQueue.GetAllMessages方法。列表D举例说明如何应用这个方法。   列表D   System.Messaging.Message[] messages = queue.GetAllMessages();   foreach (System.Messaging.Message message in messages)   {   //Do something with the message.   }   你也可以用GetMessageEnumerator2方法代替上面的MessageQueue.GetAllMessages方法。虽然这两个方法的用法类似，但GetMessageEnumerator2只能向前（forward-only）。对于非常庞大的队列，则应用使用这个方法，而不是MessageQueue.GetAllMessages方法。   这是因为GetAllMessages方法领取所有消息，把它们保存在当地内存中；而GetMessageEnumerator2方法只领取当前消息在本地保存，在调用MoveNext时才领取下一条消息。列表E举例说明了GetMessageEnumerator2方法的用法。这段代码检查队列中的每一条消息，再删除它。   列表E   MessageEnumerator enumerator = queue.GetMessageEnumerator2();   while (enumerator.MoveNext())   enumerator.RemoveCurrent();   在使用GetMessageEnumerator2方法时，还要考虑另外一个问题，即你要访问队列中增加的任何新消息，即使它们是在你调用GetMessageEnumerator2后再增加的。这假定新消息被添加到队列末尾。   如果你只希望返回队列中的第一条消息，你应该使用MessageQueue.Receive方法。这个方法会领取队列中的第一条消息，在这个过程中将它从队列中删除。由于消息在读取的时候被删除，你可以确保你的进程是唯一收到消息的进程。Receive方法的应用实例如列表F所示。   列表F   System.Messaging.Message message = queue.Receive();   可以用Peek方法代替Receive方法。Peek方法像Receive方法一样领取队列中的第一条消息；但是，它在队列中保留消息备份。这允许你从队列中删除消息之前检查消息内容。Peek的语法与Receive类似。   列表G   System.Messaging.Message message = queue.Peek();   发送/接收序列化对象   虽然给队列发送文本的功能非常有用，但队列还允许你发送可序列化对象。这意味着你可以建立一个自定义的.NET类，实例化它的一个实例，将其发送给队列以便其它应用程序使用。要完成这个过程，首先得使用XML Serializer序列化被发送的对象，然后对序列化对象放到消息的正文中。   例如，假设我们希望给TechRepublic消息队列发送以下对象（列表H）：   列表H   [Serializable()]   publicclassMessageContent   {   privateDateTime _creationDate = DateTime.Now;   privatestring _messageText;   public MessageContent()   {   }   public MessageContent(string messageText)   {   _messageText = messageText;   }   publicstring MessageText   {   get { return _messageText; }   set { _messageText = value; }   }   publicDateTime CreationDate   {   get { return _creationDate; }   set { _creationDate = value; }   }   }   给队列发送这个对象的一个实例只需简单调用MessageQueue.Send方法，并把一个对象实例作为参数提交给这个方法。列表I说明了这种情况。   列表I   MessageContent message = newMessageContent("Hello world!");   queue.Send(message, "Sample Message");   如你所见，上面的代码类似于我们前面发送正文为一个字符串的消息时使用的代码。接收一个包含序列化对象的消息更加困难一些。我们需要告诉消息它包含哪种对象。   为向消息指出它包含哪种对象，我们必须建立消息的格式化器（formatter）。给消息的Formatter属性指定一个System.Messaging.XmlMessageFormatter对象即可建立格式化器。由于我们的消息包含一个MessageContent对象，我们希望为它配置XmlMessageFormatter。   列表J   message.Formatter =    new System.Messaging.XmlMessageFormatter(   newType[1] { typeof(MessageContent) }   );   既然我们已经给消息指定了一个格式化器，我们可以从消息中提取MessageContent对象。但在这之前，我们需要把message.Body属性的返回值分配给一个MessageContent对象。   列表K   MessageContent content = (MessageContent)message.Body;   在这个例子中，“content”变量是我们向队列发送的原始MessageContent对象的序列化版本，我们可以访问原始对象的所有属性和值。   设定消息优先级别   在正常情况下，队列中的消息以先进先出的形式被访问。这表示如何你先发送消息A，再发送消息B，那么队列将首先返回消息A，然后才是消息B。在多数情况下，这样处理没有问题。但是，有时，由于一条消息比其它消息更加重要，你希望将它提到队列前面。要实现这种功能，你就需要设定消息优先级别。   一条消息的优先级别由它的Message.Priority属性值决定。下面是这个属性的所有有效值（全部来自MessagePriority的列举类型）：   最高（Highest）  非常高（VeryHigh）  高（High）  高于正常级别（AboveNormal）  正常（Normal）  低（Low）  非常低（VeryLow）  最低（Lowest）  消息在队列中的位置由它的优先级别决定——例如，假如队列中有四条消息，两条消息的优先级别为“正常”（Normal），另两条为“高”（High）。则队列中消息排列如下：   High Priority A——这是发送给队列的第一条“高”优先级消息。  High Priority B——这是发送给队列的第二条“高”优先级消息。  Normal Priority A——这是发送队列的第一条“正常”优先级消息。  Normal Priority B——这是发送队列的第二条“正常”优先级消息。  根据这个顺序，如果我们给队列发送另一条“最高”优先级的消息，它将位于队列的顶部。   如果需要使用消息优先级功能，你必须修改发送消息的代码。因为Message对象的构造器没有指定消息优先级别的功能，你必须实例化一个Message对象，并在将它发送给队列之前给它设定相应的属性。列表L中的代码说明如何设定优先级别，并给队列发送一条“最高”优先级别的消息。   列表L   //Instantiate the queue   MessageQueue queue = newMessageQueue(queueName);   //Create a XmlSerializer for the object type we're sending.   XmlSerializer serializer = new    XmlSerializer(typeof(MessageContent));   //Instantiate a new message.   System.Messaging.Message queueMessage =    new System.Messaging.Message();   //Set the priority to Highest.   queueMessage.Priority = MessagePriority.Highest;   //Create our MessageContent object.   MessageContent messageContent =    newMessageContent("Hello world - IMPORTANT!");   //Serialize the MessageContent object into the queueMessage.   serializer.Serialize(queueMessage.BodyStream, messageContent);   //Send the message.   queue.Send(queueMessage, "HIGH PRIORITY");   这段代码和上面代码的最明显区别在于它使用了XmlFormatter。它实际是可选的，列表L中的代码也可用列表M中的代码代替。   列表M   //Instantiate a new message.   System.Messaging.Message queueMessage =    new System.Messaging.Message();   //Set the priority to Highest.   queueMessage.Priority = MessagePriority.Highest;   //Create our MessageContent object.   MessageContent messageContent =    newMessageContent("Hello world - IMPORTANT!");   //Set the body as the messageContent object.   queueMessage.Body = messageContent;   //Send the message.   queue.Send(queueMessage, "HIGH PRIORITY");   这段代码执行和列表L中的代码相同的任务，但代码更少。   应用   输入消费者请求是MSMQ功能的一个简单实例。消费者提出一个请求，由一个面向消费者的应用程序将它送交给消息队列。向队列发送请求后，它会向消费者送出一个确认（acknowledgement）。   然后，一个独立的进程从队列中提取消息，并运行任何所需的业务逻辑（business logic）。完成业务逻辑后，处理系统将向另一个队列提交一个响应。接下来，面向消费者的应用程序从队列中提取这个响应，并给消费者返回一个响应。   这种类型的配置能够加快面向消费者的应用程序的速度，使其迅速做出反应，同时在一个内部系统中完成大量处理工作。这样还可以将请求处理分散到多台内部机器上，提供可扩展性。   下载样本项目   欲获得本文显示的所有代码，请下载相关的实例项目。项目中包含你从一个队列中读或写消息所需的所有代码。   责任编辑:德东   查看本文国际来源   C#中用NAMEDPIPE进程间通信 本文只是一个测试例子，核心代码是kernel32.dll中的一组windows api函数，这里不深入研究，代码都在codeproject上。 http://www.codeproject.com/KB/threads/dotnetnamedpipespart1.aspx   测试效果如下，可以做到aspx和给console app发送消息后得到反馈： console app为服务器端代码如下   view plaincopy to clipboardprint?

1. using System;   

2. using AppModule.InterProcessComm;   

3. using AppModule.NamedPipes;   

4. using System.Threading;   

5. namespace Server   

6. {   

7.     class Program   

8.     {   

9.         //**c#中用namedpipe进程间通信   

10.         //**组件代码来自codeproject   

11.         //**http://www.codeproject.com/KB/threads/dotnetnamedpipespart1.aspx    

12.         //**下载上面链接中的代码，编译AppModule.InterProcessComm和AppModule.NamedPipes两个dll   

13.         //**引用这两个dll到本例中，运行如下代码作为服务器端测试   

14.         //**测试代码by jinjazz（因为原作者的两个测试程序比较复杂，这里简化后供大家参考）  

15.         static void Main(string[] args)   

16.         {   

17.             ServerPipeConnection PipeConnection = new ServerPipeConnection("np-test-by-jinjazz", 512, 512, 5000, false);   

18.             Console.WriteLine("listening..");   

19.             while (true)   

20.             {   

21.                 try  

22.                 {   

23.                     PipeConnection.Disconnect();   

24.                     PipeConnection.Connect();   

25.                     string request = PipeConnection.Read();   

26.                     if (!string.IsNullOrEmpty(request))   

27.                     {   

28.                         Console.WriteLine("get:" + request);   

29.                         PipeConnection.Write("get:" + request);   

30.                         if (request.ToLower() == "break") break;   

31.                     }   

32.                 }   

33.                 catch (Exception ex)   

34.                 {   

35.                     Console.WriteLine(ex.Message);   

36.                     break;   

37.                 }   

38.             }   

39.             PipeConnection.Dispose();   

40.             Console.Write("press any key to exit..");   

41.             Console.Read();   

42.         }   

43.     }   

44. }  

      客户端的aspx代码如下   view plaincopy to clipboardprint?

1. using System;   

2. using System.Web;   

3. using AppModule.InterProcessComm;   

4. using AppModule.NamedPipes;   

5. public partial class _Default : System.Web.UI.Page    

6. {   

7.     protected void Page_Load(object sender, EventArgs e)   

8.     {   

9.         Response.Write(SendRequest("测试asdf"));   

10.     }   

11.     ///    

12.     /// 测试namepiped客户端   

13.     ///    

14.     /// 发送命令   

15.     /// 返回数据   

16.     string SendRequest(string request)   

17.     {   

18.         string response="";   

19.         IInterProcessConnection clientConnection = null;   

20.         try  

21.         {   

22.             clientConnection = new ClientPipeConnection("np-test-by-jinjazz", ".");   

23.             clientConnection.Connect();   

24.             clientConnection.Write(request);   

25.             response=clientConnection.Read();   

26.             clientConnection.Close();   

27.         }   

28.         catch (Exception ex)   

29.         {   

30.             clientConnection.Dispose();   

31.             response = ex.Message;   

32.         }   

33.         return response;   

34.     }   

35. }  

      测试环境为windows vista和windows2003