WCF分布式开发之MSMQ消息队列

    if (!MessageQueue.Exists(@".\MYFIRSTMSMQ"))
    {
        using (MessageQueue mq = MessageQueue.Create(@".\MYFIRSTMSMQ"))//创建一个公共消息队列
        {
            mq.Label = "myFirstMSMQ";
            Console.WriteLine("已经创建了一个公共队列{0}", mq.Label);
            Console.WriteLine("公共队列{0}的路径为{1}", mq.Label, mq.Path);
            mq.Send("MSMQ 消息", "今天又学到个有趣的知识");
        }
    }
    foreach (MessageQueue mq in MessageQueue.GetPublicQueues())//获取所有公共队列，发送消息
    {
        mq.Send("发送公共消息队列" + DateTime.Now.ToLongTimeString(), "今天又学到个有趣的知识");
        Console.WriteLine("公有消息已经送到{0}", mq.Path);
    }

    if (!MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))
    {
        using (MessageQueue mq = MessageQueue.Create(@".\Private$\MYFIRSTMSMQ"))//创建一个私有消息队列
        {
            mq.Label = "myFirstPrivateMSMQ";
            Console.WriteLine("已经创建了一个私有队列{0}", mq.Label);
            Console.WriteLine("私有队列{0}的路径为{1}", mq.Label, mq.Path);
            mq.Send("MSMQ 私有队列消息" + "今天又学到个有趣的知识");
        }
    }

    if (MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))
    {
        MessageQueue mq = new MessageQueue(@".\Private$\MYFIRSTMSMQ");//找到私有队列，发送消息

        mq.Send("发送私有消息队列" + DateTime.Now.ToLongTimeString() + "今天又学到个有趣的知识");
        Console.WriteLine("私有消息已经送到{0}", mq.Path);
    }

if (MessageQueue.Exists(@".\MYFIRSTMSMQ"))// 获取公共消息队列
{
    using (MessageQueue mq = new MessageQueue(@".\MYFIRSTMSMQ"))//创建消息队列对象
    {
        mq.Formatter = new XmlMessageFormatter(new string[] { "System.String" });//设置消息队列的格式化器，还有BinaryMessageFormatter,ActiveXMessageFormatter等
        foreach (Message msg in mq.GetAllMessages())
        {
            Console.WriteLine("接收到的消息是:{0}", msg.Body);
        }
        Message firstmsg = mq.Receive();
        Console.WriteLine("收到的第一条消息为：{0}", firstmsg.Body);
    }
}

if (MessageQueue.Exists(@".\Private$\MYFIRSTMSMQ"))// 获取私有消息队列
{
    using (MessageQueue mq = new MessageQueue(@".\Private$\MYFIRSTMSMQ"))
    {
        //....
    }
}