NET中MSMQ的使用----附例子

目录

1. 一:MSMQ的一些理论上的知识
2. 二:队列类型（Queue Type）
3. 三:安装消息队列
4. 四:在C#中Messagequeue class
5. 五:MSMQ-发送消息到远程专用队列
6. 六:例子

 

 

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

二：队列类型（Queue Type）
          由您或网络中的其余用户建立的队列和系统队列。用户建立的队列多是如下任何一种队列： 
          “公共队列”在整个“消息队列”网络中复制，而且有可能由网络链接的全部站点访问。 
          “专用队列”不在整个网络中发布。相反，它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。 
          “管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定但愿 MessageQueue 组件使用的管理队列（若是有的话）。       
          “响应队列”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定但愿 MessageQueue 组件使用的响应队列（若是有的话）。 
           系统生成的队列通常分为如下几类： “日记队列”可选地存储发送消息的副本和从队列中移除的消息副本。每一个“消息队列”客户端上的单个日记队列存储从该计算机发送的消息副本。在服务器上为每一个队列建立了一个单独的日记队列。此日记跟踪从该队列中移除的消息。 “死信队列”存储没法传递或已过时的消息的副本。若是过时或没法传递的消息是事务性消息，则被存储在一种特殊的死信队列中，称为“事务性死信队列”。死信存储在过时消息所在的计算机上。有关超时期限和过时消息的更多信息，请参见默认消息属性。 “报告队列”包含指示消息到达目标所通过的路由的消息，还能够包含测试消息。每台计算机上只能有一个报告队列。 “专用系统队列”是一系列存储系统执行消息处理操做所需的管理和通知消息的专用队列。 在应用程序中进行的大多数工做都涉及访问公共队列及其消息。可是，根据应用程序的日记记录、确认和其余特殊处理须要，在平常操做中极可能要使用几种不一样的系统队列。

三：安装消息队列

若是你相使用消息队列进行通讯的话，你就必须在你的电脑上安装消息队列，经过组件安装，具体安装的方法在这里就不详解了,相似于安装IIS同样

 

　

　　对消息队列有了简单的了解后，使用MSMQ进行软件开发须要安装MSMQ，安装完后就该进入实际的开发阶段。具体的安装过程就是在控制面板里“添加/删除程序”下“添加/删除Windows组件”，完成添加就OK。安装完成后就能够经过交互界添加新的消息队列，详细以下图：

 

　　

出了上面这种交互界面来建立MSMQ外，也能够经过编程来完成。

四：在C#中Messagequeue class

在使用.net开发msmq时，你必须引入命名空System.Messaging

MessageQueue 支持两种消息类型，同步和异步，同步方法使用的是peek();receive();异步使用的是：

Beginpeek() and Beginreceive();二者没有什么本质区别，都是封装好的方法，你只要直接建立Messagequeue的对象来调用这个方法就OK了， 我想至于什么同步和异步是什么意思，就没有必有解释了吧，

 

五：MSMQ-发送消息到远程专用队列

 

 

在工做组模式下，远程访问专用队列。在网上找到一篇文章，翻译了一下。

最后结论，直接使用多元素格式名方式，利用IP地址直接对单个或多个目标发送消息

MessageQueue rmQ = new MessageQueue("FormatName:Direct=TCP:121.0.0.1//private$//queue,Direct=TCP:192.168.1.2//private$//queue");

rmQ.Send("sent to regular queue - Atul");

原文地址

http://www.infosysblogs.com/microsoft/2007/02/msmq_sending_message_to_remote.html

 

1.当须要引用远程队列时，使用“machinename/private$/queuename”的格式没法工做。会返回“invalid queue path”错误。

 

 

2.队列名称须要使用“"FormatName:Direct=OS:machinename//private$//queuename”的格式。其余友好形式的表达式都是被转换为FormatName格式以后进行调用的。并且其余这些友好表达式的转换是基于Active Directory（域）来进行解析的，若是没有域的支持，这些表达式将没法工做。

 

例：

    MessageQueue rmQ = new MessageQueue 

                                    ("FormatName:Direct=OS:machinename//private$//queue");

    rmQ.Send("sent to regular queue - Atul");

 

 

3.FontName是区分大小写的。若是表达式为“FORMATNAME:Direct=OS:machinename//private$//queuename”，是没法工做的。但这种表达式不会返回任何错误。FontName好像是表达式里惟一区分大小写的部分。其余部分能够随意使用大小写，例如可使用“DIRECT”。

 

 

4.若是想要使用机器IP地址，表达式的语法为“FormatName:Direct=TCP:ipaddress//private$//queuename”

 

  例：

     MessageQueue rmQ = new MessageQueue

                                     ("FormatName:Direct=TCP:121.0.0.1//private$//queue");

     rmQ.Send("sent to regular queue - Atul");

 

 

