Async-Protokollierung, die eine NullReferenceException wirft

Question

Ich versuche, einige Informationen zu SQL Server innerhalb einer MVC 4-Controller-Aktion, die .NET 4.0 mit dem AsyncTargetingPack abzielt, zu protokollieren. Ich würde gehen Sie direkt zu .NET 4.5, aber mein App lebt in Azure und we're still waiting for the update ...

Dieser Code funktioniert wie erwartet (eine Zeile zu meiner Datenbank ohne Ausnahmen geworfen geschrieben):

public class SystemActionLogger : ISystemActionLogger 
{ 
    private readonly ActionBlock<Tuple<SystemAction, object>> actionBlock; 

    public SystemActionLogger(ISystemActionLogEntryRepository repository) 
    { 
     actionBlock = new ActionBlock<Tuple<SystemAction, object>>(
      entry => TaskEx.Run(async() => 
       { 
        string data = await JsonConvert.SerializeObjectAsync(entry.Item2); 
        await repository.PersistAsync(new SystemActionLogEntry(entry.Item1, data)); 
       })); 
    } 

    public void Log(SystemAction systemAction, object data) 
    { 
     actionBlock.Post(new Tuple<SystemAction, object>(systemAction, data)); 
    } 
} 

Und Dieser Code führt eine Nullreferenceexception:

public class SystemActionLogger : ISystemActionLogger 
{ 
    private readonly ActionBlock<Tuple<SystemAction, object>> actionBlock; 

    public SystemActionLogger(ISystemActionLogEntryRepository repository) 
    { 
     actionBlock = new ActionBlock<Tuple<SystemAction, object>>(async entry => 
      { 
       string data = await JsonConvert.SerializeObjectAsync(entry.Item2); 
       await repository.PersistAsync(new SystemActionLogEntry(entry.Item1, data)); 
      }); 
    } 

    public void Log(SystemAction systemAction, object data) 
    { 
     actionBlock.Post(new Tuple<SystemAction, object>(systemAction, data)); 
    } 
} 

Nullreferenceexception: „der Objektverweis auf eine Instanz eines Objekts nicht gesetzt“

Server stack trace: 
    at System.Web.ThreadContext.AssociateWithCurrentThread(Boolean setImpersonationContext) 
    at System.Web.HttpApplication.OnThreadEnterPrivate(Boolean setImpersonationContext) 
    at System.Web.LegacyAspNetSynchronizationContext.CallCallbackPossiblyUnderLock(SendOrPostCallback callback, Object state) 
    at System.Web.LegacyAspNetSynchronizationContext.CallCallback(SendOrPostCallback callback, Object state) 
    at System.Runtime.CompilerServices.TaskAwaiter.<>c__DisplayClassa.<OnCompletedInternal>b__0(Task param0) 

Exception rethrown at [0]: 
    at System.Runtime.CompilerServices.AsyncMethodBuilderCore.<ThrowAsync>b__1(Object state) 
    at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx) 
    at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx) 
    at System.Threading.QueueUserWorkItemCallback.System.Threading.IThreadPoolWorkItem.ExecuteWorkItem() 
    at System.Threading.ThreadPoolWorkQueue.Dispatch() 

Ich habe keine Sichtbarkeit in der Ausnahme, da es alle externen Code ist. Ich verstehe nicht, warum der zweite Codeblock fehlschlägt. Dies ist der Code, den ich ursprünglich geschrieben habe.

Was mache ich falsch?

Answer 1

Dataflow funktioniert nur mit .NET 4.5. Die Tatsache, dass Sie es unter .NET 4.0 ausführen, wird nicht unterstützt und ist wahrscheinlich der Grund dafür, dass Sie fehlerhafte Ausnahmen sehen.

Answer 2

Ich hatte gerade ein sehr ähnliches Problem (NullReference von AssociateWithCurrentThread bei Verwendung einer Protokollierungsaufgabe).

Das Problem, das ich hatte, war, dass die ursprüngliche Aktion nicht die Beendigung der Protokollierung Aufgabe wartete, so wenn das Protokoll beendet und versucht, den ursprünglichen Thread wieder eine NullReference wird ausgelöst, da der ursprüngliche Thread beendet wurde.

Dies wurde für mich gelöst, indem sichergestellt wurde, dass der Anforderungscontroller auf die Protokollierungsfunktion wartete.

Answer 3

Ich hatte dieses Problem mit .net4.5, als mein Web-Service einen anderen WCF-Dienst asynchron aufgerufen hat. Ich habe einfach eine kurze Zeit Wait() angehängt, da mir die Antwort (Telemetrieereignis) egal war.

public static void Event(string key, string message) { 
    Telemetry.Event(key, message).Wait(100); 
}