MSMQ 概述

青羽,DanielWise,碧海山城 | | 访问(546)

  MSMQ全称MicroSoft Message Queue,微软消息队列,是在多个不同的应用之间实现相互通信的一种异步传输模式,相互通信的应用可以分布于同一台机器上,也可以分布于相连的网络空间中的任一位置。它的实现原理是:消息的发送者把自己想要发送的信息放入一个容器中(我们称之为Message),然后把它保存至一个系统公用空间的消息队列(Message Queue)中;本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理。MSMQ 可以工作在在线或者离线场景,并提供异步编程功能。如果客户端离线,MSMQ将会是最合适的方法,这是因为服务端不需要等待客户端读取数据并向服务端返回确认。

  消息Message 是由通信的双方所需要传递的信息。

  队列 的类型主要包括一下几种:

  “公共队列”在整个“消息队列”网络中复制,并且有可能由网络连接的所有站点访问。

  “专用队列”不在整个网络中发布。相反,它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。

  “管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列(如果有的话)。

  “响应队列”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列(如果有的话)。

  优点 :稳定、消息优先级、脱机能力以及安全性,有保障的消息传递和执行许多业务处理的可靠的防故障机制。

  缺点 :MSMQ不适合于Client需要Server端实时交互情况.大量请求时候,响应延迟.

  确定MSMQ 是否已经安装

  通过在运行窗口执行"Services",然后找到Message Queuing. 如果没有就说明MSMQ 没有安装。

  MSMQ 安装

  控制面板 -> 添加/删除Windows 组件 -- 选择消息队列 - 下一步

  这将在你的系统中安装MSMQ,然后你可以通计算机管理来进行确认。

  控制面板 -> 管理工具 -> 计算机管理 -> 服务和应用 -> 消息队列,

  你将看到出栈队列,私有队列,系统队列,触发器。

  消息类型

  MSMQ 支持两种类型的消息: XML 和二进制, 下面的例子分别使用XML的二进制消息。

  MSMQ 架构(命名空间集成关系)

  System

  Messaging

  Message

  MessageQueue

  MessageEnumerator

  MessageType

  MessagePriority

  MSMQ 示例程序

using System;
using System.Messaging;
using System.Drawing;
using System.Drawing.Imaging;

namespace ConsoleMessage
{
    class Program
    {
        static void Main(string[] args)
        {
            CreateQueue(@".\Private$\ImageQueue");//队列名称
            SendMessage();
            ReceiveMessage();
            Console.ReadKey();
        }

        // 创建列队消息
        public static void CreateQueue(string queuePath)
        {
            try
            {
                if (!MessageQueue.Exists(queuePath))
                {
                    MessageQueue.Create(queuePath);
                }
                else
                {
                    Console.WriteLine(queuePath + " already exists.");
                }
            }
            catch (MessageQueueException e)
            {
                Console.WriteLine(e.Message);
            }
        }

        // 一个图像发送到一个队列,使用BinaryMessageFormatter。
        public static void SendMessage()
        {
            try
            {
                //创建新的位图。
                //文件必须在释放\ bin \调试或\ bin \文件夹
                //或它的位置应该给的完整路径
                MessageQueue myQueue = new MessageQueue(@".\Private$\ImageQueue");//队列名称
                string filePath = @"D:\BLogClump\1.jpg";
                Image myImage = Bitmap.FromFile(filePath);
                Message msg = new Message(myImage, new BinaryMessageFormatter());
                myQueue.Send(msg);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }

        // 接收一条消息,其中包含一个图像。
        public static void ReceiveMessage()
        {
            try
            {
                MessageQueue myQueue = new MessageQueue(@".\Private$\ImageQueue");//队列名称
                myQueue.Formatter = new BinaryMessageFormatter();
                Message myMessage = myQueue.Receive();
                Bitmap myImage = (Bitmap)myMessage.Body;
                string saveFilePath = @"D:\BLogClump\NewImage.jpg";
                myImage.Save(saveFilePath, ImageFormat.Jpeg);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }
    }
}

  在这个例子中我们将一个JPG图片文件存储到MSMQ队列,它可以在接下来的步骤中被接收然后使用。

  运行这个程序并确认是否"被发送的图片" 文件在Debug或者Release 文件夹中被创建。

