不好_.Net消息队列的使用

篇首语：本文由编程笔记#小编为大家整理，主要介绍了.Net消息队列的使用相关的知识，希望对你有一定的参考价值。

.Net使用消息队列&＃xff0c;借助windows组件来存储要完成的一系列任务&＃xff0c;不用程序使用同一个队列&＃xff0c;方便不同程序之间的数据共享和协作……

以本人经验&＃xff0c;这个在某个方面类似于session&＃xff08;当然还有很多方面不同&＃xff09;,相同之处&＃xff1a;session可以把信息存储在aspnet_state服务中&＃xff0c;网站重新编译或者重新启动网站&＃xff0c;session不会丢失&＃xff08;session超时是正常情况&＃xff0c;这种情况除外&＃xff09;。

win7中安装消息队列组件&＃xff0c;其他操作系统请百度搜索相关资料。

如果服务没有自动启动&＃xff0c;需要启动服务&＃xff1a;

先创建队列&＃xff0c;再使用队列&＃xff0c;队列中的消息&＃xff0c;发送一个多一个&＃xff0c;接收一个少一个&＃xff0c;先进先出。

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();//每一个队列最好只发送和接收同一种格式的信息&＃xff0c;不然不好转换格式。
//receiveSimpleMsg();//
//receiveSimpleMsg();
//sendComplexMsg();
//receiveComplexMsg();
MsgModel m &＃61; receiveComplexMsg();
Response.Write(m.ToString());


private void sendSimpleMsg()

//实例化MessageQueue,并指向现有的一个名称为VideoQueue队列
MessageQueue MQ &＃61; new MessageQueue(&＃64;".\\private$\\MsgQueue");
//MQ.Send("消息测试", "测试消息");
System.Messaging.Message message &＃61; new System.Messaging.Message();
message.Label &＃61; "消息lable";
message.Body &＃61; "消息body";
MQ.Send(message);
Response.Write("成功发送消息&＃xff0c;" &＃43; DateTime.Now &＃43; "
");

private void receiveSimpleMsg()

MessageQueue MQ &＃61; new MessageQueue(&＃64;".\\private$\\MsgQueue");
//调用MessageQueue的Receive方法接收消息
if (MQ.GetAllMessages().Length > 0)

System.Messaging.Message message &＃61; MQ.Receive(TimeSpan.FromSeconds(5));
if (message !&＃61; null)

//message.Formatter &＃61; new System.Messaging.XmlMessageFormatter(new string[] "Message.Bussiness.VideoPath,Message" );//消息类型转换
message.Formatter &＃61; new System.Messaging.XmlMessageFormatter(new Type[] typeof(string) );
Response.Write(string.Format("接收消息成功,lable:0,body:1,2
", message.Label, message.Body.ToString(), DateTime.Now));


else

Response.Write("没有消息了&＃xff01;
");


private void sendComplexMsg()

//实例化MessageQueue,并指向现有的一个名称为VideoQueue队列
MessageQueue MQ &＃61; new MessageQueue(&＃64;".\\private$\\MsgQueue");
//MQ.Send("消息测试", "测试消息");
System.Messaging.Message message &＃61; new System.Messaging.Message();
message.Label &＃61; "复杂消息lable";
message.Body &＃61; new MsgModel("1", "消息1");
MQ.Send(message);
Response.Write("成功发送消息&＃xff0c;"&＃43;DateTime.Now&＃43;"
");

private void receiveComplexMsg()

MessageQueue MQ &＃61; new MessageQueue(&＃64;".\\private$\\MsgQueue");
//调用MessageQueue的Receive方法接收消息
if (MQ.GetAllMessages().Length > 0)

System.Messaging.Message message &＃61; MQ.Receive(TimeSpan.FromSeconds(5));
if (message !&＃61; null)

message.Formatter &＃61; new System.Messaging.XmlMessageFormatter(new Type[] typeof(MsgModel) );//消息类型转换
MsgModel msg &＃61; (MsgModel)message.Body;
Response.Write(string.Format("接收消息成功,lable:0,body:1,2
", message.Label, msg, DateTime.Now));


else

Response.Write("没有消息了&＃xff01;
");


private T receiveComplexMsg()

MessageQueue MQ &＃61; new MessageQueue(&＃64;".\\private$\\MsgQueue");
//调用MessageQueue的Receive方法接收消息
if (MQ.GetAllMessages().Length > 0)

System.Messaging.Message message &＃61; MQ.Receive(TimeSpan.FromSeconds(5));
if (message !&＃61; null)

message.Formatter &＃61; new System.Messaging.XmlMessageFormatter(new Type[] typeof(T) );//消息类型转换
T msg &＃61; (T)message.Body;
return msg;


return default(T);

///