WinFormMSMQ 微软消息队列 的使用小例子，如何发送 至指定的 从 .net 249万源代码下载-
&文件名称: WinFormMSMQ& & [
& & & & &&]
&&所属分类:
&&开发工具: C#
&&文件大小: 73 KB
&&上传时间:
&&下载次数: 0
&&提 供 者:
&详细说明：微软消息队列MSMQ的使用小例子，如何发送消息至指定的消息队列，如何从指定的消息队列取到数据-Microsoft Message Queuing MSMQ using small examples, how to send a message to the specified message queue, how to learn
the message queue specified data
文件列表(点击判断是否您需要的文件，如果是垃圾请在下面评价投诉):
&&WinFormMSMQ\app.config&&...........\bin\Debug\log\.txt&&...........\...\.....\WinFormMSMQ.exe&&...........\...\.....\WinFormMSMQ.exe.config&&...........\...\.....\WinFormMSMQ.pdb&&...........\...\.....\WinFormMSMQ.vshost.exe&&...........\...\.....\WinFormMSMQ.vshost.exe.config&&...........\...\.....\WinFormMSMQ.vshost.exe.manifest&&...........\...\Debug.rar&&...........\FrmMain.cs&&...........\FrmMain.Designer.cs&&...........\FrmMain.resx&&...........\FrmRevice.cs&&...........\FrmRevice.Designer.cs&&...........\FrmRevice.resx&&...........\FrmSend.cs&&...........\FrmSend.Designer.cs&&...........\FrmSend.resx&&...........\MSMQInfo.cs&&...........\obj\x86\Debug\DesignTimeResolveAssemblyReferences.cache&&...........\...\...\.....\DesignTimeResolveAssemblyReferencesInput.cache&&...........\...\...\.....\TempPE\Properties.Resources.Designer.cs.dll&&...........\...\...\.....\WinFormMSMQ.csproj.FileListAbsolute.txt&&...........\...\...\.....\WinFormMSMQ.csproj.GenerateResource.Cache&&...........\...\...\.....\WinFormMSMQ.exe&&...........\...\...\.....\WinFormMSMQ.FrmMain.resources&&...........\...\...\.....\WinFormMSMQ.FrmRevice.resources&&...........\...\...\.....\WinFormMSMQ.FrmSend.resources&&...........\...\...\.....\WinFormMSMQ.pdb&&...........\...\...\.....\WinFormMSMQ.Properties.Resources.resources&&...........\Program.cs&&...........\...perties\AssemblyInfo.cs&&...........\..........\Resources.Designer.cs&&...........\..........\Resources.resx&&...........\..........\Settings.Designer.cs&&...........\..........\Settings.settings&&...........\ReviceMess.cs&&...........\SendMess.cs&&...........\WinFormMSMQ.csproj&&...........\obj\x86\Debug\TempPE&&...........\bin\Debug\log&&...........\obj\x86\Debug&&...........\bin\Debug&&...........\...\Release&&...........\obj\x86&&...........\bin&&...........\obj&&...........\Properties&&WinFormMSMQ
&输入关键字，在本站249万海量源码库中尽情搜索： 上传我的文档
 下载
 收藏
该文档贡献者很忙，什么也没留下。
 下载此文档