  MSMQ与XML Web Services和.Net Remoting一样,是一种分布式开发技术。

  MSMQ与其他(不同点):

  1.在使用XML Web Services或.Net Remoting组件时,Client端需要和Server端实时交换信息,Server需要保持联机.

  2.MSMQ则可以在Server离线的情况下工作,将Message临时保存在Client端的消息队列中,以后联机时再发送到Server端处理。

  显然,MSMQ不适合于Client需要Server端及时响应的这种情况,MSMQ以异步的方式和Server端交互,不用担心等待Server端的长时间处理过程。消息其实就是异步的。

  虽然XML Web Services和.Net Remoting都提供了[OneWay]属性来处理异步调用,用来解决Server端长方法调用长时间阻碍Client端。但是不能解决大量Client负载的问题,此时Server接受的请求快于处理请求。一般情况下,[OneWay]属性不用于专门的消息服务中。

  基本术语和概念(Basic terms and concepts)

  “消息”是在两台计算机间传送的数据单位。消息可以非常简单,例如只包含文本字符串;也可以更复杂,可能包含嵌入对象。

  消息被发送到队列中。

  “消息队列 ”是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。 队列的主要目的是提供路由并保证消息的传递;如果发送消息时接收者不可用,消息队列会保留消息,直到可以成功地传递它。“消息队列”是 Microsoft 的消息处理技术,它在任何安装了 Microsoft Windows 的计算机组合中,为任何应用程序提供消息处理和消息队列功能,无论这些计算机是否在同一个网络上或者是否同时联机。

  “消息队列网络 ”是能够相互间来回发送消息的任何一组计算机。网络中的不同计算机在确保消息顺利处理的过程中扮演不同的角色。它们中有些提供路由信息以确定如何发送消息,有些保存整个网络的重要信息,而有些只是发送和接收消息。

  “消息队列 ”安装期间,管理员确定哪些服务器可以互相通信,并设置特定服务器的特殊角色。构成此“消息队列”网络的计算机称为“站点”,它们之间通过“站点链接”相互连接。每个站点链接都有一个关联的“开销”,它由管理员确定,指示了经过此站点链接传递消息的频率。“消息队列”管理员还在网络中设置一台或多台作为“路由服务器”的计算机。路由服务器查看各站点链接的开销,确定经过多个站点传递消息的最快和最有效的方法,以此决定如何传递消息。

  2. 队列类型(Queue Type)

  有两种主要的队列类型:由您或网络中的其他用户创建的队列和系统队列。用户创建的队列可能是以下任何一种队列:

  “公共队列 ”在整个“消息队列”网络中复制,并且有可能由网络连接的所有站点访问。

  “专用队列 ”不在整个网络中发布。相反,它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。

  “管理队列 ”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列(如果有的话)。

  “响应队列 ”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列(如果有的话)。

  系统生成的队列一般分为以下几类:

  “日记队列 ”可选地存储发送消息的副本和从队列中移除的消息副本。每个“消息队列”客户端上的单个日记队列存储从该计算机发送的消息副本。在服务器上为每个队列创建了一个单独的日记队列。此日记跟踪从该队列中移除的消息。

  “死信队列 ”存储无法传递或已过期的消息的副本。如果过期或无法传递的消息是事务性消息,则被存储在一种特殊的死信队列中,称为“事务性死信队列”。死信存储在过期消息所在的计算机上。有关超时期限和过期消息的更多信息,请参见默认消息属性。

  “报告队列 ”包含指示消息到达目标所经过的路由的消息,还可以包含测试消息。每台计算机上只能有一个报告队列。

  “专用系统队列 ”是一系列存储系统执行消息处理操作所需的管理和通知消息的专用队列。

  在应用程序中进行的大多数工作都涉及访问公共队列及其消息 。但是,根据应用程序的日记记录、确认和其他特殊处理需要,在日常操作中很可能要使用几种不同的系统队列。

  3. 同步和异步通信(Synchronous VS. Asynchronous Communication)队列通信天生就是异步的,因为将消息发送到队列和从队列中接收消息是在不同的进程中完成的。另外,可以异步执行接收操作,因为要接收消息的人可以对任何给定的队列调用 BeginReceive 方法,然后立即继续其他任务而不用等待答复。这与人们所了解的“同步通信”截然不同。

