消息队列的简单处理

private void 发送ToolStripMenuItem_Click(object sender, EventArgs e)
        {
            System.Messaging.MessageQueue queue;
            if (MessageQueue.Exists(".\\Private$\\MSMQDemo"))

                queue = new MessageQueue(".\\Private$\\MSMQDemo");

            else

                queue = MessageQueue.Create(".\\Private$\\MSMQDemo");

       // Open queue

        queue = new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");

 

       // Create message

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

       message.Body = "hello";

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

 

       // Put message into queue

       queue.Send(message);

            

        }

        private void 接收ToolStripMenuItem_Click(object sender, EventArgs e)
        {
            // Open queue

            System.Messaging.MessageQueue queue = new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");

            // Receive message, 同步的Receive方法阻塞当前执行线程，直到一个message可以得到 

            System.Messaging.Message message = queue.Receive();

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

            //txtReceiveMessage.Text = message.Body.ToString();
            MessageBox.Show(message.Body.ToString());

        }