【IT168技术文档】
上篇讲到WinCe下的MSMQ安装 ，这篇讲述一下MSMQ在.NET Compact Framework下的开发。
所谓MQ就是Message Queue，消息队列。消息队列可以作为不同应用程序之间，甚至不同机器之间通信的渠道。在消息队列下进行通信的内容称为消息（Message），在C#程序下Message就是对象。
MSMQ就是Microsoft公司提供的MQ服务程序。MQ服务程序负责管理消息队列，保证消息在消息队列这一渠道下能无误的发送到对端，MQ支持离线交易，有时候消息会缓存在MQ服务程序中，当接收方再线时候在提取消息。这一特性使得MQ可以广泛使用在移动领域，因为移动应用的网络不能保证7×24的长连接。
生成队列
在CF.net下开发MQ，需要引用System.Messaging库。
using System.Messaging;
public class MQService
{
private const string mMachinePrefix = @".\";
private const string mPrivateQueueNamePrefix = mMachinePrefix + @"Private$\";
private const string mServiceQueuePath = mPrivateQueueNamePrefix + "MQServiceQueue$";
private MessageQueue mServiceQueue;
private void InitServiceQueue()
{
// create the message queue
try
{
// check to make sure the message queue does not exist already
if (!MessageQueue.Exists(mServiceQueuePath))
{
// create the new message queue and make it transactional
mServiceQueue = MessageQueue.Create(mServiceQueuePath);
mServiceQueue.Close();
}
else
{
mServiceQueue = new MessageQueue(mServiceQueuePath);
}
Type[] types = new Type[1];
types[0] = typeof(string);
mServiceQueue.Formatter = new XmlMessageFormatter(types);
mServiceQueue.ReceiveCompleted += new ReceiveCompletedEventHandler(MessageListenerEventHandler);
// Begin the asynchronous receive operation.
mServiceQueue.BeginReceive();
mServiceQueue.Close();
}
// show message if we used an invalid message queue name;
catch (MessageQueueException MQException)
{
Console.WriteLine(MQException.Message);
}
return;
}
}
在建立Q之前先检查该Q是否存在，如果存在就生成Q的处理对象，如果不存在就先在队列管理器建立这个Q。建立Q的时候，输入参数为一个string，这个string可以为path（路径），FormatName或者Label。使用path的相对广泛，在例子中使用path作为输入参数。Path由MachineName and QueueName组成，建立的Q可以分为Public，Private，Journal和DeadLetter。使用广泛的是Public和Private，Public的Q由MachineName and QueueName组成，格式如MachineName\QueueName，而Private的Q的格式为MachineName\Private$\QueueName，比Public的Q多了一个标识Private$，在例子中使用了Private的Q。路径“.\”指的是本地机器。
Property Formatter十分重要，他定义了消息体的格式，所谓消息体的格式就是通过这个Q通信的消息的数据类型，一个Q可以传递多个不同的数据类型，需要在Type进行定义然后赋值给Formatter。
Event ReceiveCompleted用来注册接收处理函数，当Q接收到消息后，使用注册的函数进行处理。使用ReceiveCompleted注册处理函数以后，必须调用BeginReceive让这个Q进入异步接收状态。
下面讲述MQ应用中两种常见的应用模式，第一种为请求回应模式，第二种为注册广播模式。
