在 C# 中使用 MSMQ 验证异常队列

Question

我是 Windows Server 中 Microsoft 消息队列的新手，如果 EmployeeID 为 NULL，我需要推送。

Employee 模型类是

public class Employee
{
    public string EmployeeID { get; set; }
    public string EmployeeName { get; set; }
}

public void ValidationProcess(Employee emp)
{
    if((emp != null) || (emp.EmployeeID == null))
    {
       // Push into Validation Exception Queue using MSMQ
    }
}

一旦数据被推入验证异常队列，它应该由单独的进程处理。进程需要每 1 小时启动一次，它应该调用以下方法

public void ValidationExceptionProcess(object obj)
{
    // Some Inner Process

    // Log the Error
}

请指导我如何创建和处理它。

Answer 1

第一步： 在服务器/PC 上安装 MSMQ 作为 Windows 功能

然后：
- 如果队列不存在，则创建队列
- 异步推送队列中的消息
有用guide

从 msmq 推送和检索消息的代码示例：

public class ExceptionMSMQ
    {
        private static readonly string description = "Example description";
        private static readonly string path = @".\Private$\myqueue";
        private static MessageQueue exceptionQueue;
        public static MessageQueue ExceptionQueue
        {
            get
            {
                if (exceptionQueue == null)
                {
                    try
                    {
                        if (MessageQueue.Exists(path))
                        {
                            exceptionQueue = new MessageQueue(path);
                            exceptionQueue.Label = description;
                        }
                        else
                        {
                            MessageQueue.Create(path);
                            exceptionQueue = new MessageQueue(path);
                            exceptionQueue.Label = description;
                        }
                    }
                    catch
                    {
                        throw;
                    }
                    finally
                    {
                        exceptionQueue.Dispose();
                    }
                }
                return exceptionQueue;
            }
        }

        public static void PushMessage(string message)
        {
            ExceptionQueue.Send(message);
        }

        private static List<string> RetrieveMessages()
        {
            List<string> messages = new List<string>();
            using (ExceptionQueue)
            {
                System.Messaging.Message[] queueMessages = ExceptionQueue.GetAllMessages();
                foreach (System.Messaging.Message message in queueMessages)
                {
                    message.Formatter = new XmlMessageFormatter(
                    new String[] { "System.String, mscorlib" });
                    string msg = message.Body.ToString();
                    messages.Add(msg);
                }
            }
            return messages;
        }

        public static void Main(string[] args)
        {
            ExceptionMSMQ.PushMessage("my exception string");

        }
    }

另一种广泛使用的方法是使用开箱即用的记录器，它已经包含此功能，如 Enterprise Library 或 NLog，它们提供了简单的接口来执行此操作。

对于检索消息，我会推荐一个单独的 Windows 服务，它会定期读取消息并处理它们。这里给出了一个很好的例子：Windows service with timer

更新： Windows 服务示例：

MSMQConsumerService.cs

public partial class MSMQConsumerService : ServiceBase
{
    private System.Timers.Timer timer;

    public MSMQConsumerService()
    {
        InitializeComponent();
    }

    protected override void OnStart(string[] args)
    {
        this.timer = new System.Timers.Timer(30000D);  // 30000 milliseconds = 30 seconds
        this.timer.AutoReset = true;
        this.timer.Elapsed += new System.Timers.ElapsedEventHandler(this.ProcessQueueMessages);
        this.timer.Start();
    }

    protected override void OnStop()
    {
        this.timer.Stop();
        this.timer = null;
    }

    private void ProcessQueueMessages(object sender, System.Timers.ElapsedEventArgs e)
    {
        MessageProcessor.StartProcessing();
    }

}

和 MessageProcessor.cs

public class MessageProcessor
    {
        public static void StartProcessing()
        {
            List<string> messages = ExceptionMSMQ.RetrieveMessages();
            foreach(string message in messages)
            {
                //write message in database
            }
        }
    }