//创建消息队列 并发送消息到队列

            try

            {

                //连接到本地新创建的队列

                MessageQueue myQueue = new MessageQueue(".\\private$\\test2");

                //创建一个消息

                System.Messaging.Message myMessage = new System.Messaging.Message();

                //给消息体赋值

                myMessage.Body = "你好我是消息体";

                myMessage.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });

                //发送消息到队列中（创建队列时勾选了事务性之后 不能直接使用 public void Send(object obj) 这个方法 因为其不支持事务）

                // 我要使用下面这个支持事务的发送方法

                myQueue.Send(myMessage,System.Messaging.MessageQueueTransactionType.Single);

            }

            catch (ArgumentException ex)

            {

                Console.WriteLine(ex.Message);

            }

            //创建一个任务 让其不断的在接收消息队列发出的消息

            Task t = Task.Factory.StartNew(() => {

                while (true)

                {

                    //创建队列 要跟发消息的队列同一个名称

                    MessageQueue mq = new MessageQueue(@".\private$\test2");

                    // 如果不用多线程就会阻塞在Receive

                    System.Messaging.Message m = mq.Receive();

                    //定义内容格式

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

                    //接收到消息后 回去更新主线程的UI界面

                    Action<String> AsyncUIDelegate = delegate (string n)

                    {

                        this.ReceiveText2.Text = n; //对ui的操作

                    };//定义一个委托

                    this.ReceiveText2.Invoke(AsyncUIDelegate, new object[] { m.Body.ToString() });

                }

            });