【原】C# 消息队列之MSMQ

首先说一下，消息队列 (MSMQ Microsoft Message Queuing)是MS提供的服务，也就是Windows操作系统的功能，并不是.Net提供的。

消息队列（MSMQ）技术使得运行于不同时间的应用程序能够在各种各样的网络和可能暂时脱机的系统之间进行通信。

应用程序将消息发送到队列，并从队列中读取消息。

下图演示了消息队列如何保存由多个发送应用程序生成的消息，并被多个接收应用程序读取。

消息一旦发送到队列中，便会一直存在，即使发送的应用程序已经关闭。

 MSMQ服务默认是关闭的，(Window7及以上操作系统)按以下方式打开

1、打开运行，输入"OptionalFeatures"，钩上Microsoft Message Queue(MSMQ)服务器。

消息队列（Message Queue）是一种使用队列（Queue）作为底层存储数据结构，可以用于解决不同进程与应用程序之间通讯的分布式消息容器，也可以称为消息中间件。

目前比较常用的消息队列有ActiveMQ、RabbitMQ、MSMQ ，Kafka、RocketMQ、Redis等。

消息队列和队列有什么区别呢？

唯一的区别在于入队列的时候称为生产者，出队列的时候称为消费者。

我理解的MSMQ

      MSMQ可以被看成一个数据储存装置，就如同数据库，只不过数据存储的是一条一条的记录，而MSMQ存储的是一个一个的消息(messsge)。Message可以被理解为一种数据容器，我们在稍后会讲到。MSMQ一个重要的应用场景就是离线信息交互，例如，我们在给朋友发送邮件，而此时朋友并未登入邮箱，这个时候我们的邮件就可以发到邮件服务器的MSMQ队列中，当朋友登入邮箱的时候，系统在从服务器的MSMQ队列中取出U件。当然MSMQ的用途远不止这些，例如，充当数据缓存，实现异步操作等等，这里就不在一一举例了。

系统的消息队列，为我们提供了3种队列传出队列，专用队列和系统队列，而用户能自由创建的只有专用队列。我们可以尝试创建一个专用队列，"右击"专用队列，再点击"新建"，得到新增界面如下图。由于我们创建的是专用队列，所以在队列命名上面显示的添加"private$",另一个事务复选框表示我们要创建的是队列是否为事务队列，这个在稍后我会详细的解释

 

我在专用队列里面添加一个叫"shaoshun"的专用队列，在专用队列文件夹下面就可以找到，如图

消息

      消息是MSMQ的存储对象，封装为System.Messaging.Message对象，它由一个主体(body)和若干属性构成，其中我们的用户数据通常被序列化装入body主体中，这也是我们称它为数据容器的原因。除了body属性，还有几个属性相对来说比较重要：Priority(消息的优先级)，Label(用户定义的消息标识)，Formatter(消息的序列组件，当用户将复杂类型数据填充到body中，用户的数据会先被序列化)

队列

　　在前面，我们通过手动创建了一个专用队列。我们知道队列分事务性队列和非事务性队列，默认创建的是非事务性队列。当我们勾选事务性复选框，我们就会创建事务性队列，那么什么是事务性队列呢?事务性队列将消息保存在磁盘上，实现了持久化，也就是说当我们关机，断电后，下次再启动机器，我们的消息依然保存在队列里面，而非事务性队列则将消息保存在内存中，也就是说我重启电脑后，队列里面的消息将不存在了。

     队列支持事务操作，当我们把对多个消息的接收操作纳入一个事务中，那么只要有一个消息接收不成功，队列将抛弃前面接收的所有消息，实现事务回滚。队列事务同时支持消息按顺序接收与发送。

实例：

 需要先引用System.Messaging.dll

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

• 
  

#region 消息队列using System;using System.Collections.Generic;using System.Linq;using System.Messaging;using System.Text;using System.Threading;using System.Threading.Tasks; namespace test{ class Program { static void Main(string[] args) { #region 创建消息队列 const string queueName = @".\Private$\jiyiqin"; MessageQueue mq = null; if (!MessageQueue.Exists(queueName))// 如果指定的路径queueName中不存在队列，那么在该路径，即queueName中创建一个消息队列。jiyiqin就是你想要创建消息队列的名字 { mq = MessageQueue.Create(queueName);//创建名称jiyiqin的消息队列的实例。 Console.WriteLine("创建消息队列完成：" + queueName); } else //如果消息队列jiyiqin已经存在，那么创建该消息队列的一个实例 { mq = new MessageQueue(queueName);//创建名称jiyiqin的消息队列的实例。 } mq.SetPermissions("Administrator", MessageQueueAccessRights.FullControl); mq.SetPermissions("ANONYMOUS LOGON", MessageQueueAccessRights.FullControl); mq.SetPermissions("Everyone", MessageQueueAccessRights.FullControl); #endregion #region 发送消息队列 string strTx = "123我"; Message msgTx = new Message(); msgTx.Body = strTx; msgTx.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) }); mq.Send(msgTx); #endregion #region 接收消息队列 //接收到的消息对象 Message msgRx = mq.Receive(); //指定格式化程序 msgRx.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) }); //接收到的内容 string strRx = msgRx.Body.ToString(); System.Windows.Forms.MessageBox.Show(strRx); #endregion } }}