ESB：消息队列之小试牛刀

环境要求

• 安装MSMQ

示例代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using System.Messaging;

namespace MSMQStudy
{
    class Program
    {
        static void Main(string[] args)
        {
            string mqName = "test";

            CreaetPrivateMessageQueue(mqName);

            SendMessage(mqName, "hello,world");

            ReceiveMessage(mqName);
        }

        private static void CreaetPrivateMessageQueue(string mqName)
        {
            var path = CreateMessageQueuePath(mqName);

            if (!MessageQueue.Exists(path))
            {
                MessageQueue.Create(path);
            }
        }

        private static string CreateMessageQueuePath(string mqName)
        {
            return string.Format(".\\private$\\{0}", mqName);
        }

        private static void SendMessage(string mqName, string content)
        {
            var path = CreateMessageQueuePath(mqName);

            var mq = new MessageQueue(path);

            mq.Send(content);
        }

        private static void ReceiveMessage(string mqName)
        {
            var path = CreateMessageQueuePath(mqName);

            var mq = new MessageQueue(path);

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

            for (var message = mq.Receive(); message != null; message = mq.Receive())
            {
                Console.WriteLine(message.Body);
            }
        }
    }
}