MessageQueue Disposed More Than Once

Question

Tôi đã nhìn thấy lỗi này trên các bài đăng khác, nhưng không phải cho tình huống chính xác này.

Tôi có hai lớp học thực hiện tương tự với MessageQueue. Do đó, tôi tóm tắt việc tạo và xử lý hàng đợi cho một lớp trợ giúp. Tôi nhận được lỗi này và tôi không thể xem hàng đợi có thể được xử lý nhiều lần như thế nào.

Object 'MessageQueue' có thể được xử lý nhiều hơn một lần trong phương pháp 'MsmqHelper.DisposeQueue (MessageQueue)'

Trong một trong những lớp học, đây là cách hàng đợi được sử dụng:

private MessageQueue _messageQueue; 

Sau đó, , trong constructor của lớp:

this._messageQueue = MsmqHelper.InitializeQueue(); 

Không phải là nó thực sự quan trọng, nhưng đối với sự hoàn chỉnh, đây là nơi mà các hàng đợi được sử dụng:

this._messageQueue.Send(workflowCreated); 

Và đây là những phương pháp Vứt bỏ:

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

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

    MsmqHelper.DisposeQueue(this._messageQueue); 
} 

Và đây là đoạn code trong lớp helper mà thực sự gọi Dispose():

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

ở đâu nó có thể cho hàng đợi được xử lý nhiều hơn một lần trong tình huống này?

** Chỉnh sửa **

Tôi nghĩ sẽ thật thú vị khi thêm nhận xét của tôi, trong cuộc trò chuyện bên dưới, tại đây. Đó là một bản tóm tắt tốt, cùng với câu trả lời được chấp nhận:

Tôi nghĩ mình đã hiểu ngay bây giờ. Tham số phương thức messageQueue không liên quan gì đến tham chiếu gốc (this._messageQueue) cho đối tượng. Vì vậy, kiểm tra messageQueue cho null, và thiết lập nó để null, không tốt. Người gọi vẫn có thể vượt qua trong biến của nó (this._messageQueue) ngay cả sau khi được xử lý. Do đó, có thể được xử lý nhiều hơn một lần.

Nhân tiện, thậm chí đặt biến của người gọi (this._messageQueue) thành null, trong phương thức gọi, không được trợ giúp. Vấn đề tồn tại chỉ trong MsmqHelper.DisposeQueue(). Vì vậy, câu trả lời là để vượt qua bởi ref hoặc đơn giản là không gọi DisposeQueue() và làm tất cả trong phương thức gọi.

** Chỉnh sửa 2 **

Sau khi thử điều này, tôi nhận được lỗi tương tự. Tôi chỉ đơn giản là không nhận được nó.

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

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

** Chỉnh sửa 3 - Lỗi? **

Tôi bắt đầu nghĩ rằng đây có thể là lỗi. Nếu tôi nhận xét messageQueue.Dispose(), lỗi sẽ biến mất. TUY NHIÊN, tôi có thể tin nhắn cuộc gọiQueue.Close() và messageQueue.Dispose() cùng nhau trong phương thức gọi. Đi con số. Tôi nghĩ rằng tôi sẽ thực hiện các cuộc gọi tương tự từ các phương thức gọi điện thoại hoặc chỉ gọi Close() hoặc Dispose() thay vì cả hai.

Answer 1

Đóng giải phóng mọi nguồn lực của đối tượng MessageQueue. Xem documentation here. Lỗi này rất có thể được tạo trong CA vì nó thấy rằng đường dẫn thực hiện của Close cũng gọi Dispose.

Từ các tài liệu:

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; 
    } 

Đóng dường như sẽ giải phóng tài nguyên nhưng sẽ cho phép các thành phần để reacquire họ nếu họ đã không được thu thập. Có thể thận trọng hơn khi mở đối tượng MessageQueue, sử dụng nó và sau đó đóng nó trong cùng một cuộc gọi thay vì mở nó trong một khoảng thời gian và đóng nó sau đó vì kết nối bộ nhớ đệm loại bỏ phí mở MessageQueue trong các cuộc gọi lặp lại.

* CẬP NHẬT * Dường như CA đối xử với CA2202 khác nhau cho các trường thành viên so với đi qua các đối tượng dùng một lần đến một phương pháp, thậm chí nếu phương pháp đó là tin tới lớp. Bất kể, theo tài liệu, bạn chỉ nên gọi Close() hoặc Dispose() nhưng không phải cả hai. Tuy nhiên, tôi khuyên bạn nên thay đổi thiết kế của mình để tạo, sử dụng và sau đó đóng đối tượng MessageQueue tất cả trong phạm vi hoạt động thư của bạn như ví dụ từ ví dụ tài liệu minh họa ở trên.

Answer 2

Có.Điều này có thể vứt bỏ đối tượng nhiều lần:

Giá trị this._messageQueue đánh giá không không thay đổi sau khi gọi MsmqHelper.DisposeQueue(this._messageQueue).

Chỉ tham số địa phương (tên messageQueue) được gán giá trị null trong phương pháp DisposeQueue. Do đó, "null guard" không bảo vệ đúng thời gian tiếp theo. (Điều này là do hành vi mặc định của C# là Call-By-Value: vui lòng xem liên kết để hiểu ý nghĩa của điều này trong ngữ cảnh "chuyển giá trị của tham chiếu đến đối tượng".)

Hoặc tham gia ref hoặc chỉ định this._messageQueue = null trong người gọi.

Answer 3

Nếu MessageQueue lớp thực hiện IDisposable iterface, sau đó không có điểm để sử dụng phương thức Dispose một cách rõ ràng và phương thức Close(), bởi vì trong tất cả các lớp học như vậy() phương thức Close thường là không phải là một phương pháp iterface mà là một phương pháp học . Thông thường, trong phương thức Dispose, tất cả các lệnh impementation đều phải gọi Close() mehod trước khi phát hành các tài nguyên quản lý/không được quản lý.

Một lần nữa, bằng cách đẩy mạnh trình trợ giúp tĩnh bên ngoài, bạn phá vỡ mẫu Dùng một lần. Nó không phải là cách chính xác để kiểm soát tuổi thọ của đối tượng; Bạn không cần phải mess lên với mẫu dùng một lần, bạn chỉ có thể sử dụng nó

Và mã của bạn có thể được đơn giản hóa như thế này:

// 1. Use static class. By the agreement, all helper classes should be static to avoid 
    // IDisposable inheritance, in example 
    public static class MsmqHelper//: IDisposable 
    { 
     //private MessageQueue _messageQueue; 

     //public MessageQueueHelper(bool workflowCreated) 
     //{ 
     // this._messageQueue = MsmqHelper.InitializeQueue(); 
     // this._messageQueue.Send(workflowCreated); 
     //} 

     public static SendMessage(object workflowCreated) 
     { 
      // 2. If static method in static class does not takes parameters, 
      // I might be better to to implicitly call the constructor? 

      // using(MessageQueue msmsq = MsmqHelper.InitializeQueue()) 

      using(MessageQueue msmsq = new MessageQueue()) 
      { 
       msmq.Send(workflowCreated); 
       msmq.Close(); 

       // MsmqHelper.DisposeQueue(msmq); 

       // 3. You should explicitly call Close object to immediately release  
       // unmanaged resources, while managed ones will be released 
       // at next GC rounds, as soon as possible 
      } 
     } 
     //private MessageQueue _messageQueue; 

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

     //private void Dispose(bool disposing) 
     //{ 
    // if (disposing == false) { return; } 
    // 
    // MsmqHelper.DisposeQueue(this._messageQueue); 
    //} 

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