1. 程式人生 > >.Net訊息佇列的使用

.Net訊息佇列的使用

.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);
        }
    }
}