MessageQueue.BeginReceive是如何工作的以及如何正确使用它？

Question

我目前有一个后台线程。在这个线程中是一个无限循环。

此循环偶尔会更新数据库中的某些值，然后在 MessageQueue 上侦听 1 秒（使用 queue.Receive(TimeSpan.FromSeconds(1)) ）。

只要没有消息传入，此调用就会在内部抛出 MessageQueueException（超时），该异常被捕获，然后循环继续。如果有消息，调用通常会返回并处理该消息，然后继续循环。

这会导致很多第一次机会异常（每秒一次，除非有消息要处理），并且这会垃圾邮件调试输出，并且当我忘记排除 MessageQueueExceptions 时也会中断调试器。

那么如何正确地完成 MessageQueue 的异步处理，同时仍然确保只要我的应用程序运行，队列就会受到监视并且数据库也会偶尔更新。当然这里的线程不应该使用100%的CPU。

我只需要大局观或一些正确完成的异步处理的提示。

Answer 1

我建议不要在线程中循环，而是为 MessageQueue 的 ReceiveCompleted 事件注册委托，如下所述：

using System;
使用系统消息传递；

命名空间我的项目
{
///
/// 为示例提供容器类。
///
公共类 MyNewQueue
{

    //**************************************************
    // Provides an entry point into the application.
    //       
    // This example performs asynchronous receive operation
    // processing.
    //**************************************************

    public static void Main()
    {
        // Create an instance of MessageQueue. Set its formatter.
        MessageQueue myQueue = new MessageQueue(".\\myQueue");
        myQueue.Formatter = new XmlMessageFormatter(new Type[]
            {typeof(String)});

        // Add an event handler for the ReceiveCompleted event.
        myQueue.ReceiveCompleted += new 
            ReceiveCompletedEventHandler(MyReceiveCompleted);

        // Begin the asynchronous receive operation.
        myQueue.BeginReceive();

        // Do other work on the current thread.

        return;
    }


    //**************************************************
    // Provides an event handler for the ReceiveCompleted
    // event.
    //**************************************************

    private static void MyReceiveCompleted(Object source, 
        ReceiveCompletedEventArgs asyncResult)
    {
        // Connect to the queue.
        MessageQueue mq = (MessageQueue)source;

        // End the asynchronous Receive operation.
        Message m = mq.EndReceive(asyncResult.AsyncResult);

        // Display message information on the screen.
        Console.WriteLine("Message: " + (string)m.Body);

        // Restart the asynchronous Receive operation.
        mq.BeginReceive();

        return; 
    }
}

}

来源：https://learn.microsoft.com/en-us/dotnet/api/system.messaging.messagequeue.receivecompleted?view=netframework-4.7.2

Answer 2

您是否考虑过从 MessageEnumerator 返回a href="http://msdn.microsoft.com/en-us/library/system.messaging.messagequeue.getmessageenumerator2.aspx" rel="nofollow">MessageQueue.GetMessageEnumerator2 ？

• 您可以获取队列的动态内容，以便在迭代过程中检查消息并从队列中删除消息。
• 如果没有消息，那么 MoveNext() 将返回 false，并且您不需要捕获第一次机会异常。
• 如果在开始迭代后有新消息，那么它们将被迭代（如果它们是放在光标后面）。
• 如果光标之前有新消息，那么您只需重置迭代器或继续（如果您目前不需要优先级较低的消息）。

Answer 3

与杰米·迪克森的评论相反，这种情况是特殊的。请注意该方法及其参数的命名： BeginReceive(TimeSpan timeout)

如果该方法被命名为 BeginTryReceive，那么如果没有收到消息，那就完全正常了。将其命名为 BeginReceive（或 Receive，对于同步版本）意味着消息将进入队列。 TimeSpan 参数被命名为 timeout 也很重要，因为超时是异常的。超时意味着预期会得到响应，但没有给出响应，调用者选择停止等待并假设发生了错误。当您以 1 秒超时调用 BeginReceive/Receive 时，您是在声明，如果此时没有消息进入队列，则一定出现了问题，我们需要对其进行处理。

如果我理解您想要正确执行的操作，我实现此操作的方法是：

• 以非常大的超时调用 BeginReceive，或者如果我没有将空队列视为错误，则甚至没有超时。
• 将事件处理程序附加到 ReceiveCompleted 事件，该事件处理程序 1) 处理消息，2) 再次调用 BeginReceive。
• 我不会使用无限循环。当使用像 BeginReceive 这样的异步方法时，这既是不好的做法，也是完全多余的。
• 编辑：要放弃任何客户端都没有读取的队列，请让队列写入者查看该队列以确定它是否“死亡”。

编辑：我还有另一个建议。由于我不知道您申请的详细信息，我不知道它是否可行或合适。在我看来，您基本上是在客户端和服务器之间建立连接，并以消息队列作为通信通道。为什么这是“联系”？因为如果没有人在监听，队列将不会被写入。我想这就是联系。使用套接字或命名管道来传输消息不是更合适吗？这样，客户端在完成读取后只需关闭 Stream 对象，服务器就会立即收到通知。正如我所说，我不知道它是否适合你正在做的事情，但感觉这是一个更合适的沟通渠道。