C# MessageQueue 消息队列 实例源码下载

MessageQueue

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;

using System.Messaging;
using System.Configuration;

namespace MessageStudy
{
    public partial class Form1 : Form
    {
        /// <summary>
        /// 定义消息路径
        /// </summary>
        public const string sMessageConnectionString = @".\Private$\Demo";
        public Form1()
        {
            InitializeComponent();
            txtQueue.Text = ConfigurationManager.AppSettings["path"].ToString();
        }

        /// <summary>
        /// 发送
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnSend_Click(object sender, EventArgs e)
        {
            if (txbSend.Text.Trim() == "")
            {
                MessageBox.Show("请输入要发送的message!");
                txbSend.Focus();
                return;
            }


            //完整队列格式为：  计算机名\private$\队列名称 (专用队列)
            MessageQueue mqQue = new MessageQueue(txtQueue.Text.Trim());
            mqQue.MessageReadPropertyFilter.SetAll();

            System.Messaging.Message msg = new System.Messaging.Message();
            //消息主体
            msg.Body = txbSend.Text.Trim()   " "   DateTime.Now.ToString();
            //用描述设置ID
            msg.Label = txbMessageID.Text;
            //将消息加入到发送队列
            msg.ResponseQueue = mqQue;
            msg.AttachSenderId = true;

            msg.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });

            try
            {   
                //发送
                mqQue.Send(msg);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message.ToString());
            }


        }

        /// <summary>
        /// 接收
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnReceive_Click(object sender, EventArgs e)
        {
           
            MessageQueue mqQue = null;
            if (MessageQueue.Exists(sMessageConnectionString))
            {
                mqQue = new System.Messaging.MessageQueue(sMessageConnectionString);
            }
            //得到所有消息
            System.Messaging.Message[] messages = mqQue.GetAllMessages();
            if (messages.Length > 0)
            {
                foreach (System.Messaging.Message msgVal in messages)
                {
                    //根据ID得到消息(这个ID放在消息的label中)
                    if (msgVal.Label==txbReceiveMsgID.Text)
                    {
                        //同步接收，直到得到一条消息为止，如果消息队列为空，会一直阻塞
                        System.Messaging.Message msg = mqQue.Receive();
                        msg.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] { typeof(string) });
                        //消息的内容
                        txbReceive.Text = "["   DateTime.Now.ToString()   "]: "   msg.Body.ToString();
                        break;
                    }
                    else
                    {
                        txbReceiveMsgID.Text = "没有找到指定ID的Message";
                    }
                }
            }
        }


        /// <summary>
        /// 清除消息队列
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btnClear_Click(object sender, EventArgs e)
        {
            MessageQueue mqQue = null;
            if (MessageQueue.Exists(sMessageConnectionString))
            {
                //清除所有消息
                mqQue = new System.Messaging.MessageQueue(sMessageConnectionString);
                mqQue.Purge();

            }
        }
    }
}