Anforderung Körper zweimal lesen

Question

Ich versuche, den Körper in einer Middleware zu Authentifizierungszwecken zu lesen, aber wenn die Anfrage an den API-Controller kommt, ist das Objekt leer, da der Text bereits gelesen wurde. Gibt es das überhaupt? Ich lese den Körper so in meiner Middleware.

var buffer = new byte[ Convert.ToInt32(context.Request.ContentLength) ]; 
await context.Request.Body.ReadAsync(buffer, 0, buffer.Length); 
var body = Encoding.UTF8.GetString(buffer); 

Answer 1

Wenn Sie application/x-www-form-urlencoded oder multipart/form-data verwenden, können Sie sicher nennen context.Request.ReadFormAsync() mehrere Male, da es eine zwischengespeicherte Instanz bei nachfolgenden Aufrufen zurückgibt.

Wenn Sie einen anderen Inhaltstyp verwenden, müssen Sie die Anforderung manuell puffern und den Anfragetext durch einen zurückspulbaren Stream wie MemoryStream ersetzen. Hier ist, wie Sie tun können, eine Inline-Middleware (Sie müssen es bald in Ihrer Pipeline registrieren):

app.Use(next => async context => { 
    // Keep the original stream in a separate 
    // variable to restore it later if necessary. 
    var stream = context.Request.Body; 

    // Optimization: don't buffer the request if 
    // there was no stream or if it is rewindable. 
    if (stream == Stream.Null || stream.CanSeek) { 
     await next(context); 

     return; 
    } 

    try { 
     using (var buffer = new MemoryStream()) { 
      // Copy the request stream to the memory stream. 
      await stream.CopyToAsync(buffer); 

      // Rewind the memory stream. 
      buffer.Position = 0L; 

      // Replace the request stream by the memory stream. 
      context.Request.Body = buffer; 

      // Invoke the rest of the pipeline. 
      await next(context); 
     } 
    } 

    finally { 
     // Restore the original stream. 
     context.Request.Body = stream; 
    } 
}); 

Sie können auch die BufferingHelper.EnableRewind() Erweiterung verwenden, die einen Teil des Microsoft.AspNet.Http Paket ist: es basiert auf einem ähnlichen Ansatz sondern stützt sich auf einen speziellen Strom, der Pufferung von Daten im Speicher beginnt und Spulen alles in eine temporäre Datei auf der Festplatte, wenn der Schwellenwert erreicht ist:

app.Use(next => context => { 
    context.Request.EnableRewind(); 

    return next(context); 
}); 

FYI: eine Puffermiddleware wird wahrscheinlich zu vNext in der Zukunft hinzugefügt werden.

Answer 2

Verwendung für PinPoint Erwähnung von EnableRewind

Startup.cs 
using Microsoft.AspNetCore.Http.Internal; 

Startup.Configure(...){ 
... 
//Its important the rewind us added before UseMvc 
app.Use(next => context => { context.Request.EnableRewind(); return next(context); }); 
app.UseMvc() 
... 
} 

Dann in Ihrer Middleware einfach zurückspulen und wieder gelesen

private async Task GenerateToken(HttpContext context) 
    { 
    context.Request.EnableRewind(); 
    string jsonData = new StreamReader(context.Request.Body).ReadToEnd(); 
    ... 
    }