c# - MessageQueue 被多次处置

Question

我在其他帖子上看到过这个错误，但不是针对这种情况。

我有两个类使用 MessageQueue 做同样的事情。因此，我将队列的创建和处理抽象为一个辅助类。我遇到了这个错误，而且我看不出如何多次处理队列。

可以在方法“MsmqHelper.DisposeQueue(MessageQueue)”中多次释放对象“messageQueue”

在其中一个类中，队列是这样使用的:

private MessageQueue _messageQueue;

然后，在类的构造函数中:

this._messageQueue = MsmqHelper.InitializeQueue();

这并不重要，但为了完整起见，这里是使用队列的地方:

this._messageQueue.Send(workflowCreated);

这里是 Dispose 方法:

public void Dispose()
{
    Dispose(true);
    GC.SuppressFinalize(this);
}

private void Dispose(bool disposing)
{
    if (disposing == false) { return; }

    MsmqHelper.DisposeQueue(this._messageQueue);
}

这是实际调用 Dispose() 的辅助类中的代码:

public static void DisposeQueue(MessageQueue messageQueue)
{
    if (messageQueue != null)
    {
        messageQueue.Close();
        messageQueue.Dispose();
        messageQueue = null;
    }
}

在这种情况下，哪里有可能多次处理队列？

** 编辑 **

我认为在下面的对话中添加我的评论会很好。这是一个很好的总结，以及公认的答案:

我想我现在明白了。 messageQueue 方法参数与对象的原始 (this._messageQueue) 引用无关。因此，检查 messageQueue 是否为 null 并将其设置为 null 并没有好处。即使在被处置之后，调用者仍然可以传入其变量 (this._messageQueue)。因此，能够被多次处置。

顺便说一句，即使在调用方法中将调用者的变量 (this._messageQueue) 设置为 null，也无济于事。该问题仅存在于 MsmqHelper.DisposeQueue() 中。所以答案是通过 ref 或根本不调用 DisposeQueue() 并在调用方法中完成所有操作。

** 编辑 2 **

尝试之后，我得到了同样的错误。我就是不明白。

public static void DisposeQueue(ref MessageQueue messageQueue)
{
    if (messageQueue == null) { return; }

    messageQueue.Close();
    messageQueue.Dispose();
    messageQueue = null;
}

** 编辑 3 -- 错误？ **

我开始认为这可能是一个错误。如果我评论 messageQueue.Dispose()，错误就会消失。但是，我可以在调用 方法中同时调用messageQueue.Close() 和messageQueue.Dispose()。去搞清楚。我想我只是要从调用方法进行这些相同的调用，或者只调用 Close() 或 Dispose() 而不是两者。

Answer 1

关闭会释放 MessageQueue 对象的所有资源。查看documentation here .该错误极有可能是在CA中产生的，因为它看到Close的执行路径也调用了Dispose。

来自文档:

    public  void ReceiveMessage()
    {
        // Connect to the a on the local computer.
        MessageQueue myQueue = new MessageQueue(".\\myQueue");

        // Set the formatter to indicate body contains an Order.
        myQueue.Formatter = new XmlMessageFormatter(new Type[]
            {typeof(String)});

        try
        {
            // Receive and format the message. 
            Message myMessage1 = myQueue.Receive();
            Message myMessage2 = myQueue.Receive();
        }

        catch (MessageQueueException)
        {
            // Handle sources of any MessageQueueException.
        }

        // Catch other exceptions as necessary.

        finally
        {
            // Free resources.
            myQueue.Close();
        }

        return;
    }

Close 显然会释放资源，但如果资源尚未被收集，将允许组件重新获取它们。打开 MessageQueue 对象，使用它，然后在同一个调用中关闭它可能更谨慎，而不是打开它一段时间后再关闭它，因为连接缓存消除了在重复调用中打开 MessageQueue 的开销。

*更新*看起来 CA 对成员字段的 CA2202 处理方式与将一次性对象传递给方法不同，即使该方法对类是私有(private)的。无论如何，根据文档，您只需要调用 Close() 或 Dispose() 而不是两者。但是，我建议更改您的设计，以便您在消息操作的范围内创建、使用然后关闭 MessageQueue 对象，就像上面文档示例中演示的示例一样。