使用C#封装一个MQ测试工具

using System;
using System.Messaging;

namespace MQTestTool
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("MQ Test Tool");
            Console.WriteLine("1. Create Queue");
            Console.WriteLine("2. Delete Queue");
            Console.WriteLine("3. Send Message");
            Console.WriteLine("4. Receive Message");
            Console.WriteLine("5. Get Queue Message Count");
            Console.WriteLine("6. Clear Queue");
            Console.WriteLine("0. Exit");

            while (true)
            {
                Console.Write("Enter your choice: ");
                if (!int.TryParse(Console.ReadLine(), out int choice))
                {
                    Console.WriteLine("Invalid input. Please try again.");
                    continue;
                }

                switch (choice)
                {
                    case 1:
                        CreateQueue();
                        break;
                    case 2:
                        DeleteQueue();
                        break;
                    case 3:
                        SendMessage();
                        break;
                    case 4:
                        ReceiveMessage();
                        break;
                    case 5:
                        GetMessageCount();
                        break;
                    case 6:
                        ClearQueue();
                        break;
                    case 0:
                        Console.WriteLine("Exiting...");
                        return;
                    default:
                        Console.WriteLine("Invalid choice. Please try again.");
                        break;
                }
            }
        }

        static void CreateQueue()
        {
            Console.Write("Enter Queue Path (e.g., .\\private$\\testQueue): ");
            string queuePath = Console.ReadLine();

            if (!MessageQueue.Exists(queuePath))
            {
                MessageQueue.Create(queuePath);
                Console.WriteLine($"Queue created at {queuePath}");
            }
            else
            {
                Console.WriteLine("Queue already exists.");
            }
        }

        static void DeleteQueue()
        {
            Console.Write("Enter Queue Path (e.g., .\\private$\\testQueue): ");
            string queuePath = Console.ReadLine();

            if (MessageQueue.Exists(queuePath))
            {
                MessageQueue.Delete(queuePath);
                Console.WriteLine($"Queue deleted at {queuePath}");
            }
            else
            {
                Console.WriteLine("Queue does not exist.");
            }
        }

        static void SendMessage()
        {
            Console.Write("Enter Queue Path (e.g., .\\private$\\testQueue): ");
            string queuePath = Console.ReadLine();
            Console.Write("Enter Message: ");
            string message = Console.ReadLine();

            using (MessageQueue queue = new MessageQueue(queuePath))
            {
                queue.Send(message);
                Console.WriteLine("Message sent successfully.");
            }
        }

        static void ReceiveMessage()
        {
            Console.Write("Enter Queue Path (e.g., .\\private$\\testQueue): ");
            string queuePath = Console.ReadLine();

            using (MessageQueue queue = new MessageQueue(queuePath))
            {
                if (queue.GetAllMessages().Length > 0)
                {
                    Message receivedMessage = queue.Receive();
                    Console.WriteLine($"Received Message: {receivedMessage.Body}");
                }
                else
                {
                    Console.WriteLine("No messages in the queue.");
                }
            }
        }

        static void GetMessageCount()
        {
            Console.Write("Enter Queue Path (e.g., .\\private$\\testQueue): ");
            string queuePath = Console.ReadLine();

            using (MessageQueue queue = new MessageQueue(queuePath))
            {
                int messageCount = queue.GetAllMessages().Length;
                Console.WriteLine($"Message Count: {messageCount}");
            }
        }

        static void ClearQueue()
        {
            Console.Write("Enter Queue Path (e.g., .\\private$\\testQueue): ");
            string queuePath = Console.ReadLine();

            using (MessageQueue queue = new MessageQueue(queuePath))
            {
                queue.Purge();
                Console.WriteLine("Queue cleared successfully.");
            }
        }
    }
}

MQ Test Tool
1. Create Queue
2. Delete Queue
3. Send Message
4. Receive Message
5. Get Queue Message Count
6. Clear Queue
0. Exit
Enter your choice: 1
Enter Queue Path (e.g., .\private$\testQueue): .\private$\testQueue
Queue created at .\private$\testQueue