是否可以将 GetAllMessages 和 Purge 作为事务处理

Question

在开始处理队列中的消息之前，我需要收集所有“旧”消息并处理它们。之后我进入读取/处理循环。

GetAllMessages 将返回消息数组，但是它不会将它们从队列中删除。 Purge 将从队列中删除所有消息。我需要将两者作为交易来完成。这可能吗？

Answer 1

听起来您需要在（重新）启动服务后处理剩余消息。

我实现的解决方案只是使用可配置的接收超时来控制处理循环，因此您的服务不需要担心队列的状态 - 它将处理那里的任何内容。

这是一个简单的 C# 示例，

...
Message msg;
MessageQueueTransaction currentTransaction = new MessageQueueTransaction();
TimeSpan receiveTimeOut = new TimeSpan(0, 0, 30);

while (MyService.IsRunning)
{
    try
    {
        currentTransaction.Begin();
        msg = this.sourceQueue.Receive(receiveTimeOut, currentTransaction);

        // process your message here

        currentTransaction.Commit();
    }
    catch(MessageQueueException mqex)
    {
        switch(mqex.MessageQueueErrorCode)
        {
            case MessageQueueErrorCode.IOTimeout :
                // That's okay ... try again, maybe there's a new message then
                break;

            default :
                // That's not okay ... abort transaction
                currentTransaction.Abort();
        }
    }
}

我计划将超时延长为动态，因为每次超时异常抛出时都会增加超时，并在处理消息后立即重置它。

使用 MSMQ 编程最佳实践中给出了简短的介绍，尽管它没有不完全支持我提出的解决方案。

---

进一步挖掘后，我发现了 一个建议 MSMQ 激活的答案，但我自己还没有尝试过。