WCF分布式开发之MSMQ消息队列

一、MSMQ简介

MSMQ（微软消息队列）是Windows操作系统中消息应用程序的基础，是用于创建分布式、松散连接的消息通讯应用程序的开发工具。

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

1、MSMQ的实现原理

消息的发送者把自己想要发送的信息放入一个容器，然后把它保存到一个系统公用空间的消息队列中，本地或异地的消息接收程序再从该队列中取出发给它的消息进行处理。

消息队列是一个公用存储空间，它可以存在于内存中或物理文件中，因此，消息以两种方式发送，即快递方式和可恢复模式。MSMQ机制类似QQ消息传递机制。下图演示了MSMQ的实现原理。

2、安装

默认情况下安装操作系统是不安装消息队列的，你可以在控制面板中找到添加/删除程序，然后选择添加/删除Windows组件一项，然后选择应用程序服务器，双击它进入详细资料中选择消息队列一项进行安装。

如果服务没有自动启动，需要启动服务：
这里写图片描述

3、两个概念

一个是消息Message：Message是通信双方需要传递的消息，它可以是文本、图片、视频等。消息包含发送和接收者的标识，只有指定的用户才能取得消息。

另一个是队列Queue：用来保存消息的存储空间，消息对列分为3类：

公共队列：MachineName\QueueName
能被别的机器所访问，如果你的多个项目中用到消息队列，那么你可以把队列定义为公共队列
专用队列：MachineName\Private$\QueueName
只针对于本机的程序才可以调用的队列，有些情况下为了安全起见定义为私有队列。
日志队列：MachineName\QueueName\Journal$

4、MicroSoft.Message.Queue常用的方法：

Create方法:创建使用指定路径的新消息队列。
Delete方法：删除现有的消息队列。
Existe方法：查看指定消息队列是否存在。
GetPublicQueues方法：在“消息队列”网络中定位消息队列。
Send方法：发送消息到指定的消息队列。
GetAllMessages()方法:得到队列中的所有消息。
Receive/BeginReceive方法：检索指定消息队列中最前面的消息，并将其从该队列中移除
Peek/BeginPeek方法：查看某个特定队列中的消息队列，但不从该队列中移出消息。。
Purge方法：清空指定队列的消息。

二、服务端

首先，实现服务器端。创建一个控制台项目，添加System.Messaging引用，因为消息队列的类全部封装在System.Messaging.dll程序集里。

服务器端代码需要注意的是，公共队列只能在域环境中创建，如果个人电脑没有加入域环境，则不能创建公共队列。

    if (!MessageQueue.Exists(@".\MYFIRSTMSMQ"))
    {
        using (MessageQueue mq = MessageQueue.Create(@".\MYFIRSTMSMQ"))//创建一个公共消息队列
        {
            mq.Label = "myFirstMSMQ";
            Console.WriteLine("已经创建了一个公共队列{0}", mq.Label);
            Console.WriteLine("公共队列{0}的路径为{1}", mq.Label, mq.Path);
            mq.Send("MSMQ 消息", "今天又学到个有趣的知识");
        }
    }
    foreach (MessageQueue mq in MessageQueue.GetPublicQueues())//获取所有公共队列，发送消息
    {
        mq.Send("发送公共消息队列" + DateTime.Now.ToLongTimeString(), "今天又学到个有趣的知识");
        Console.WriteLine("公有消息已经送到{0}", mq.Path);
    }

    if (!MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))
    {
        using (MessageQueue mq = MessageQueue.Create(@".\Private$\MYFIRSTMSMQ"))//创建一个私有消息队列
        {
            mq.Label = "myFirstPrivateMSMQ";
            Console.WriteLine("已经创建了一个私有队列{0}", mq.Label);
            Console.WriteLine("私有队列{0}的路径为{1}", mq.Label, mq.Path);
            mq.Send("MSMQ 私有队列消息" + "今天又学到个有趣的知识");
        }
    }

    if (MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))
    {
        MessageQueue mq = new MessageQueue(@".\Private$\MYFIRSTMSMQ");//找到私有队列，发送消息

        mq.Send("发送私有消息队列" + DateTime.Now.ToLongTimeString() + "今天又学到个有趣的知识");
        Console.WriteLine("私有消息已经送到{0}", mq.Path);
    }

三、客户端

服务器端把消息发送到共享的消息队列中，然后，客户端从这个共享的消息队列中取出消息进行处理。

if (MessageQueue.Exists(@".\MYFIRSTMSMQ"))// 获取公共消息队列
{
    using (MessageQueue mq = new MessageQueue(@".\MYFIRSTMSMQ"))//创建消息队列对象
    {
        mq.Formatter = new XmlMessageFormatter(new string[] { "System.String" });//设置消息队列的格式化器，还有BinaryMessageFormatter,ActiveXMessageFormatter等
        foreach (Message msg in mq.GetAllMessages())
        {
            Console.WriteLine("接收到的消息是:{0}", msg.Body);
        }
        Message firstmsg = mq.Receive();
        Console.WriteLine("收到的第一条消息为：{0}", firstmsg.Body);
    }
}

if (MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))// 获取私有消息队列
{
    using (MessageQueue mq = new MessageQueue(@".\Private$\MYFIRSTMSMQ"))
    {
        //....
    }
}

频道导航