基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 5 元　

支付宝支付

微信支付

   源码介绍

---

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

            }
        }
    }
}