手写MSMQ微软消息队列收发工具类

using System;
using System.Messaging;
namespace MSMQTool
{
    public class MsmqUtils
    {
        // 发送消息到指定队列
        public static void SendMessage(string queuePath, string message)
        {
            if (!MessageQueue.Exists(queuePath))
            {
                MessageQueue.Create(queuePath);
            }
            using (MessageQueue queue = new MessageQueue(queuePath))
            {
                queue.Send(message);
            }
        }
        // 从指定队列接收消息
        public static string ReceiveMessage(string queuePath)
        {
            if (!MessageQueue.Exists(queuePath))
            {
                return null;
            }
            using (MessageQueue queue = new MessageQueue(queuePath))
            {
                using (Message msg = queue.Receive())
                {
                    msg.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
                    return (string)msg.Body;
                }
            }
        }
    }
}

class Program
{
    static void Main()
    {
        string queuePath = @".\private$\MyQueue";
        MsmqUtils.SendMessage(queuePath, "Hello, MSMQ!");
        string receivedMessage = MsmqUtils.ReceiveMessage(queuePath);
        Console.WriteLine(receivedMessage);
    }
}