正在努力加载中...
MSMQ(消息队列)学习笔记
下载积分：840
内容提示：MSMQ(消息队列)学习笔记
文档格式：DOC|
浏览次数：151|
上传日期： 18:40:16|
文档星级：
该用户还上传了这些文档
MSMQ(消息队列)学习笔记
官方公共微信当前位置： →
→ MSMQ 消息队列
MSMQ 消息队列
& 作者及来源： dapeng888 - 博客园 &
&收藏到→_→：
摘要: MSMQ 消息队列
"MSMQ 消息队列"：：
原文地址：/jiashe_007/blog/static/3/
手记：转来的！今天装西门子wincc ，没成功，提示微软消息队列message queue 没有安装，然后在控制面板－添加删除程序里安装windows组件，提示要插入系统盘，找了好久都没找到，才发现原来系统盘是很重要的资料，不可以丢啊！第二天找来系统盘安装，安装的过程中中断，提示&无法启动msmq服务&，刚开始不知道msmq是个什么东西，上网搜索，果然有人问了同样的问题，但是没有解答，然后就找到这篇博文，看了看，对消息队列有了了解。还不错！使用下面的方法，首先启动msmq服务，然后就可以安装消息队列，安装了消息队列就可以安装wincc了！wincc 7.0 sp1很大，需要安装内容很多！
问2：无法启动msmq服务！！！！cmd的方法用过了，最后msdos里显示， 系统发生1058错误，无法启动服务，原因是他被禁用或者与他相关的设备没有启动;问题补充：我列表里没有这个服务啊，连cmd里也这么提示&&&
答2：原因：&distributed transaction coordinator&服务未启动。解决：右击&我的电脑&管理&服务和&服务&中将此服务启动。也可使用如下方法：开始&运行中输入：cmd后依次输入如下语句：
net stop msdtc&&&&&& msdtc -uninstall&&&&&& msdtc -install&&&&&& net start msdtc
问1：为什么在xp上添加消息队列时不成功提示：无法启动msmq服务，消息队列客户端安装失败
无法启动msmq服务 错误代码0x42c 错误描述：依存服务或组无法启动。
答1：没有答案
msmq的简单介绍
标签：&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属性：以千字节为单位设置一个队列（日志队列）的消息最搜索此文相关文章：此文来自: 马开东博客
网址: 站长QQ
MSMQ 消息队列_博客园相关文章
博客园_总排行榜
博客园_最新
博客园_月排行榜
博客园_周排行榜
博客园_日排行榜MSMQ(消息队列)续 - 虔诚者 - 推酷
MSMQ(消息队列)续 - 虔诚者
在上一篇我简单介绍了MSMQ的相关概念，本篇将以代码说明
Message是MSMQ的数据存储单元，我们的用户数据一般也被填充在Message的body当中，因此很重要，让我们来看一看其在.net中的体现，如图：
在图上我们可以看见，Message提供了三个构造函数,参数body表示我们的用户数据，当我们在构造函数中传入，数据最终会被赋值给其同名属性body,参数formatter对应同名属性Formatter，它是一个序列化器，当我们的用户数据是一个复杂类型，比如类的时候Message会自动采用该序列化器将我们的复杂类型序列化。message支持3种序列化对象：
-- XMLMessageFormatter对象----MessageQueue组件的默认格式化程序设置。
-- BinaryMessageFormatter对象;
-- ActiveXMessageFormatter对象;
由于后两者格式化后的消息通常不能为人阅读，所以我们经常用到的是XMLMessageFormatter对象。该对象构造方法有三种重载：
public XmlMessageFormatter();
public XmlMessageFormatter(string[] targetTypeNames);
public XmlMessageFormatter(Type[] targetTypes);
消息(Message)需要保存在msmq队列中，.net中采用System.Messaging.MessageQueue来管理MSMQ队列,它提供能操作MSMQ的绝大多数API，比如
1.判断指定路径的队列是否存在。其中path代表队列的路径，表示形式为&主机名\队列名称&，例如：&.\private$\myQueue&,其中&.&代表本地主机，&\private$\myQueue&则代表队列的名称，&private$&表示我们创建的是专用队列，在网络上我们可以通过路径来唯一确定一个队列。
public static bool Exists(string path);
2.创建队列。path代表队列的路径，transactional表示是否创建事务队列，默认为fasle。关于事务队列我在上一篇做了详细的论述，这里不在重复。
public static MessageQueue Create(string path);
public static MessageQueue Create(string path, bool transactional);
3.删除队列
public static void Delete(string path);
4.发送消息到MSMQ。obj代表我们的用户数据，transation表示将我们的发送操作纳入事务当中。在前面我们说过MSMQ接收的是Message,但是在这里我们看到Send操作并未强制要求我们采用Message类型参数。这是因为当我传入一个Object参数数据时，在Send操作的内部自动的给我们创建了一个Message消息对象，并且将我们的传入的Object参数采用默认的序列化器序列化，然后装入Message的body属性当中，如果我们在Send方法中指定label属性，它将被赋值给Message的同名Label属性。当然我们完全可以自定义一个message对象传入Send方法中
public void Send(object obj);
public void Send(object obj, MessageQueueTransaction transaction);
public void Send(object obj, string label);
5.接收消息。同理接收消息也可以被纳入事务当中，采用Receive方法在取MSMQ的消息时，如果成功，会把MSMQ的对应消息给删除掉，并且只能取到消息队里中的排队头的消息。
public Message Receive();
public Message Receive(MessageQueueTransaction transaction);
public Message Receive(TimeSpan timeout);
如果我们想取指定标识的消息，就的采用如下的方法了,id代表消息的唯一标示。
public Message ReceiveById(string id);
public Message ReceiveById(string id, MessageQueueTransaction transaction);
如果我们在接收消息的后，不想把MSMQ队列中的消息删除怎么办呢?那么采用下面的方法吧，因为这两个方法接收MSMQ的消息，不会删除MSMQ中对应的消息，所以他们不支持事务，即没有提供事务的参数。
public Message Peek();
public Message PeekById(string id);
我们也可以一次性吧队列里面的所有消息取出来
public Message[] GetAllMessages();
说了这么多，下面让我们来代码实战一下，我们采用控制台程序做测试，我把MSMQ队列做了简单的封装，如下
using System.Collections.G
using System.L
using System.M
using System.T
using System.Threading.T
namespace Test
public class QueueManger
/// &summary&
/// 创建MSMQ队列
/// &/summary&
/// &param name=&queuePath&&队列路径&/param&
/// &param name=&transactional&&是否事务队列&/param&
public static void Createqueue(string queuePath, bool transactional = false)
//判断队列是否存在
if (!MessageQueue.Exists(queuePath))
MessageQueue.Create(queuePath);
Console.WriteLine(queuePath + &已成功创建！&);
Console.WriteLine(queuePath + &已经存在！&);
catch (MessageQueueException e)
Console.WriteLine(e.Message);
/// &summary&
/// 删除队列
/// &/summary&
/// &param name=&queuePath&&&/param&
public static void Deletequeue(string queuePath)
//判断队列是否存在
if (MessageQueue.Exists(queuePath))
MessageQueue.Delete(@&.\private$\myQueue&);
Console.WriteLine(queuePath + &已删除！&);
Console.WriteLine(queuePath + &不存在！&);
catch (MessageQueueException e)
Console.WriteLine(e.Message);
/// &summary&
/// 发送消息
/// &/summary&
/// &typeparam name=&T&&用户数据类型&/typeparam&
/// &param name=&target&&用户数据&/param&
/// &param name=&queuePath&&队列名称&/param&
/// &param name=&tran&&&/param&
/// &returns&&/returns&
public static bool SendMessage&T&(T target, string queuePath, MessageQueueTransaction tran = null)
//连接到本地的队列
MessageQueue myQueue = new MessageQueue(queuePath);
System.Messaging.Message myMessage = new System.Messaging.Message();
myMessage.Body =
myMessage.Formatter = new XmlMessageFormatter(new Type[] { typeof(T) });
//发送消息到队列中
if (tran == null)
myQueue.Send(myMessage);
myQueue.Send(myMessage, tran);
Console.WriteLine(&消息已成功发送到&+queuePath + &队列！&);
return true;
catch (ArgumentException e)
Console.WriteLine(e.Message);
return false;
/// &summary&
/// 接收消息
/// &/summary&
/// &typeparam name=&T&&用户的数据类型&/typeparam&
/// &param name=&queuePath&&消息路径&/param&
/// &returns&用户填充在消息当中的数据&/returns&
public static T ReceiveMessage&T&(string queuePath,MessageQueueTransaction tran=null)
//连接到本地队列
MessageQueue myQueue = new MessageQueue(queuePath);
myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(T) });
//从队列中接收消息
System.Messaging.Message myMessage = tran == null ? myQueue.Receive() : myQueue.Receive(tran);
return (T)myMessage.B //获取消息的内容
catch (MessageQueueException e)
Console.WriteLine(e.Message);
catch (InvalidCastException e)
Console.WriteLine(e.Message);
return default(T);
/// &summary&
/// 采用Peek方法接收消息
/// &/summary&
/// &typeparam name=&T&&用户数据类型&/typeparam&
/// &param name=&queuePath&&队列路径&/param&
/// &returns&用户数据&/returns&
public static T ReceiveMessageByPeek&T&(string queuePath)
//连接到本地队列
MessageQueue myQueue = new MessageQueue(queuePath);
myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(T) });
//从队列中接收消息
System.Messaging.Message myMessage = myQueue.Peek();
return (T)myMessage.B //获取消息的内容
catch (MessageQueueException e)
Console.WriteLine(e.Message);
catch (InvalidCastException e)
Console.WriteLine(e.Message);
return default(T);
/// &summary&
/// 获取队列中的所有消息
/// &/summary&
/// &typeparam name=&T&&用户数据类型&/typeparam&
/// &param name=&queuePath&&队列路径&/param&
/// &returns&用户数据集合&/returns&
public static List&T& GetAllMessage&T&(string queuePath)
MessageQueue myQueue = new MessageQueue(queuePath);
myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(T) });
Message[] msgArr=
myQueue.GetAllMessages();
List&T& list=new List&T&();
msgArr.ToList().ForEach((o) =&
list.Add((T)o.Body);
catch(Exception e)
Console.WriteLine(e.Message);
return null;
我们的用户实体也很简单，如下
using System.Collections.G
using System.L
using System.T
using System.Threading.T
namespace Test
public class Student
/// &summary&
/// &/summary&
public int Age { get; set; }
/// &summary&
/// &/summary&
public string Name { get; set; }
下面我们来创建一个队列
using System.Collections.G
using System.L
using System.M
using System.T
using System.Threading.T
namespace Test
class Program
static void Main(string[] args)
string queuepath = @&.\private$\myQueue&;
QueueManger.Createqueue(queuepath);
Console.ReadKey();
下面我们向队列中发送消息(如图右边的消息成功被加入)
using System.Collections.G
using System.L
using System.M
using System.T
using System.Threading.T
namespace Test
class Program
static void Main(string[] args)
string queuepath = @&.\private$\myQueue&;
//QueueManger.Createqueue(queuepath);
Student stu = new Student() { Name=&shaoshun&,Age=18};
QueueManger.SendMessage&Student&(stu, queuepath);
Console.ReadKey();
接着我们采用Peek方法接收消息(即不移除MSMQ的对应消息)，很显然图中的Message依然存在MSMQ队列中
using System.Collections.G
using System.L
using System.M
using System.T
using System.Threading.T
namespace Test
class Program
static void Main(string[] args)
string queuepath = @&.\private$\myQueue&;
//QueueManger.Createqueue(queuepath);
//Student stu = new Student() { Name=&shaoshun&,Age=18};
//QueueManger.SendMessage&Student&(stu, queuepath);
Student stu=
QueueManger.ReceiveMessageByPeek&Student&(queuepath);
Console.WriteLine(stu.Name);
Console.ReadKey();
接着我们采用Receive方法来接收消息。这个时候我们可以很明显的看见MSMQ原来对应的消息被删除了
using System.Collections.G
using System.L
using System.M
using System.T
using System.Threading.T
namespace Test
class Program
static void Main(string[] args)
string queuepath = @&.\private$\myQueue&;
//QueueManger.Createqueue(queuepath);
//Student stu = new Student() { Name=&shaoshun&,Age=18};
//QueueManger.SendMessage&Student&(stu, queuepath);
//Student stu=
QueueManger.ReceiveMessageByPeek&Student&(queuepath);
Student stu = QueueManger.ReceiveMessage&Student&(queuepath);
Console.WriteLine(stu.Name);
Console.ReadKey();
最后让我来测试，MSMQ的事务性。我们先删除我们的队列，在重新创建。我们连续向队列中插入5个消息，但是在插入第5个消息的时候我们抛出异常，如果MSMQ支持事务的话那么前面发送的4个Message将被回滚掉，MSMQ队列中应该为0个消息
using System.Collections.G
using System.L
using System.M
using System.T
using System.Threading.T
namespace Test
class Program
static void Main(string[] args)
string queuepath = @&.\private$\myQueue&;
//QueueManger.Createqueue(queuepath);
//Student stu = new Student() { Name=&shaoshun&,Age=18};
//QueueManger.SendMessage&Student&(stu, queuepath);
//Student stu=
QueueManger.ReceiveMessageByPeek&Student&(queuepath);
//Student stu = QueueManger.ReceiveMessage&Student&(queuepath);
//Console.WriteLine(stu.Name);
QueueManger.Deletequeue(queuepath);
QueueManger.Createqueue(queuepath);
MessageQueueTransaction tran = new MessageQueueTransaction();
tran.Begin();
for (int i = 0; i & 4; i++)
stu=new Student(){Name=&shaoshun&+i,Age=i};
QueueManger.SendMessage&Student&(stu, queuepath, tran);
if (i == 3)
throw new Exception();
tran.Abort();
Console.ReadKey();
另外值得注意的是，MSMQ的消息发送与接收，采用的是同步的方式。这样假如我们的消息队列中一个消息都没有，我们调用Receive()去接收该队列的消息会怎么样呢? 程序会被阻塞在这里，直到消息队列中有消息，程序才会接着往下走。碰到这种情况是很要命的，但是不怕MSMQ支持异步消息，由于篇幅有限我就不在多少，这里我给出一个异步操作的链接有兴趣的朋友可以去研究下，点击
已发表评论数()
已收藏到推刊！
请填写推刊名
描述不能大于100个字符!
权限设置： 公开
仅自己可见
正文不准确
排版有问题
没有分页内容
视频无法显示
图片无法显示