  在同步通信中,请求的发送方在执行其他任务前,必须等待来自预定接收方的响应。发送方等待的时间完全取决于接收方处理请求和发送响应所用的时间。

  4. 同消息队列交互(Interacting with Message Queues)消息处理和消息为基于服务器的应用程序组件之间的进程间通信提供了强大灵活的机制。同组件间的直接调用相比,它们具有若干优点,其中包括:

  稳定性 — 组件失败对消息的影响程度远远小于组件间的直接调用,因为消息存储在队列中并一直留在那 里,直到被适当地处理。消息处理同事务处理相似,因为消息处理是有保证的。

  消息优先级 — 更紧急或更重要的消息可在相对不重要的消息之前接收,因此可以为关键的应用程序保证足够的响应时间。

  脱机能力 — 发送消息时,它们可被发送到临时队列中并一直留在那里,直到被成功地传递。当因任何原因对所需队列的访问不可用时,用户可以继续执行操作。同时,其他操作可以继续进行,如同消息已经得到了处理一样,这是因为网络连接恢复时消息传递是有保证的。

  事务性消息处理 — 将多个相关消息耦合为单个事务,确保消息按顺序传递、只传递一次并且可以从它们的目标队列中被成功地检索。如果出现任何错误,将取消整个事务。

  安全性 — MessageQueue 组件基于的消息队列技术使用 Windows 安全来保护访问控制,提供审核,并对组件发送和接收的消息进行加密和验证。

  提问:最近看了一些MSMQ的资料,感觉很是奇怪,在IIS中装上此服务后,感觉这东西就像一个小数据库一样,暂时保存一些发送过来的数据,然后另一端再去收取?

  回答:是的。

  提问:这样有什么用呢?直接在数据库中建立一个表不就直接解决了吗?

  回答:你可以在数据库中保存一个对象(类的实例)吗?(当然SQL2005是面向对象的了),比如你有一个customer的类的实例,包含有这个customer的名称、年龄等等,你可以直接把这个实例保存到MSMQ,取出后也是实例,由你的问题可以看出对OOP的概念还不熟悉。为什么要用OOP而不是所有的应用都用数据库呢?这个问题你应该好好想想。

  提问:还可以实现到底发送给哪一个的用户,可是MSMQ就是一个简单的发送与接收,连用户方向都没有,真不知道他为什么存在?

  回答:你可以建立若干不同名称,不同权限的MSMQ,并且有入和出两种队列,为何你说没有方向?

  提问:或者说在什么样的解决方案中它可以存在?

  回答:在基于OOP的B/S或C/S结构中都可以采用其作为数据通讯的方式,尤其是需要长时间等待的异步处理

  如果数据库中断了连接怎么办?数据没有办法上传了!你可以写到本机的队列中等待通讯恢复后上传服务器。比如银行的业务,底下的分行不需要和总行服务器随时连通的,否则......

  MSMQ是Windows自带的标准组件,可以通过控制面板来安装:

  添加/删除程序 -> 添加/删除Windows组件,选择MSMQ

  利用 MSMQ(Microsoft Message Queue),应用程序开发人员可以通过发送和接收消息方便地与应用程序进行快速可靠的通信。消息处理为您提供了有保障的消息传递和执行许多业务处理的可靠的防故障方法。

  MSMQ与XML Web Services和.Net Remoting一样,是一种分布式开发技术。但是在使用XML Web Services或.Net Remoting组件时,Client端需要和Server端实时交换信息,Server需要保持联机。MSMQ则可以在Server离线的情况下工作,将Message临时保存在Client端的消息队列中,以后联机时再发送到Server端处理

  显然,MSMQ不适合于Client需要Server端及时响应的这种情况,MSMQ以异步的方式和Server端交互,不用担心等待Server端的长时间处理过程。

  虽然XML Web Services和.Net Remoting都提供了[OneWay]属性来处理异步调用,用来解决Server端长方法调用长时间阻碍Client端。但是不能解决大量Client负载的问题,此时Server接受的请求快于处理请求。

  一般情况下,[OneWay]属性不用于专门的消息服务中。