MSMQ Receive（）方法超时

Question

我以前的原始问题是MSMQ Slow Queue Reading，但是我从中提出了更高的要求，现在认为我对这个问题的了解更加清楚了。

我的代码（实际上是我正在使用的开放源代码库的一部分）看起来像这样：

queue.Receive(TimeSpan.FromSeconds(10), MessageQueueTransactionType.Automatic);

正在使用Messaging.MessageQueue.Receive函数，并且队列是MessageQueue。问题如下。

以上代码行将以指定的超时时间（10秒）被调用。 Receive(...)功能是一种阻止功能，应该阻止直到消息到达队列时才返回。如果在超时之前未收到任何消息，它将在超时时返回。如果在调用函数时消息在队列中，它将立即返回该消息。

但是，正在发生的是正在调用Receive(...)函数，因为队列中没有消息，因此正在等待新消息进入。当新消息进入时（超时之前），它未检测到此新消息并继续等待。最终会遇到超时问题，此时代码将继续并再次调用Receive(...)，在此处拾取消息并进行处理。

现在，仅在数天/周后才会出现此问题。通过删除并重新创建队列，我可以使它再次正常工作。它发生在不同的计算机和不同的队列上。因此，似乎有一些东西正在建立，直到某个时候它破坏了Receive(...)函数使用的触发/通知功能。

我已经检查了很多不同的东西，并且一切看起来都很正常，并且与正常工作的队列没有什么不同。有足够的磁盘空间（13gig可用空间）和RAM（据我所知，大约1GB中有350MB可用空间）。我已经检查了所有与其他队列相同的注册表项，并且性能监视器未显示任何异常。我也运行过TMQ工具，看不到任何明显的错误。

我在所有计算机上都使用Windows XP，并且它们都安装了Service Pack 3。我没有向队列发送大量消息，最多每2秒发送1条消息，但通常比这少很多。消息也很小，并且没有接近4MB的限制。

我唯一注意到的是C：\ WINDOWS \ system32 \ msmq \ storage中的p0000001.mq和r0000067.mq文件都为4,096KB，但是它们在其他计算机上的大小也没有出现此问题。 。该问题不会一次出现在计算机上的每个队列上，因为我可以在计算机上重新创建1个问题队列，而其他队列仍然遇到该问题。

我对MSMQ的经验不是很丰富，所以如果您发布可能要检查的内容，请说明如何检查它们，或者在哪里可以找到您所谈论内容的更多详细信息。

当前情况是：

• 计算机A-4个正常队列
• 计算机B-2个队列遇到问题，1个队列正常
• ComputerC-2个队列遇到问题
• ComputerD-1个队列正常
• 计算机E-2个正常队列

因此，我有大量要比较和测试的计算机/队列。

Answer 1

有什么特殊原因，您没有使用事件处理程序来监听队列？ System.Messaging库允许您将处理程序附加到队列，而不是（如果我了解您的正确操作）将接收器循环每10秒。尝试这样的事情：

class MSMQListener
{
    public void StartListening(string queuePath)
    {
        MessageQueue msQueue = new MessageQueue(queuePath);
        msQueue.ReceiveCompleted += QueueMessageReceived;
        msQueue.BeginReceive();
    }

    private void QueueMessageReceived(object source, ReceiveCompletedEventArgs args)
    {
        MessageQueue msQueue = (MessageQueue)source;

        //once a message is received, stop receiving
        Message msMessage = null;
        msMessage = msQueue.EndReceive(args.AsyncResult);

        //do something with the message

        //begin receiving again
        msQueue.BeginReceive();
    }
}

Answer 2

我们也在使用NServiceBus，并且在我们的网络中也有类似的问题。

[基本上，MSMQ使用带有两阶段提交的UDP。收到消息后，必须对其进行确认。在未确认之前，由于尚未完成接收事务，因此无法在客户端上接收它。

这是由我们在不同时期的不同事物造成的：

• 曾经，这是由于分布式事务处理协调器由于防火墙配置错误而无法在机器之间进行通信
• 另一时间，我们使用的克隆的虚拟机没有sysprep，这使得内部MSMQ id不唯一，并使它接收到一台计算机的消息，并确认另一台计算机的消息。最终，MSMQ弄清楚了，但要花相当长的时间。

Answer 3

尝试一下

公共消息接收（TimeSpan超时，光标游标）

重载功能。

要获取MessageQueue的游标，请对该队列调用CreateCursor方法。

当需要读取不在队列最前面的消息时，游标与诸如Peek（TimeSpan，Cursor，PeekAction）和Receive（TimeSpan，Cursor）之类的方法一起使用。这包括同步或异步读取消息。不需要使用游标仅读取队列中的第一条消息。

在事务中读取消息时，如果事务中止，消息队列不会回滚光标移动。例如，假设有一个队列，其中包含两个消息A1和A2。如果您在事务中删除消息A1，则消息队列会将光标移动到消息A2。但是，如果由于某种原因导致事务中止，则将消息A1重新插入到队列中，但是光标仍然指向消息A2。

要关闭光标，请调用关闭。

Answer 4

如果您要使用完全同步且没有事件的内容，则可以测试此方法

public object Receive(string path, int millisecondsTimeout)
{
    var mq = new System.Messaging.MessageQueue(path);
    var asyncResult = mq.BeginReceive();
    var handles = new System.Threading.WaitHandle[] { asyncResult.AsyncWaitHandle };
    var index = System.Threading.WaitHandle.WaitAny(handles, millisecondsTimeout);
    if (index == 258) // Timeout
    {
        mq.Close();
        return null;
    }
    var result = mq.EndReceive(asyncResult);
    return result;
}