अनुरोध निकाय दो बार

Question

मैं प्रमाणीकरण उद्देश्यों के लिए शरीर को मिडलवेयर में पढ़ने की कोशिश कर रहा हूं, लेकिन जब अनुरोध एपीआई नियंत्रक को मिलता है तो वस्तु खाली होती है क्योंकि शरीर पहले से ही पढ़ा जा चुका है। वैसे भी इसके आसपास है। मैं इस तरह के शरीर को अपने मिडलवेयर में पढ़ रहा हूं।

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

आप application/x-www-form-urlencoded या multipart/form-data का उपयोग कर रहे हैं, तो आप सुरक्षित रूप से के रूप में यह आगामी कॉल पर एक कैश्ड उदाहरण देता context.Request.ReadFormAsync() कई बार फोन कर सकते हैं।

यदि आप एक अलग सामग्री प्रकार का उपयोग कर रहे हैं, तो आपको अनुरोध को मैन्युअल रूप से बफर करना होगा और अनुरोध निकाय को MemoryStream जैसे रिवाइंडेबल स्ट्रीम द्वारा प्रतिस्थापित करना होगा। यहां आपके द्वारा किसी इनलाइन मिडलवेयर का उपयोग कर सकता है (यदि आप अपने पाइप लाइन में जल्द ही यह रजिस्टर करने की आवश्यकता):

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

तुम भी BufferingHelper.EnableRewind() विस्तार है, जो Microsoft.AspNet.Http पैकेज का हिस्सा है का उपयोग कर सकते हैं: यह एक समान दृष्टिकोण पर आधारित है FYI करें

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

    return next(context); 
}); 

: लेकिन एक विशेष धारा है कि स्मृति में बफरिंग डेटा शुरू होता है और डिस्क पर एक अस्थायी फ़ाइल के लिए सब कुछ spools पर निर्भर करता है जब सीमा तक पहुंचने पर एक बफरिंग मिडलवेयर शायद भविष्य में vNext में जोड़ दिया जाएगा।

Answer 2

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() 
... 
} 

फिर से ठीक से निर्धारित की उल्लेख के लिए प्रयोग अपने मिडलवेयर में आप सिर्फ रिवाइंड करने और

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