发表文章 返回首页
当前位置: bitsCN.com > DotNet > C# >

使用微软消息队列实现C#进程间通信

时间:2007-06-12 08:00来源:中国网管联盟 作者:bitsCN整理 点击:
     

 顾名思义,微软消息队列(MSMQ)是一种给队列发送消息以便稍后进行处理的方法。消息由一个“Producer”(生产者)应用程序发送出去,再由一个“Consumer”(消费者)应用程序返回。

54ne.com

 这两个应用程序可以在同一台机器上,在整个网络中,或甚至是位于并不总是连接在一起的不同机器上。MSMQ具有故障保险特性,因为如果第一次传送失败,它会重新发送消息。这样可保证你的应用程序消息到达它们的目的地。

54com.cn

 我将应用一个叫做“TechRepublic”的队列。当你运行本文下载版本中的样本实例时,如果这个队列不存在,它会自动建立。 54com.cn

 在前面的一篇文章中,Zach Smith说明了如何使用IPC通道在同一台机器上的两个进程间通信。他将在本文中说明如何在同一台机器或网络上的应用程序间实现进程间通信。 feedom.net

访问MSMQ

中国网管联盟www.bitscn.com

 通过.NET访问队列由System.Messaging.MessageQueue对象完成。列表A说明了如何在一台名为“SRV-MESSAGING”的计算机上访问TechRepublic队列。

54ne.com

列表A

中国网管论坛bbs.bitsCN.com

MessageQueue queue = new MessageQueue("SRV-MESSAGINGTechRepublic"); 
feedom.net

注:要应用这个对象,你必须在你的项目中添加一个参考。

中国网管联盟www、bitsCN、com

 现在我们有了一个MessageQueue对象,这个对象为你提供与队列交互需要的所有功能。 54ne.com

 如果队列不存在,你可以调用MessageQueue对象的静态Create方法编程建立队列。列表B中的代码说明如何检查队列是否存在,建立队列或给队列添加一个参考。 中国网管联盟www、bitsCN、com

列表B 网管网bitsCN_com

MessageQueue queue = null;

中国网管联盟www、bitsCN、com

string queueName = "SRV-MESSAGINGTechRepublic";

网管网bitsCN.com

if (MessageQueue.Exists(queueName))

中国网管联盟www、bitsCN、com

queue = newMessageQueue(queueName);

网管网bitsCN.com

else

中国网管联盟www_bitscn_com

queue = MessageQueue.Create(queueName, false); 中国网管联盟www.bitscn.com

54ne.com

改写队列 54com.cn

改写队列时,用到MessageQueue.Send方法。列表C举例说明如何向TechRepublic队列发送一条消息。

中国网管论坛bbs.bitsCN.com

列表C 中国网管联盟www.bitscn.com

queue.Send("My message body", "Message Label"); 
中国网管联盟www.bitscn.com

 在这个例子中,我们给TechRepublic队列发送一条正文为“My message body”的消息,并对这个消息应用了一个“Message Label”标签。消息标签允许你不需阅读消息正文就可以分割消息。如果从计算机管理控制台中查看队列,还可在“队列消息”部分看到这些标签。

54ne.com

读取队列

中国网管联盟www.bitscn.com

 可以使用几种方法从队列中读取消息。最常见的情况是从队列中取出所有消息,然后一次性处理它们。这时要调用MessageQueue.GetAllMessages方法。列表D举例说明如何应用这个方法。 网管网bitsCN.com

列表D

 System.Messaging.Message[] messages = queue.GetAllMessages();

foreach (System.Messaging.Message message in messages)

中国网管联盟www_bitscn_com

{ 54com.cn

//Do something with the message. 网管网bitsCN_com

}

网管联盟www.bitsCN.com

feedom.net

 你也可以用GetMessageEnumerator2方法代替上面的MessageQueue.GetAllMessages方法。虽然这两个方法的用法类似,但GetMessageEnumerator2只能向前(forward-only)。对于非常庞大的队列,则应用使用这个方法,而不是MessageQueue.GetAllMessages方法。

网管网bitsCN.com

 这是因为GetAllMessages方法领取所有消息,把它们保存在当地内存中;而GetMessageEnumerator2方法只领取当前消息在本地保存,在调用MoveNext时才领取下一条消息。列表E举例说明了GetMessageEnumerator2方法的用法。这段代码检查队列中的每一条消息,再删除它。 网管网bitsCN.com

 

中国网管联盟www、bitsCN、com

中国网管联盟www_bitscn_com

顶一下
(0)
0%
踩一下
(0)
0%
------分隔线----------------------------
最新评论 查看所有评论
发表评论 查看所有评论
请自觉遵守互联网相关的政策法规,严禁发布色情、暴力、反动的言论。
评价:
表情:
用户名: 密码: 验证码:
推荐内容