C#操作MSMQ向本地消息队列发送和接收消息

注意：不管是访问远程队列还是本地队列，访问者的本地系统一定要安装MSMQ。下面是在C#项目环境下操作MSMQ向本地发送和接收消息的示例代码：

[csharp] view plain copy

1. using System;  
2. using System.Messaging;  
3.   
4. namespace JSONMSMQ  
5. {  
6.     class Program  
7.     {  
8.         static void Main(string[] args)  
9.         {  
10.             // 本地消息队列的地址  
11.   
12.             // 初始化消息队列实例，该实例引用指定路径的“消息队列”队列  
13.             // 初始化 Message类的实例  
14.             // 设置消息的内容——json格式  
15.             // 发送消息（非事务性）  
16.             string msmqPath = @".\Private$\json";  
17.   
18.             MessageQueue mq = new MessageQueue(msmqPath);  
19.             Message msg = new Message();  
20.             msg.Body = "{\"empoyees\":[{\"firstName\":\"Bill\", \"lastName\":\"Gates\"}, {\"firstName\":\"Indiana\", \"lastName\":\"Jones\"}]}";  
21.             mq.Send(msg);  
22.   
23.             // 接收消息msgReceive  
24.             // 设置消息的格式  
25.             // 把消息转换为字符串格式  
26.             // ...  
27.             Message msgReceive = mq.Receive();  
28.             msgReceive.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });  
29.             string receivedMsmq =  msgReceive.Body.ToString();  
30.   
31.             Console.Write(receivedMsmq);  
32.             mq.Purge();// 删除队列中所有消息  
33.             Console.ReadLine();  
34.         }  
35.     }  
36. }  

提取出来的消息如下图所示：