来自 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;            
}

我在 Global.asax.cs 中设置了 ServicePointManager.DefaultConnectionLimit = 1000

在我当前的应用程序中，我在“await cgStream.CopyToAsync(fileStream);”上遇到异常 尝试读取 cgStream 时的行。例外是“无法访问关闭的流”。带有 null InnerException 另一个应用程序异常是： System.Web.HttpException：远程主机关闭了连接。错误代码是 0x800703E3。在 System.Web.Hosting.IIS7WorkerRequest.RaiseCommunicationError(Int32 result, Boolean throwOnDisconnect) 在 System.Web.Hosting.IIS7WorkerRequest.ExplicitFlush() 在 System.Web.HttpResponse.Flush(Boolean finalFlush, Boolean async)

平均而言，10 个请求中有 1 个因上述错误而失败。由于它是随机的并且并不总是失败，因此很难解决问题。

上面的代码是在帮助下编写的：http : //www.tugberkugurlu.com/archive/efficiently-streaming-large-http-responses-with-httpclient

任何与此问题相关的帮助表示赞赏！

谢谢

Answer 1

我发现了代码中的问题：问题是我在“使用”中初始化 HttpClient 对象并在使用范围之外使用其响应。这将处理 HttpClient 对象，从而中断远程连接，这就是我无法流式传输内容的原因。随机行为是因为我们不知道对象何时会被释放，有时它不会在流之前被释放，有时它会被释放。

Answer 2

根据文档，Stream.CopyToAsync是异步的。这意味着它不会阻止调用者（您的方法），调用者将继续在finally 块中处理流。换句话说，你有一个竞争条件。切换到Stream.CopyTo，你应该可以开始了。