Task.StartNew.ReceiveAsync() funktioniert nicht richtig beim Empfang von Nachrichten von MSMQ

Question

Ich verwende Implementierung Phase dieser URL how-can-i-read-messages-from-a-queue-in-parallel, es funktioniert gut, wenn ich vorher verwendet habe, nach einiger Zeit funktioniert es nicht, ich weiß nicht ' Verstehst du nicht, was passiert? Nachdem ich Zeit verbracht habe, schließe ich das Programm bei einer bestimmten Methode ab.

/// <summary> 
    /// APM -> TAP conversion for MessageQueue.Begin/EndPeek. 
    /// </summary> 
    private static Task<Message> PeekAsync(MessageQueue messageQueue) 
    { 
     return Task.Factory.FromAsync(messageQueue.BeginPeek(), messageQueue.EndPeek); 
    } 

, wenn ich diese Implementierung kommentieren Sie auf RunAsync() Verfahren und ReceiveAsync() Methode

/// <summary> 
    /// APM -> TAP conversion for MessageQueue.Begin/EndReceive. 
    /// </summary> 
    private static Task<Message> ReceiveAsync(MessageQueue messageQueue, TimeSpan timeout) 
    { 
     return Task.Factory.FromAsync(messageQueue.BeginReceive(timeout), messageQueue.EndPeek); 
    } 

dann Programm beenden, gibt Aufruf ist keine Ausnahme, weder irgend etwas geschehen. Einfach Programm ist beendet.

aus meiner Perspektive Task.Factory.FromAsync() ist ein Grund, aber nicht uncertand warum?

Wenn ich die gleiche Warteschlange mit dem Empfang von Nachrichten als BeginReceive() Eventhandler verwende, funktioniert es OK. Wie erkenne ich das?

Answer 1

In der ReceiveAsync-Funktion sollte der zweite Parameter FromAsyncmessageQueue.EndReceive statt messageQueue.EndPeek sein.

Answer 2

Erste Dinge zuerst.

Wie @xwlantian wies darauf hin. Ihre Vermischung Ihrer APM-Methodenpaare.

Sie sollten Ihre BeginXXX immer mit der korrekten EndXXX Methode übereinstimmen. Andernfalls erhalten Sie eine Ausnahme.

In Ihrem Fall

Task.Factory.FromAsync(messageQueue.BeginReceive(timeout), messageQueue.EndPeek) 

Sollte

Task.Factory.FromAsync(messageQueue.BeginReceive(timeout), messageQueue.EndReceive) 

lesen Sie sollten jedoch diese Texte selbst der Lage gewesen, zu beheben, wenn Sie die richtigen Informationen (die Ausnahme/Stacktrace) hatte. Was Sie behaupten, wurde vermisst.

Dies ist nicht wahr.

Der Grund, warum Sie keine Ausnahme sehen, ist, dass Visual Studio nicht break auf Ihre Ausnahme (das ist die typische Weise, die Sie "finden" Ausnahmen). Stattdessen können Sie Ihre Windows-Ereignisanzeige ansehen, und Sie sollten dort die Ausnahme finden.

Warum haben Sie die Ausnahme nicht "gesehen"?

Die folgenden wahr

1. Ihre Ausnahme ohne try/catch Paar auf einem Hintergrund-Thread aufgetreten der Stapel nach oben.
2. Sie hatten keinen Ausnahme-Handler in der AppDomain.
3. Sie haben "Just My Code" in Ihren "Debugging" -Einstellungen aktiviert.