using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Messaging;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using Msg = System.Messaging.Message;namespace MessageQueueDemo
{public partial class Form1 : Form{public Form1(){InitializeComponent();}private async Task<string> GetMessage(string labelId){List<Msg> msgs = new List<Msg>();//监听当前自己计算机上的私有队列MessageQueue msgQueue = new MessageQueue(@".\private$\myQueue");string result = null;Random r = new Random();await Task.Run(() =>{//使用该方法允许您动态删除Queuevar me = msgQueue.GetMessageEnumerator2();Msg tmpMsg = null;for (IEnumerator pointer = me; pointer.MoveNext();){//先返回当前的QueuetmpMsg = (Msg)pointer.Current;//如果该Label是符合当前文本框可以接受的Id，删除该Msgif (tmpMsg.Label == labelId){tmpMsg = me.RemoveCurrent();//模拟接收的时间不同Thread.Sleep(r.Next(100, 500));//必须指定每一个Msg的存储信息格式tmpMsg.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });msgs.Add(tmpMsg);//必须加上去，因为删除当前的Msg之后不使用“重置”，导致MoveNext为false。
                        me.Reset();}}if (msgs.Count > 0){result = string.Join(",", (from m in msgsselect m.Body.ToString()));}});return result;}private async void button1_Click(object sender, EventArgs e){//初始化已经创建的QueueMessageQueue msgQueue = new MessageQueue(@".\private$\myQueue");//模拟发送Msg（1和2交替发送）for (int i = 1; i < 11; i++){Msg message = new Msg(i % 2 == 0 ? "1" : "2", new XmlMessageFormatter(new Type[] { typeof(string) }));

                 //Send第一个参数：发送的消息对象；第二个参数：Label

                 msgQueue.Send(message, i % 2 == 0 ? "1" : "2");

            }//异步接收var content1 = await GetMessage("1");var content2 = await GetMessage("2");textBox2.Text = content1;textBox3.Text = content2;}}
}