什么是消息队列?

“消息”是在两台计算机间传送的数据单位。消息可以非常简单，例如只包含文本字符串；也可以更复杂，可能包含嵌入对象。 消息被发送到队列中。“消息队列”是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。队列的主要目的是提供路由并保证消息的传递；如果发送消息时接收者不可用，消息队列会保留消息，直到可以成功地传递它。 “消息队列”是 Microsoft 的消息处理技术，它在任何安装了 Microsoft Windows 的计算机组合中，为任何应用程序提供消息处理和消息队列功能，无论这些计算机是否在同一个网络上或者是否同时联机。 “消息队列网络”是能够相互间来回发送消息的任何一组计算机。网络中的不同计算机在确保消息顺利处理的过程中扮演不同的角色。它们中有些提供路由信息以确定如何发送消息，有些保存整个网络的重要信息，而有些只是发送和接收消息。 “消息队列”安装期间，管理员确定哪些服务器可以互相通信，并设置特定服务器的特殊角色。构成此“消息队列”网络的计算机称为“站点”，它们之间通过“站点链接”相互连接。每个站点链接都有一个关联的“开销”，它由管理员确定，指示了经过此站点链接传递消息的频率。 “消息队列”管理员还在网络中设置一台或多台作为“路由服务器”的计算机。路由服务器查看各站点链接的开销，确定经过多个站点传递消息的最快和最有效的方法，以此决定如何传递消息。

使用msmq

　　msmq(microsoft message queue,微软消息队列)是在多个不同的应用之间实现相互通信的一种异步传输模式,相互通信的应用可以分布于同一台机器上,也可以分布于相连的网络空间中的任一位置.它的实现原理是:消息的发送者把自己想要发送的信息放入一个容器中（我们称之为message）,然后把它保存至一个系统公用空间的消息队列(message queue)中;本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理.

在消息传递机制中,有两个比较重要的概念.一个是消息,一个是队列.消息是由通信的双方所需要传递的信息,它可以是各式各样的媒体,如文本.声音.图象等等.消息最终的理解方式,为消息传递的双方事先商定,这样做的好处是,一是相当于对数据进行了简单的加密,二则采用自己定义的格式可以节省通信的传递量.消息可以含有发送与接收者的标识,这样只有指定的用户才能看到只传递给他的信息与返回是否操作成功的回执.消息也可以含有时间戳,以便于接收方对某些与时间相关的应用进行处理.消息还可以含有到期时间,它表明如果在指定时间内消息还未到达则作废,这主要应用与时间性关联较为紧密的应用.

消息队列是发送与接收消息的公用存储空间,它可以存在于内存中或者是物理文件中.消息可以以两种方式发送,即快递方式(express)与可恢复模式（recoverable）,它们的区别在于,快递方式为了消息的快速传递,把消息放置于内存中,而不放于物理磁盘上,以获取较高的处理能力;可恢复模式在传送过程的每一步骤中,都把消息写入物理磁盘中,以得到较好的故障恢复能力.消息队列可以放置在发送方.接收方所在的机器上,也可以单独放置在另外一台机器上.正是由于消息队列在放置方式上的灵活性,形成了消息传送机制的可靠性.当保存消息队列的机器发生故障而重新启动以后,以可恢复模式发送的消息可以恢复到故障发生之前的状态,而以快递方式发送的消息则丢失了.另一方面,采用消息传递机制,发送方必要再担心接收方是否启动.是否发生故障等等非必要因素,只要消息成功发送出去,就可以认为处理完成,而实际上对方可能甚至未曾开机,或者实际完成交易时可能已经是第二天了.

　　采用msmq带来的好处是:由于是异步通信,无论是发送方还是接收方都不用等待对方返回成功消息,就可以执行余下的代码,因而大大地提高了事物处理的能力;当信息传送过程中,信息发送机制具有一定功能的故障恢复能力;msmq的消息传递机制使得消息通信的双方具有不同的物理平台成为可能.

　　在微软的.net平台上利用其提供的msmq功能,可以轻松创建或者删除消息队列.发送或者接收消息.甚至于对消息队列进行管理.
在.net产品中,提供了一个msmq类库"system.messaging.dll".它提供了两个类分别对消息对象与消息队列对象进行操作.在能够使用msmq功能之前,你必须确定你的机器上安装了msmq消息队列组件,并确保服务正在运行中.在使用asp.net编程时,应在头部使用:

＜%@ assembly name="system.messaging"%＞ ＜%@ import namespace="system.messsaging"%＞

将msmq类库引入asp.net文件

　　1． 对消息队列的创建

　　　dim msgque as messagequeue

　　　msgque=new messagequeue(msgpath)

其中:msgpath可以为本地私有队列,如"./myqueue",也可以为其他机器的公有队列,如"saidy/777$/myqueue",saidy为另一机器名.

　　2． 消息的发送

　　　dim msgque as messagequeue

　　　msgque.send(msg)

　　　其中:msg为任一对象.

　　3． 消息的接收

　　消息的接收又分成同步与异步方式两种,同步接收在规定时间内从消息队列中取出收到的第一条消息,当消息队列中没有消息时,程序处于等待状态;异步接收方式则是定义了一个事件处理函数,当消息队列中第一个消息到达时立即触发该函数.
1） 同步方式

　　 dim msg as message

　　dim fmt as xmlmessageformatter

　　fmt= ctype(msgque.formatter,xmlmessageformatter)

　　fmt.targettypenames = new string(){"system.string"}

　　msg=msgque.receive(new timespan(0,0,3))

　　首先定义收到消息应转换成的格式,然后在指定时间内去接收消息

　　2） 异步方式

dim fmt as xmlmessageformatter

定义接收消息类型

fmt = ctype(msgque.formatter,xmlmessageformatter)

fmt.targettypenames = new string(){"system.string"}

定义消息处理函数入口

addhandler msgque.receivecompleted, new receivecompletedeventhandler

(addressof onreceivecompleted)

定义消息处理函数

public shared sub onreceivecompleted(s as object, asyncresult as receiveasynceventargs)

dim msgque as messagequeue = ctype(s,messagequeue)

dim msg as message = msgque.endreceive(asyncresult.asyncresult)

此时msg.body即为所取消息对象

msgque.beginreceive()

重新定义异步接收方式

end sub

启动异步接收方式

msgque.beginreceive

　　消息队列配置属性

　　关于队列的属性

　　　path属性:它可以决定引用队列的三种方式,路径引用.格式名引用.标识引用

　　　category属性:标识当前使用的队列的类型.category是队列所有者定义的guid值.该guid值可以有guid生成工具产生或者是用户自定义的数字值.guid值不会唯一,这样才可以根据相同的guid值,把多个消息队列划分为不同的类别（category）.

　　跟发送数据类型相关的属性

　　　formatter属性:决定在一个队列中如何发送与接收消息的顺序,以及可以在一个消息中发送什么样的内容.

　　与队列交互相关的属性

　　　denysharereceive属性:决定同一时间内只有一个部件能够访问消息队列中的消息.

　　　canread与canwrite属性:决定队列是否可以被读取或者是写入.

　　　maximumqueuesize与maximumjournalsize属性:以千字节为单位设置一个队列（日志队列）的消息最大容纳量.一旦接收的消息到达这个容量,新的消息将不再被接收.

　　一般情况下,消息队列的最大值为消息队列管理员所设置,如果这个值没有控制的话,那么缺省的消息队列最大容量将是无限制的.

　　　usejournalqueue属性::设置是否将收到的消息拷贝到日志消息队列中去.