5.在代码中建立的队列实例对象的事务性属性，必须与要发送的目标队列的属性相匹配。前面的例子中发送的消息为非事务型消息，若是要发送消息到事务型的队列，代码为：

    MessageQueue rmTxnQ = new MessageQueue

                                            ("FormatName:Direct=OS:machinename//private$//queue");

    rmTxnQ.Send("sent to Txn queue - Atul", MessageQueueTransactionType.Single);

 

若是事务型属性不匹配，消息将没法传递。系统不会返回任何错误，但该条消息却会丢掉。

 

 

6.最后，当你发送消息到远程队列，系统会在本机建立一个临时的传出队列。这样作的目的是防止远程队列没法访问。在计算机管理器中查看消息队列/传出队列，能够看到这些临时队列。在管理器的右侧能够显示状态（联通、未联通）以及IP地址。

 

六：例子

------------------------------------------------------------------------------

 

using System;

using System.Collections.Generic;

using System.Text;

using System.Messaging;

 

namespace MyQueue

{

    public class MyMessageQueue

    {

 

        private string Path;

        /// <summary>

        /// 1.经过Create方法建立使用指定路径的新消息队列

        /// </summary>

        /// <param name="queuePath"></param>

        public void Createqueue(string queuePath)

        {

            try

            {

                if (!MessageQueue.Exists(queuePath))

                {

                    MessageQueue.Create(queuePath);

                }

                else

                {

                    Console.WriteLine(queuePath + "已经存在！");

                    //MessageQueue.Delete(queuePath);

                    //MessageQueue.Create(queuePath);

                    //Console.WriteLine(queuePath + "删除重建");

                }

                Path = queuePath;

            }

            catch (MessageQueueException e)

            {

                Console.WriteLine(e.Message);

            }

        }

 

        /// <summary>

        ///  2.链接消息队列并发送消息到队列

        /// 远程模式：MessageQueue rmQ = new MessageQueue("FormatName:Direct=OS:machinename//private$//queue");

        ///     rmQ.Send("sent to regular queue - Atul");对于外网的MSMQ只能发不能收

        /// </summary>

        public void SendMessage()

        {

            try

            {

                //链接到本地队列

                MessageQueue myQueue = new MessageQueue(Path);

                //MessageQueue myQueue = new MessageQueue("FormatName:Direct=TCP:192.168.12.79//Private$//myQueue1");

                //MessageQueue rmQ = new MessageQueue("FormatName:Direct=TCP:121.0.0.1//private$//queue");--远程格式

                Message myMessage = new Message();

                myMessage.Body = "消息内容34kuangbo去死";

                myMessage.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });

                //发生消息到队列中

                myQueue.Send(myMessage);

                Console.WriteLine("消息发送成功！");

                Console.ReadLine();

            }

            catch (ArgumentException e)

            {

                Console.WriteLine(e.Message);

            }

        }

 

        /// <summary>

        /// 3.链接消息队列并从队列中接收消息

        /// </summary>

        public void ReceiveMessage()

        {

            MessageQueue myQueue = new MessageQueue(Path);

            myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });

            try

            {

                //从队列中接收消息

                Message myMessage = myQueue.Receive();// myQueue.Peek();--接收后不消息从队列中移除

                string context = myMessage.Body.ToString();

                Console.WriteLine("消息内容：" + context);

                Console.ReadLine();

            }

            catch (MessageQueueException e)

            {

                Console.WriteLine(e.Message);

            }

            catch (InvalidCastException e)

            {

                Console.WriteLine(e.Message);

            }

        }

 

        /// <summary>

        /// 4.清空指定队列的消息

        /// </summary>

        public void ClealMessage()

        {

            MessageQueue myQueue = new MessageQueue(Path);

            myQueue.Purge();

            Console.WriteLine("已清空对了{0}上的全部消息",Path);

        }

 

        /// <summary>

        /// 5.链接队列并获取队列的所有消息

        /// </summary>

        public void GetAllMessage()

        {

            MessageQueue myQueue = new MessageQueue(Path);

            Message[] allMessage = myQueue.GetAllMessages();

            XmlMessageFormatter formatter = new XmlMessageFormatter(new Type[] { typeof(string) });

            for (int i = 0; i < allMessage.Length; i++)

            {

                allMessage[i].Formatter = formatter;

                Console.WriteLine("第{0}机密消息为:{1}", i+1, allMessage[i].Body.ToString());

            }

            Console.ReadLine();

        }

 

    }

}

------------------------

using System;

using System.Collections.Generic;

using System.Text;

namespace MyQueue

{

    class Program

    {

        static void Main(string[] args)

        {

            MyMessageQueue queue = new MyMessageQueue();

            queue.Createqueue(".//Private$//myQueue2");

            queue.SendMessage();

            queue.GetAllMessage();

            //queue.ReceiveMessage();

            //queue.ClealMessage();

        }

    }

}

注意：传输的 路径格式 要正确。

出处：http://blog.csdn.net/sage425/article/details/6298461