.net msmq消息队列实例详解
时间:2019-04-14
本文章向大家介绍.net msmq消息队列实例详解,主要包括.net msmq消息队列实例详解使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本文为大家分享了.net msmq消息队列实例代码,供大家参考,具体内容如下
1.msmq消息队列windows环境安装
控制面板----》程序和功能----》启用或关闭Windows程序----》Microsoft Message Queue(MSMQ)服务器
选中如图所示功能点击“确认”进行安装,安装好后可在 “计算机管理”中进行查看
2.创建消息队列实体对象
/// <summary> /// 消息实体 /// </summary> [Serializable] public class MsmqData { public int Id { get; set; } public string Name { get; set; } }
实体对象必须可序列化,即需添加[Serializable]
3.创建消息队列管理对象
/// <summary> /// 消息队列管理对象 /// </summary> public class MSMQManager { /// <summary> /// 消息队列地址 /// </summary> public string _path; /// <summary> /// 消息队列对象 /// </summary> public MessageQueue _msmq; /// <summary> /// 构造函数并初始化消息队列对象 /// </summary> /// <param name="path"></param> public MSMQManager(string path = null) { if (string.IsNullOrEmpty(path)) { _path = ConfigurationManager.AppSettings["MsmqPath"].ToString(); } else { _path = path; } if (MessageQueue.Exists(_path)) { _msmq = new MessageQueue(_path); } else { _msmq = MessageQueue.Create(_path); } } /// <summary> /// 发送消息队列 /// </summary> /// <param name="body"></param> public void Send(object body) { _msmq.Send(new Message(body, new XmlMessageFormatter(new Type[] { typeof(MsmqData) }))); } /// <summary> /// 接受队列中第一个消息后删除 /// </summary> /// <returns></returns> public object ReceiveMessage() { var msg = _msmq.Receive(); if (msg != null) { //msg.Formatter = new BinaryMessageFormatter(); msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(MsmqData) }); var body = (MsmqData)msg.Body; Console.WriteLine("消息内容:{0},{1}", body.Id, body.Name); return msg.Body; } return null; } /// <summary> /// 遍历消息队列中的消息并删除 /// </summary> public void WriteAllMessage() { var enumerator = _msmq.GetMessageEnumerator2(); while (enumerator.MoveNext()) { Message msg = (Message)(enumerator.Current); //msg.Formatter = new BinaryMessageFormatter(); msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(MsmqData) }); var body = (MsmqData)msg.Body; Console.WriteLine("消息内容:{0},{1}", body.Id, body.Name); //根据消息ID查询并删除消息队列 _msmq.ReceiveById(msg.Id); } } }
此例中使用XML格式(XmlMessageFormtter)对消息进行格式化
4.主程序添加调用消息队列
static void Main(string[] args) { var msmqManager = new MSMQManager(); for (int i = 1; i <= 10; i++) { MsmqData data = new MsmqData() { Id = i, Name = string.Format("Name{0}", i) }; //发送消息 msmqManager.Send(data); } var msg = msmqManager.ReceiveMessage(); msmqManager.WriteAllMessage(); Console.ReadLine(); }
添加消息队列地址配置,本例使用私有队列
<appSettings> <add key="MsmqPath" value=".\private$\myQueue"/> </appSettings>
5.运行程序查看结果
可以在发送完消息后打上断点查看消息队列消息正文
最后运行结果
6.常见消息队列类型路径的语法
队列类型
路径中使用的语法
公共队列
MachineName\QueueName
专用队列
MachineName\Private$\QueueName
日志队列
MachineName\QueueName\Journal$
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
- Angularjs基础(四)
- Google Fonts导致WordPress 速度问题的三个解决方案
- DW Replace Open Sans:将WordPress 后台中的open-sans字体加载源从Google Fonts换为360 CDN
- Angularjs基础(三)
- 低多边形(Low-Poly)简介及相关素材分享下载
- 开发者的福音:GenerateWP 自动生成WordPress 开发相关代码
- 自定义WordPress 密码文章提示文字
- 解决WordPress文章密码保护在首页(摘要)不起作用
- WordPress 3.9+的 TinyMCE 4 编辑器增强开发
- Angularjs基础(二)
- Angularjs基础(一)
- iOS 7 Web App的初级优化之道
- Less 常用基础知识
- WooCommerce 结算页面自定义(删除/添加)表单元素
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法