.Net訊息佇列的使用
阿新 • • 發佈:2019-02-20
.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); } } }