消息隊列的簡單使用

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

 

private void sendSimpleMsg()
    {
        //實例化MessageQueue,並指向現有的一個名稱爲VideoQueue隊列  
        MessageQueue MQ = new MessageQueue(@".\private$\MsgQueue");
        //MQ.Send("消息測試", "測試消息");  
        System.Messaging.Message message = new System.Messaging.Message();
        message.Label = name.Text+"的消息";
        message.Body = txtmessage.Text;
        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/>");
        }
    }
    #region
    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/>");
    }
    #endregion

    #region
    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/>");
        }
    }
    #endregion
    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);
    }

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