NET中MSMQ的使用----附例子
目录
- 一:MSMQ的一些理论上的知识
- 二:队列类型(Queue Type)
- 三:安装消息队列
- 四:在C#中Messagequeue class
- 五:MSMQ-发送消息到远程专用队列
- 六:例子
一、在学习Messagequeue 类之前,首先介绍一下MSMQ的一些理论上的知识 MSMQ(MicroSoft Message Queue,微软消息队列)官方的解释是:在多个不同的应用之间实现相互通信的一种异步传输模式,相互通信的应用可以分布于同一台机器上,也可以分布于相连的网络空间中的任一位置。MSMQ通过发送和接受消息使得应用程序之间的通信变的更快和更可靠。
它的实现原理是:消息的发送者把自己想要发送的信息放入一个容器中(我们称之为Message),然后把它保存至一个系统公用空间的消息队列(Message Queue)中;本地或者是异地的消息接收程序再从该队列中取出发给它的消息进行处理。
在消息传递机制中,有两个比较重要的概念。一个是消息,一个是队列。消息是由通信的双方所需要传递的信息,说白了它可以是各式各样的媒体,如文本、声音、图象,在我们编程的时候,它一般是一个类的对象或字符串等,消息最终的理解方式,为消息传递的双方事先商定,这样做的好处是,一是相当于对数据进行了简单的加密,二则采用自己定义的格式可以节省通信的传递量。队列是发送和接收消息的公用存储空间,它可以存在于内存中或者是物理文件中。
采用MSMQ带来的好处是:由于是异步通信,无论是发送方还是接收方都不用等待对方返回成功消息,就可以执行余下的代码,因而大大地提高了事物处理的能力;当信息传送过程中,信息发送机制具有一定功能的故障恢复能力;MSMQ的消息传递机制使得消息通信的双方具有不同的物理平台成为可能。在微软的.net平台上利用其提供的MSMQ功能,可以轻松创建或者删除消息队列、发送或者接收消息、甚至于对消息队列进行管理。
二:队列类型(Queue Type) 由您或网络中的其他用户创建的队列和系统队列。用户创建的队列可能是以下任何一种队列:
“公共队列”在整个“消息队列”网络中复制,并且有可能由网络连接的所有站点访问。
“专用队列”不在整个网络中发布。相反,它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。
“管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列(如果有的话)。
“响应队列”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列(如果有的话)。
系统生成的队列一般分为以下几类: “日记队列”可选地存储发送消息的副本和从队列中移除的消息副本。每个“消息队列”客户端上的单个日记队列存储从该计算机发送的消息副本。在服务器上为每个队列创建了一个单独的日记队列。此日记跟踪从该队列中移除的消息。 “死信队列”存储无法传递或已过期的消息的副本。如果过期或无法传递的消息是事务性消息,则被存储在一种特殊的死信队列中,称为“事务性死信队列”。死信存储在过期消息所在的计算机上。有关超时期限和过期消息的更多信息,请参见默认消息属性。 “报告队列”包含指示消息到达目标所经过的路由的消息,还可以包含测试消息。每台计算机上只能有一个报告队列。 “专用系统队列”是一系列存储系统执行消息处理操作所需的管理和通知消息的专用队列。 在应用程序中进行的大多数工作都涉及访问公共队列及其消息。但是,根据应用程序的日记记录、确认和其他特殊处理需要,在日常操作中很可能要使用几种不同的系统队列。
三:安装消息队列
如果你相使用消息队列进行通信的话,你就必须在你的电脑上安装消息队列,通过组件安装,具体安装的方法在这里就不详解了,类似于安装IIS一样
对消息队列有了简单的了解后,使用MSMQ进行软件开发需要安装MSMQ,安装完后就该进入实际的开发阶段。具体的安装过程就是在控制面板里“添加/删除程序”下“添加/删除Windows组件”,完成添加就OK。安装完成后就可以通过交互界添加新的消息队列,详细如下图:
出了上面这种交互界面来创建MSMQ外,也可以通过编程来完成。
四:在C#中Messagequeue class
在使用.net开发msmq时,你必须引入命名空System.Messaging
MessageQueue 支持两种消息类型,同步和异步,同步方法使用的是peek();receive();异步使用的是:
Beginpeek() and Beginreceive();两者没有什么本质区别,都是封装好的方法,你只要直接创建Messagequeue的对象来调用这个方法就OK了, 我想至于什么同步和异步是什么意思,就没有必有解释了吧,
五:MSMQ-发送消息到远程专用队列
六:例子
------------------------------------------------------------------------------
using System;
using System.Collections.Generic;
using System.Text;
using System.Messaging;
namespace MyQueue
{
public class MyMessageQueue
{
private string Path;
/// <summary>
/// 1.通过Create方法创建使用指定路径的新消息队列
/// </summary>
/// <param name="queuePath"></param>
public void Createqueue(string queuePath)
{
try
{
if (!MessageQueue.Exists(queuePath))
{
MessageQueue.Create(queuePath);
}
else
{
Console.WriteLine(queuePath + "已经存在!");
//MessageQueue.Delete(queuePath);
//MessageQueue.Create(queuePath);
//Console.WriteLine(queuePath + "删除重建");
}
Path = queuePath;
}
catch (MessageQueueException e)
{
Console.WriteLine(e.Message);
}
}
/// <summary>
/// 2.连接消息队列并发送消息到队列
/// 远程模式:MessageQueue rmQ = new MessageQueue("FormatName:Direct=OS:machinename//private$//queue");
/// rmQ.Send("sent to regular queue - Atul");对于外网的MSMQ只能发不能收
/// </summary>
public void SendMessage()
{
try
{
//连接到本地队列
MessageQueue myQueue = new MessageQueue(Path);
//MessageQueue myQueue = new MessageQueue("FormatName:Direct=TCP:192.168.12.79//Private$//myQueue1");
//MessageQueue rmQ = new MessageQueue("FormatName:Direct=TCP:121.0.0.1//private$//queue");--远程格式
Message myMessage = new Message();
myMessage.Body = "消息内容34kuangbo去死";
myMessage.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
//发生消息到队列中
myQueue.Send(myMessage);
Console.WriteLine("消息发送成功!");
Console.ReadLine();
}
catch (ArgumentException e)
{
Console.WriteLine(e.Message);
}
}
/// <summary>
/// 3.连接消息队列并从队列中接收消息
/// </summary>
public void ReceiveMessage()
{
MessageQueue myQueue = new MessageQueue(Path);
myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
try
{
//从队列中接收消息
Message myMessage = myQueue.Receive();// myQueue.Peek();--接收后不消息从队列中移除
string context = myMessage.Body.ToString();
Console.WriteLine("消息内容:" + context);
Console.ReadLine();
}
catch (MessageQueueException e)
{
Console.WriteLine(e.Message);
}
catch (InvalidCastException e)
{
Console.WriteLine(e.Message);
}
}
/// <summary>
/// 4.清空指定队列的消息
/// </summary>
public void ClealMessage()
{
MessageQueue myQueue = new MessageQueue(Path);
myQueue.Purge();
Console.WriteLine("已清空对了{0}上的所有消息",Path);
}
/// <summary>
/// 5.连接队列并获取队列的全部消息
/// </summary>
public void GetAllMessage()
{
MessageQueue myQueue = new MessageQueue(Path);
Message[] allMessage = myQueue.GetAllMessages();
XmlMessageFormatter formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
for (int i = 0; i < allMessage.Length; i++)
{
allMessage[i].Formatter = formatter;
Console.WriteLine("第{0}机密消息为:{1}", i+1, allMessage[i].Body.ToString());
}
Console.ReadLine();
}
}
}
注意:传输的 路径格式 要正确。
出处:http://blog.csdn.net/sage425/article/details/6298461
NET中MSMQ的使用----附例子相关推荐
- 十五分钟实现Google Talk客户端(附例子)
十五分钟实现Google Talk客户端(附例子) ChinaUnix博客-中国最专业的IT技术博客 - Powered by UCenter Home 十五分钟实现Google Talk客户端(附例 ...
- python中tornado的第一个例子
python中tornado的第一个例子 1 先安装tornado pip install tornado 2 新建tor.py 记住不能建立 tornado.py 这样的名字 不然会报错 Imp ...
- 独家 | 一文解析统计学在机器学习中的重要性(附学习资源)
作者:Jason Brownlee 翻译:陈之炎 校对:万文青 本文共2400字,建议阅读10分钟. 本文介绍为什么统计对于通用应用和机器学习如此重要,并大致了解各种可用的方法. 统计是一组工具,您可 ...
- anychart java实例_在.Net开发中使用AnyChart的简单例子(上)
1.AnyChart控件相关 显示效果 2.AnyChart的简单原理 AnyChart是一个Flash做的控件,原理图在安装了AnyChart后的说明文档里面有,这里贴一下 其实很好理解,就是想办法 ...
- php ajax 框架,PHP开发框架kohana中处理ajax请求的例子
这篇文章主要介绍了PHP开发框架kohana中处理ajax请求的例子,kohana是一个PHP5开发框架,需要的朋友可以参考下 今天分享的是在kohana中处理页面的ajax请求.2步搞定.前提是你的 ...
- python实时获取子进程输出_Python 从subprocess运行的子进程中实时获取输出的例子...
有些时候,我们需要将某些程序放到子进程中去运行,以达到整合系统的目的.在Python中,一个非常好的选择就是使用subprocess模块,本模块为开辟子进程去执行子程序提供了统一的接口,更加便于学习和 ...
- wow mysql dbc_DBC中悲观锁介绍附案例详解
DBC中悲观锁介绍附案例详解 了解下DBC中悲观锁: 代码如下: BDUtils 工具类: package JDBC; import java.sql.*; public class BDUtils ...
- redis cluster中添加删除重分配节点例子
redis cluster中添加删除重分配节点例子 作者:用户 来源:互联网 时间:2016-05-05 10:22:27 摘要: 本文讲的是redis cluster中添加删除重分配节点例子, re ...
- 在QT中CXDVA视频组件的例子
在QT中CXDVA视频组件的例子 在windows 平台下,cxdva视频组件可以在Qt.MFC等等框架中嵌入视频播放画面.cxdva视频组件使用起来很简单,只用简单的的调用三四个函数就可以实现播放视 ...
最新文章
- 工程数据计算机处理的方法有,第二章 CADCAM技术基础-工程数据的计算机处理2011.ppt...
- python读取二进制数据中的while循环_在Python中读取二进制文件并循环遍历每个字节...
- notepadpython插件_Notepad++插件Emmet和Python Script的安装
- 闪灯什么意思_开车闪一下闪二下闪三下大灯是什么意思
- LeetCode Implement Queue using Stacks (数据结构)
- 安卓案例:联选系部与专业
- python按位与怎么算_python 的按位与、或、异或 运算
- 李宏毅自然语言处理——文本风格转换
- 通信工程领域当前的主流技术及其社会需求调查报告
- node.js源码安装
- 【算法与数据结构】—— 大数运算
- PostgreSQL下载安装教程以及官网下载包出现的问题
- 手机上流行的各类谜语大揭密
- 交换机短路_交换机环路发现及处理
- HTML网页获取当前定位经纬度/地理位置定位/百度定位/高德定位
- ThingJS-X森可视平台框架源码 java+Netcore版本 旗舰版企业版
- timing lib时序弧
- Xavier/Tx2镜像拷贝及系统克隆
- 数学之美笔录(1):统计语言模型
- 看雪3万课程笔记-FRIDA高级API实用方法:Frida Hook Native层
热门文章
- C++Persistent segment tree持久段树的实现算法(附完整源码)
- C语言素数分解prime factoriziation算法(附完整源码)
- C语言字符串转换为整数(附完整源码)
- C++ Opengl 绘制纹理字符源码
- C语言多维数组做函数参数技术推演
- 16_clickhouse,HDFS引擎,JDBC引擎
- 1.子查询知识体系,单行子查询,多行子查询
- SimpleDateFormat 按照不同要求去改写时间的格式,或者把时间串变成date类型
- adguard没有核心 core no_业主装修最后悔的五个地方!没有之一
- 重磅资源|Pytorch1.0版本的Mask R-CNN的Facebook的官方实现