首页 / 消息队列 / .Net消息队列的使用方法
.Net消息队列的使用方法
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了.Net消息队列的使用方法,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含5847字,纯文字阅读大概需要9分钟。
内容图文
![.Net消息队列的使用方法](/upload/InfoBanner/zyjiaocheng/379/3c446efab5854f06986c519b11f756ef.jpg)
.Net使用消息队列,借助windows组件来存储要完成的一系列任务,不用程序使用同一个队列,方便不同程序之间的数据共享和协作……
以本人经验,这个在某个方面类似于session(当然还有很多方面不同),相同之处:session可以把信息存储在aspnet_state服务中,网站重新编译或者重新启动网站,session不会丢失(session超时是正常情况,这种情况除外)。
win7中安装消息队列组件,其他操作系统请百度搜索相关资料。
如果服务没有自动启动,需要启动服务:
先创建队列,再使用队列,队列中的消息,发送一个多一个,接收一个少一个,先进先出。
代码如下:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Messaging;
//添加物理文件 System.Messaging 的引用
namespace testweb
{
public partial class MSMQtest : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
//CreateNewQueue("MsgQueue");//创建一个消息队列
//sendSimpleMsg();//每一个队列最好只发送和接收同一种格式的信息,不然不好转换格式。
//receiveSimpleMsg();//
//receiveSimpleMsg();
//sendComplexMsg();
//receiveComplexMsg();
MsgModel m = receiveComplexMsg<MsgModel>();
Response.Write(m.ToString());
}
private void sendSimpleMsg()
{
//实例化MessageQueue,并指向现有的一个名称为VideoQueue队列
MessageQueue MQ = new MessageQueue(@".\private$\MsgQueue");
//MQ.Send("消息测试", "测试消息");
System.Messaging.Message message = new System.Messaging.Message();
message.Label = "消息lable";
message.Body = "消息body";
MQ.Send(message);
Response.Write("成功发送消息," + DateTime.Now + "<br/>");
}
private void receiveSimpleMsg()
{
MessageQueue MQ = new MessageQueue(@".\private$\MsgQueue");
//调用MessageQueue的Receive方法接收消息
if (MQ.GetAllMessages().Length > 0)
{
System.Messaging.Message message = MQ.Receive(TimeSpan.FromSeconds(5));
if (message != null)
{
//message.Formatter = new System.Messaging.XmlMessageFormatter(new string[] { "Message.Bussiness.VideoPath,Message" });//消息类型转换
message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
Response.Write(string.Format("接收消息成功,lable:{0},body:{1},{2}<br/>", message.Label, message.Body.ToString(), DateTime.Now));
}
}
else
{
Response.Write("没有消息了!<br/>");
}
}
private void sendComplexMsg()
{
//实例化MessageQueue,并指向现有的一个名称为VideoQueue队列
MessageQueue MQ = new MessageQueue(@".\private$\MsgQueue");
//MQ.Send("消息测试", "测试消息");
System.Messaging.Message message = new System.Messaging.Message();
message.Label = "复杂消息lable";
message.Body = new MsgModel("1", "消息1");
MQ.Send(message);
Response.Write("成功发送消息,"+DateTime.Now+"<br/>");
}
private void receiveComplexMsg()
{
MessageQueue MQ = new MessageQueue(@".\private$\MsgQueue");
//调用MessageQueue的Receive方法接收消息
if (MQ.GetAllMessages().Length > 0)
{
System.Messaging.Message message = MQ.Receive(TimeSpan.FromSeconds(5));
if (message != null)
{
message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(MsgModel) });//消息类型转换
MsgModel msg = (MsgModel)message.Body;
Response.Write(string.Format("接收消息成功,lable:{0},body:{1},{2}<br/>", message.Label, msg, DateTime.Now));
}
}
else
{
Response.Write("没有消息了!<br/>");
}
}
private T receiveComplexMsg<T>()
{
MessageQueue MQ = new MessageQueue(@".\private$\MsgQueue");
//调用MessageQueue的Receive方法接收消息
if (MQ.GetAllMessages().Length > 0)
{
System.Messaging.Message message = MQ.Receive(TimeSpan.FromSeconds(5));
if (message != null)
{
message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(T) });//消息类型转换
T msg = (T)message.Body;
return msg;
}
}
return default(T);
}
/// <summary>
/// 创建消息队列
/// </summary>
/// <param name="name">消息队列名称</param>
/// <returns></returns>
public void CreateNewQueue(string name)
{
if (!System.Messaging.MessageQueue.Exists(".\\private$\\" + name))//检查是否已经存在同名的消息队列
{
System.Messaging.MessageQueue mq = System.Messaging.MessageQueue.Create(".\\private$\\" + name);
mq.Label = "private$\\"+name;
Response.Write("创建成功!<br/>");
}
else
{
//System.Messaging.MessageQueue.Delete(".\\private$\\" + name);//删除一个消息队列
Response.Write("已经存在<br/>");
}
}
}
[Serializable]
public class MsgModel
{
public string id { get; set; }
public string Name { get; set; }
public MsgModel() { }
public MsgModel(string _id, string _Name)
{
id = _id;
Name = _Name;
}
public override string ToString()
{
if (string.IsNullOrEmpty(id) || string.IsNullOrEmpty(Name)) return "";
return string.Format("id--{0},Name--{1}",id,Name);
}
}
}
内容总结
以上是互联网集市为您收集整理的.Net消息队列的使用方法全部内容,希望文章能够帮你解决.Net消息队列的使用方法所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。