Поток от response.Content.ReadAsStreamAsync() не читается случайным образом

Question

Я создаю приложение .Net Web API, в котором следующий код вызывает вызов для моего другого приложения C# для загрузки файла, а затем сохранит его на диске. Иногда все работает нормально, и я получаю файл, но иногда код ниже не может читать поток, и я вижу закрытое исключение удаленного подключения в другом приложении.

public async Task<string> GetFilePathAsync(TestModel model) 
{ 
    string filePath = string.Empty; 
    var response = await cgRequestHelper.DownloadAsync(model); 

    if (response.IsSuccessStatusCode) 
    {      
     filePath = await SaveCgStreamAsync(cgResponse, serviceModel.FileName); 
    } 
    return filePath; 
} 

public async Task<HttpResponseMessage> DownloadAsync(TestModel model) 
{    
    if (model == null) 
     throw new ArgumentNullException("model"); 
    if (string.IsNullOrEmpty(model.Url)) 
     throw new ArgumentNullException("Url"); 
    if (model.Headers == null) 
     throw new ArgumentNullException("Headers"); 

    HttpResponseMessage response; 
    using (HttpClient httpClient = new HttpClient()) 
    { 
     foreach (var header in model.Headers) 
     { 
      httpClient.DefaultRequestHeaders.Add(header.Key, header.Value); 
     } 
     response = await httpClient.GetAsync(model.Url, HttpCompletionOption.ResponseHeadersRead); 
    } 
    return response;    
}   

public async Task<string> SaveCgStreamAsync(HttpResponseMessage response, string fileName) 
{ 
    if (response == null) 
     throw new ArgumentNullException("response"); 
    if (string.IsNullOrEmpty(fileName)) 
     throw new ArgumentNullException("fileName"); 

    var filePath = _CreateTemporaryLocation(fileName); 
    Stream cgStream = null; 
    Stream fileStream = null; 
    try 
    { 
     cgStream = await response.Content.ReadAsStreamAsync(); 
     fileStream = File.Open(filePath, FileMode.Create); 
     await cgStream.CopyToAsync(fileStream); 
    } 
    catch(Exception e) 
    { 
     throw; 
    } 
    finally 
    { 
     if(cgStream != null) 
      cgStream.Dispose(); 
     if(fileStream != null) 
      fileStream.Dispose(); 
    } 

    return filePath;    
} 

Я поставил ServicePointManager.DefaultConnectionLimit = 1000 в Global.asax.cs

В моем текущем приложении я получаю исключение на "ждут cgStream.CopyToAsync (FileStream);" когда он пытается прочитать cgStream. Исключением является «Невозможно получить доступ к закрытому потоку». с null InnerException Другое исключение для приложения: System.Web.HttpException: удаленный хост закрыл соединение. Код ошибки: 0x800703E3. на System.Web.Hosting.IIS7WorkerRequest.RaiseCommunicationError (Int32 результат, булева throwOnDisconnect) в System.Web.Hosting.IIS7WorkerRequest.ExplicitFlush() в System.Web.HttpResponse.Flush (Boolean, Boolean finalFlush асинхронном)

В среднем запрос 1 из 10 не работает с вышеуказанной ошибкой. Поскольку он случайный и не всегда не работает, очень сложно устранить проблему.

Приведенный выше код написан с помощью от: http://www.tugberkugurlu.com/archive/efficiently-streaming-large-http-responses-with-httpclient

Любая помощь в связи с этой проблемой ценится!

Благодаря

Answer 1

За документацию, Stream.CopyToAsync, хорошо, асинхронный. Это означает, что он не собирается блокировать вызывающего абонента (ваш метод), который будет продолжать Dispose из потока в блоке finally. Другими словами, у вас есть состояние гонки. Переключитесь на Stream.CopyTo, и вам должно быть хорошо.

Answer 2

Я попробую Stream.CopyTo, но вместо этого просто, чтобы вы знали, что я пытаюсь ниже код раньше и позже изменено, что CopyToAsync

public async Task<string> GetFilePathAsync(TestModel model) 
    { 
     string filePath = string.Empty; 
     var response = await cgRequestHelper.DownloadAsync(model); 

     if (response.IsSuccessStatusCode) 
     {     
      Stream cgStream = await response.Content.ReadAsStreamAsync(); 
      filePath = SaveCgStream(cgStream , model.FileName); 
     } 
     return filePath; 
    } 

    public string SaveCgStream(Stream cgStream, string fileName) 
     { 
      if (response == null) 
       throw new ArgumentNullException("response"); 
      if (string.IsNullOrEmpty(fileName)) 
       throw new ArgumentNullException("fileName"); 

      const int CHUNK_SIZE = 40000; 
      var filePath = _CreateTemporaryLocation(fileName); 
      var fileStream = File.Create(filePath, CHUNK_SIZE); 

      int bytesRead; 
      var buffer = new byte[CHUNK_SIZE]; 
      bool isReadStarted = false; 
      try 
      { 
       do 
       { 
        bytesRead = cgStream.Read(buffer, 0, CHUNK_SIZE); 
        if (bytesRead > 0) 
        { 
         isReadStarted = true; 
         fileStream.Write(buffer, 0, bytesRead); 
        } 
       } while (bytesRead > 0); 
      } 
      catch (Exception e) 
      { 
       throw e; 
      } 
      finally 
      { 
       fileStream.Close(); 
      } 
      return filePath; 
     } 

И я получаю ту же ошибку в bytesRead = cgStream.Read(buffer, 0, CHUNK_SIZE); линии. Вы все еще думаете, что это проблема CopyToAsync? Я сомневаюсь, потому что, когда я помещаю точку прерывания, я вижу, что поток не читается, поскольку свойство Read является ложным, даже если оно не подходит к методу CopyToAsync.

Я пробовал CopyTo вместо CopyToAsync, и это не помогло. Снимок экрана:

Answer 3

я понял, проблема в коде: Проблема заключалась в том, что я инициализации HttpClient объект в «используя» и используя свой ответ вне сферы с использованием. Это будет уничтожать объект HttpClient, следовательно, нарушит удаленное соединение, и поэтому я не могу передать поток. Случайное поведение состояло в том, что мы не знаем, когда объект будет удален, иногда он не удаляется перед потоковой передачей, а иногда и происходит.