.net - 如何正确清理 MSMQ 监听器？

Question

我有使用异步 API 支持从 MSMQ 读取的代码，即使用 BeginReceive()、EndReceive() 和 ReceivedCompleted 事件。基本模式是(取自MessageQueue.ReceiveCompleted Event ...

void StartListening()
{
   _msgQ.ReceiveCompleted += ReceiveCompletedEventHandler(FooReceiveCompleted);
   _msgQ.BeginReceive();
}

void FooReceiveCompleted(Object source, ReceiveCompletedEventArgs asyncResult)
{
   Message msg = _msgQ.EndReceive();
   // Do stuff with message.

   // Set up listening for next message.
   _msgQ.BeginReceive();
}

void StopListening()
{
   _msgQ.Close();
}

我能看到的问题是，总是有一个待处理的 BeginReceive() 正在等待新消息，并且通过阅读 .Net 文档，似乎没有官方/推荐的方法来清理它以停止听。

如果我在没有要接收的消息的情况下调用 EndReceive()，那么调用将阻塞，直到有消息可用。或者，除非将 EnableConnectionCache 设置为 false，否则 Close() 似乎不会清除 MSMQ 上的基础句柄(因此也不会清除挂起的监听器)，否则句柄将被缓存并且不会在关闭调用时被清除。我可以做到这一点，但理想情况下我想使用缓存。

我能看到的唯一其他选项是启用缓存，然后调用静态方法 MessageQueue.ClearConnectionCache()，这可能是应用程序域范围内的，因此会影响与我试图关闭的队列无关的队列。

附录:其他选项(来自 MessageQueue.Close() )...

Close does not always free the read and write handles to a queue, because they might be shared. You can take any of the following steps to ensure that Close frees the read and write handles to a queue:

Create the MessageQueue with exclusive access. To do so, call the MessageQueue(String, Boolean) or MessageQueue(String, Boolean, Boolean) constructor, and set the sharedModeDenyReceive parameter to true.

Create the MessageQueue with connection caching disabled. To do so, call the MessageQueue(String, Boolean, Boolean) constructor and set the enableConnectionCache parameter to false.

Disable connection caching. To do so, set the EnableConnectionCache property to false.

因此，我对文档中的 API 的第一印象是您无法正确终止队列(使用 BeginReceive/EndReceive 时)，除非未使用缓存或您对队列具有独占访问权。

Answer 1

问题的症结在于 MessageQueue.ReceiveCompleted Event 的示例 C#在 MSDN 上使用不带参数的 BeginReceive()。这是一个立即返回给调用者的异步调用，但它会导致一个未完成的异步操作，该操作可能具有很长的生命周期。

当我们尝试在 MessageQueue 上调用 Close() 时，这个未完成的异步操作会阻止 MessageQueue 的正确释放。

一种解决方案是使用 BeginReceive(Timeout)；这将导致 ReceiveCompleted 事件即使在没有消息时也会触发，此时我们可以测试一个标志以查看是否正在请求关闭并允许清理正常进行。也就是说，关闭消息队列的外部请求必须等待，例如一个 WaitHandle，ReceiveCompleted 事件将发出信号。因此，该模式在几秒(理想情况下为 1 或 2 秒)的短 BeginReceive() 超时时效果最佳。