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属性::设置是否将收到的消息拷贝到日志消息队列中去。

MSMQ是什么?,布布扣,bubuko.com

时间: 2024-10-11 00:53:14

MSMQ是什么?的相关文章

【转】MSMQ 微软消息队列 简单 示例

MSMQ它的实现原理是:消息的发送者把自己想要发送的信息放入一个容器中(我们称之为Message),然后把它保存至一个系统公用空间的消息队列(Message Queue)中:本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理. 我个人的理解,你可以把他当做一种,把数据打包后,发送到一个地方,程序也可以去取到这个打包的程序,队列的机制就不讲了,并发问题荡然无存.呵呵. 上代码: 首先 using System.Messaging; public class MsmqManagerHe

WCF基于MSMQ的事件代理服务

前言 公司目前楼主负责的项目正在改版升级,对之前的服务也在作调整,项目里有个操作日志的模块,就决定把日志单独提取出来,做个日志服务,所以就有了这篇文章 正文 MSMQ作为消息队列,B/S项目调用日志服务,日志服务往消息队列发送消息,事件代理服务负责处理消息队列的消息,贴下核心代码 事件代理服务契约 using System; using System.Collections.Generic; using System.Linq; using System.ServiceModel; using

微软消息队列MSMQ 传输异常的总结!

公司线上环境99%是esxi的虚拟环境,随着公司线上虚拟机的增加,在部署虚拟机时我们一般都是采用模板才统一部署,当一个模板建立好后,新建虚拟机时就默认采用该模版运行,没有加入用户自定义环节. 由于公司为软件型企业且百分之九十采用的是微软的.net开发用户平台,由于平台的特殊性需要和多方面机构进行数据交换工作,根据开发的环境特点,选用的是微软系统自带的消息队列MSMQ进行数据传输, 随着msmq服务器越来越多的上线,而且会多台服务器往一台服务器上发送消息,最近频繁的发现一个问题,服务器服务正常,各

C#-MSMQ安装及配置

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 <system.serviceModel>     <behaviors>         <serviceBehaviors>             <behavior name="">                 <ser

MSMQ小Demo

Demo基于http://www.cnblogs.com/zhili/p/MSMQ.html Server代码: using System.Messaging; using System.Text; using System.Threading.Tasks; namespace MSMQServer { class Program { static void Main(string[] args) { const string messageQueuePath = @".\Private$\My

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

目录 一:MSMQ的一些理论上的知识 二:队列类型(Queue Type) 三:安装消息队列 四:在C#中Messagequeue class 五:MSMQ-发送消息到远程专用队列 六:例子 一.在学习Messagequeue 类之前,首先介绍一下MSMQ的一些理论上的知识          MSMQ(MicroSoft Message Queue,微软消息队列)官方的解释是:在多个不同的应用之间实现相互通信的一种异步传输模式,相互通信的应用可以分布于同一台机器上,也可以分布于相连的网络空间中的

C#关于MSMQ通过HTTP远程发送专有队列消息的问题

两台计算机的操作系统都是Windows Server 2008两台计算机都安装了MSMQ+Http支持两台计算机的防火墙全部关闭本地Ip:192.168.1.104远程Ip:192.168.1.142远程建立专有队列:Test本地发送消息的代码:System.Messaging.MessageQueue mq =    new System.Messaging.MessageQueue ("FormatName:Direct=http://192.168.1.142/msmq/Private$/

ASP.NET中进行消息处理(MSMQ) 二

在我上一篇文章<ASP.NET中进行消息处理(MSMQ)一>里对MSMQ做了个通俗的介绍,最后以发送普通文本消息和复杂的对象消息为例介绍了消息队列的使用. 本文在此基础上继续介绍MSMQ的相关知识点,最后还是通过一个示例程序来分析MSMQ在实际项目开发中的应用. 建议:如果你对MSMQ不够了解,在你阅读本文前请先阅读第一部分:<ASP.NET中进行消息处理(MSMQ)一>. 一.消息传递的优先级      在MSMQ中消息在队列里传输是分有优先级的,这里我就以实例的形式介绍下关于优

ASP.NET中进行消息处理(MSMQ) 一

MSMQ是微软消息队列的英文缩写.那么什么是消息队列?这些介绍网上一大片这里就不多说了.本文对于大虾级的人物来说这只是小玩意而已,对于初学者来说这文章还是有一定的帮助,希望路过的大虾们别笑话我班门弄斧. 一.MSMQ介绍和安装消息队列      关于MSMQ详细的介绍请大家向http://www.baidu.com/或http://www.g.cn/等专家咨询.      使用消息队列的优点:稳定.消息优先级.脱机能力以及安全性.      消息队列分为用户创建的队列(专用队列)和系统队列,用户

ASP.NET中进行消息处理(MSMQ) 三

在本文的前两篇文章里对MSMQ的相关知识点进行了介绍,很多阅读过这前两篇文章的朋友都曾问到过这样一些问题:  1.如何把MSMQ应用到实际的项目中去呢?  2.可不可以介绍一个实际的应用实例?  3....... 在前两篇文章里,关于MSMQ常用的技术点基本介绍完毕了,本文主要以MS开源项目PetShop中的MSMQ应用作为案例来介绍MSMQ在实际项目中的应用.在PetShop里,由于系统使用了多线程的专用应用程序来监控消息队列,在进入PetShop应用分析前,我们先来了解下关于多线程和MSMQ