学步园

MSMQ(MicroSoft Message Queue，微软消息队列)在多个不同的应用之间实现相互通信的一种异步传输模式，相互通信的应用可以分布于同一台机器上，也可以分布于相连的网络空间中的任一位置。其工作原理是：消息发送方将消息放进消息队列，接收方则从消息队列中取出消息。

用C#实现发送消息的代码如下：

（需要引用并包含命名空间System.Messaging）
void Send(string message)<br /> {<br /> // 获取消息队列。MyMachine是机器的名称，TestMQ是消息队列的名称<br /> MessageQueue mq = new MessageQueue(@"FORMATNAME:DIRECT=OS:MyMachine/PRIVATE$/TestMQ");</p> <p> // 消息的编码格式<br /> XmlMessageFormatter msgFormatter = new XmlMessageFormatter( new Type[]{typeof(string)} );</p> <p> // 创建消息<br /> Message msg = new Message(message, msgFormatter);</p> <p> // 发送消息<br /> mq.Send(msg);<br /> }

实现接收消息的代码如下：

string Receive()<br /> {<br /> // 获取消息队列。此处使用机器的IP地址192.168.10.100来代替机器名<br /> MessageQueue mq = new MessageQueue(@"FORMATNAME:DIRECT=TCP:192.168.10.100/PRIVATE$/TestMQ");</p> <p> // 接收消息（如果队列中没有消息，则该函数一直处于阻塞状态。）<br /> Message msg = mq.Receive();</p> <p> // 设置消息的解码格式（必须与发送方的编码格式一致）<br /> msg.Formatter = new XmlMessageFormatter( new Type[]{typeof(string)} );</p> <p> // 将消息转换为string格式并返回<br /> return Convert.ToString(msg.Body);<br /> }

在获取消息队列 MessageQueue 时，除了可以使用机器名和IP外，还可以使用消息队列的 Guid 和 SPX，或者使用标签。

消息的编码格式除了 XmlMessageFormatter 外，还有ActiveXMessageFormatter 和 BinaryMessageFormatter，它们将消息编码为二进制格式。发送或接收 COM 组件时需要使用 ActiveXMessageFormatter。

另外，接收消息除了可以使用函数 Receive() 外，还可使用 Peek()。

Receive() 在获取消息后会将消息从消息队列中删除，而 Peek() 则将消息继续保留在消息队列中。