MSMQ学习

一、理论准备

　　MSMQ(MicroSoft Message Queue，微软消息队列)官方的解释是：在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台机器上，也可以分布于相连的网络空间中的任一位置。MSMQ通过发送和接受消息使得应用程序之间的通信变的更快和更可靠。
　　它的实现原理是：消息的发送者把自己想要发送的信息放入一个容器中（我们称之为Message），然后把它保存至一个系统公用空间的消息队列(Message Queue)中；本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理。它可以存在于内存中或者是物理文件中。消息可以以两种方式发送，即快递方式(express)和可恢复模式(recoverable)，它们的区别在于，快递方式为了消息的快速传递，把消息放置于内存中，而不放于物理磁盘上，以获取较高的处理能力；可恢复模式在传送过程的每一步骤中，都把消息写入物理磁盘中，以得到较好的故障恢复能力。默认应该是快递模式。
      在消息传递机制中，有两个比较重要的概念。一个是消息，一个是队列。消息是由通信的双方所需要传递的信息，说白了它可以是各式各样的媒体，如文本、声音、图象,在我们编程的时候，它一般是一个类的对象或字符串等，消息最终的理解方式，为消息传递的双方事先商定，这样做的好处是，一是相当于对数据进行了简单的加密，二则采用自己定义的格式可以节省通信的传递量。队列是发送和接收消息的公用存储空间，它可以存在于内存中或者是物理文件中。
      采用MSMQ带来的好处是：由于是异步通信，无论是发送方还是接收方都不用等待对方返回成功消息，就可以执行余下的代码，因而大大地提高了事物处理的能力;当信息传送过程中，信息发送机制具有一定功能的故障恢复能力；MSMQ的消息传递机制使得消息通信的双方具有不同的物理平台成为可能。在微软的.net平台上利用其提供的MSMQ功能，可以轻松创建或者删除消息队列、发送或者接收消息、甚至于对消息队列进行管理。

　　可创建的MSMQ类型： 
       “公共队列”在整个“消息队列”网络中复制，并且有可能由网络连接的所有站点访问。 路径格式为：机器名称队列名称
       “专用队列”不在整个网络中发布。相反，它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。 路径格式为：机器名称Private$队列名称
       “管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列（如果有的话）。       
       “响应队列”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列（如果有的话）。 

二、MSMQ安装及查看

　　

      

三、例子

namespace MSMQDemo
{
    public class MsmqHelper : IDisposable
    {
        private readonly string path;
        private MessageQueue mq;
        public MsmqHelper()
        {
            path = @".private$YQ2";  //这是本机实例的方式（专用队列）
            if (!MessageQueue.Exists(path))
                MessageQueue.Create(path);
            mq = new MessageQueue(path);
            mq.Formatter = new BinaryMessageFormatter();
            mq.Label = "description";//description  
        }
        //析构函数
        ~MsmqHelper()
        {
            mq.Dispose();
            //Dispose(false);
        }
        //发送消息
        public void SendMessage(object message)
        {
            mq.Send(new Message
            {
                Body = message,
                Formatter = new BinaryMessageFormatter(),
                Recoverable = true//在消息传递过程中将消息保存到磁盘上来保证消息的传递，默认为false。 
            });
        }
        //接收消息
        public object ReceiveMessage()
        {
            try
            {
                Message receivedMsg = new Message();
                receivedMsg.Formatter = new BinaryMessageFormatter();
                receivedMsg = mq.Receive();
                return receivedMsg == null ? null : receivedMsg.Body;
            }
            catch (Exception e)
            {
                //log
                return null;
            }
        }
        //释放
        public void Dispose()
        {
            //调用带参数的Dispose方法，释放托管和非托管资源
            Dispose(true);
            //手动调用了Dispose释放资源，那么析构函数就是不必要的了，这里阻止GC调用析构函数
            System.GC.SuppressFinalize(this);
        }
        protected virtual void Dispose(bool disposing)
        {
            if (disposing)
            {
                //TODO:在这里加入清理"托管资源"的代码，应该是xxx.Dispose();
                mq.Dispose();
            }
            else
                //TODO:在这里加入清理"非托管资源"的代码 
                return;//GC.Collect();

        }
    }
}

namespace MSMQDemo.Controllers
{
    public class HomeController : Controller
    {
        private MsmqHelper mqHelper;
        private static string msg = string.Empty;
        public HomeController()
        {
            mqHelper = new MsmqHelper();
        }

        public ActionResult Index()
        {
            new System.Threading.Thread(() => { SendMess(); }).Start();
            while (true)
            {
                var msg1 = (Message)mqHelper.ReceiveMessage();
                msg = (msg1.Sender + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "偷偷发送了一则电报，已被截获：" + msg1.Content);
                Response.Write(msg + "<br />");
                if (Response.IsClientConnected)
                    Response.Flush();
            }
        }
        //发送消息进程
        public void SendMess()
        {
            while (true)
            {
                mqHelper.SendMessage(new Message { Content = Guid.NewGuid().ToString("N"), Sender = "张三虫" });
                System.Threading.Thread.Sleep(200);
            }
        }

    }
    [Serializable]
    public class Message
    {
        public string Sender { get; set; }
        public string Content { get; set; }
    }
}

四、效果展示

五、demo下载

source code