使用VMware桥接模式组建局域网测试MSMQ（二）

public class MyNewQueue
    {
        static void Main(string[] args)
        {
            // Create a new instance of the class.
            MyNewQueue myNewQueue = new MyNewQueue();

            // Create new queues.
            CreateQueue(".\\private$\\myQueue");
            CreateQueue(".\\private$\\myAdministrationQueue");

            // Send messages to a queue.
            myNewQueue.SendMessage();
            Console.ReadLine();
        }

        //**************************************************
        // Creates a new queue.
        //**************************************************

        public static void CreateQueue(string queuePath)
        {
            try
            {
                if (!MessageQueue.Exists(queuePath))
                {
                    MessageQueue.Create(queuePath);
                }
                else
                {
                    Console.WriteLine(queuePath + " already exists.");
                }
            }
            catch (MessageQueueException e)
            {
                Console.WriteLine(e.Message);
            }

        }

        //**************************************************
        // Sends a string message to a queue.
        //**************************************************

        public void SendMessage()
        {

            // Connect to a queue on the local computer.
            MessageQueue myQueue = new MessageQueue($".\\private$\\myQueue");;
            myQueue.Label = "label1";
            // Create a new message.
            Message myMessage = new Message("Original Message");

            myMessage.AdministrationQueue = new MessageQueue(".\\private$\\myAdministrationQueue");
            myMessage.AcknowledgeType = AcknowledgeTypes.NegativeReceive;
            myMessage.UseDeadLetterQueue = true;
            myMessage.TimeToBeReceived = TimeSpan.FromSeconds(2);
            myMessage.Label = "label1";

            // Send the Order to the queue.
            Thread.Sleep(TimeSpan.FromSeconds(3));
            myQueue.Send(myMessage);

            return;
        }
    }

class ReceiveClient
    {
        static void Main(string[] args)
        {
            new ReceiveClient().ReceiveAckMessage();
            new ReceiveClient().ReceiveDeadLetterMessage();
            Console.ReadLine();
        }

        private void CreateQueue(string path)
        {
            try
            {
                if (!MessageQueue.Exists(path))
                {
                    MessageQueue.Create(path);
                }
                else
                {
                    Console.WriteLine("该队列已存在！");
                }
            }
            catch (MessageQueueException ex)
            {
                throw;
            }
        }

        private void ReceiveAckMessage()
        {

            MessageQueue myQueue = new MessageQueue(".\\private$\\myAdministrationQueue");
            myQueue.MessageReadPropertyFilter.CorrelationId = true;
            myQueue.MessageReadPropertyFilter.Acknowledgment = true;
            myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });


            MessageQueue mySendQueue = new MessageQueue(".\\private$\\myQueue");
            mySendQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            try
            {

                Message myMessage = myQueue.Receive(TimeSpan.FromSeconds(3));
                Console.WriteLine("_______________________________");
                Console.WriteLine("Ack Message body: " + myMessage.Body.ToString());
                Console.WriteLine("Ack Message Id: " + myMessage.Id);
                Console.WriteLine("Correlation Id: " + myMessage.CorrelationId);
                Console.WriteLine("Acknowledgment Type: " + myMessage.Acknowledgment.ToString());
                Console.WriteLine("_______________________________");

            }
            catch (MessageQueueException ex)
            {
                throw;
            }
        }

        private void ReceiveDeadLetterMessage()
        {
            MessageQueue myQueue = new MessageQueue("FormatName:Direct=os:.\\System$;DEADLETTER");
            myQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
            myQueue.MessageReadPropertyFilter.CorrelationId = true;
            try
            {
                Message myMessage = myQueue.Receive(TimeSpan.FromSeconds(3));
                Console.WriteLine("__________________________________");
                Console.WriteLine("Dead Letter Id: " + myMessage.Id);
                Console.WriteLine("Dead Letter Body: " + myMessage.Body.ToString());
                Console.WriteLine("__________________________________");
            }
            catch (MessageQueueException ex)
            {
                throw;
            }
        }
    }