訊息佇列：在訊息傳遞的過程中暫時儲存訊息的容器，充當傳送者和接受者的中間人

訊息佇列的基本操作

    using System;
    using System.Messaging;

    namespace MQ
    {
        class MQHelper
        {
            /// <summary>
            /// 建立一個訊息佇列
            /// </summary>
            /// <param name="name">訊息佇列的名稱</param>
            ///
 
 <returns>是否建立成功</returns>
            public static bool CreateNewMQ(string name)
            {
                if (!MessageQueue.Exists(".\\private$\\" + name))
                {

                    MessageQueue mq = MessageQueue.Create(".\\private$\\" + name);
                    mq.Label 
 
= "private$\\" + name;
                    return true;
                }
                else
                {
                    return false;
                }
            }
            /// <summary>
            /// 刪除一個訊息佇列
            /// </summary>
            /// <param name="name">訊息佇列的名稱
 
</param>
            /// <returns>是否建立成功</returns>
            public static bool DeleteNewMQ(string name)
            {
                if (!MessageQueue.Exists(".\\private$\\" + name))
                {
                    MessageQueue.Delete(".\\private$\\" + name);
                    return true;
                }
                else
                {
                    return false;
                }
            }
            /// <summary>
            /// 傳送訊息到指定訊息佇列
            /// </summary>
            /// <param name="mq_name">訊息佇列名稱</param>
            /// <param name="msg_lable">訊息頭</param>
            /// <param name="msg_body">訊息體</param>
            public static void SendMessage(string mq_name, string msg_lable, string msg_body)
            {
                MessageQueue mq = new MessageQueue(@".\private$\" + mq_name);
                Message message = new Message();
                message.Label = msg_lable;
                message.Body = msg_body;
                mq.Send(message);
            }
            /// <summary>
            /// 從指定訊息佇列獲取第一條訊息
            /// </summary>
            /// <param name="mq_name">訊息佇列名稱</param>
            /// <returns>Message</returns>
            public static Message ReceiveMessage(string mq_name)
            {
                MessageQueue mq = new MessageQueue(@".\private$\" + mq_name);
                if (mq.GetAllMessages().Length > 0)
                {
                    Message message = mq.Receive();
                    if (message != null)
                    {
                        message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
                    }
                    return message;
                }
                else
                {
                    return null;
                }
            }
        }
    }

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