下载时 HttpClient 未写入流

Question

目前我正在实施一种使用 HttpClient 报告进度的方法，因为我们与 .NET4 WPF 和 Windows 通用应用程序共享代码，我们使用来自 NuGet 的 Microsoft HTTP 客户端库。这个想法是将目标文件流包装在 a 中CountingInputStream并在那里报告进度：

 public override void Write(byte[] buffer, int offset, int count)
    {
        _stream.Write(buffer, offset, count);

        _bytesRead += count;
        _progress.Report(_bytesRead);

        if (_cancellationToken.IsCancellationRequested)
        {
            _cancellationToken.ThrowIfCancellationRequested();
        }
    }

然后我发送我的请求： HttpResponseMessage httpResponseMessage = AsyncHelpers.RunSync(() => _httpClient.SendAsync(httpRequestMessage, HttpCompletionOption.ResponseHeadersRead, cancellationToken));

之后，我打开文件流，然后复制内容流。响应具有正确的标头： Content-Length: 213334 Content-Type: application/octet-stream; charset=UTF-8 Content-Disposition: attachment; filename="Bondi Beach.jpg"; filename*=UTF-8''Bondi%20Beach.jpg

using(Stream fileStream = new CountingInputStream(storage.Open(downloadRequest.TargetPath, FileMode.Create), downloadRequest.Progress, cancellationToken )) {                                               
                await HttpHeaderResponseMessage.Content.CopyToAsync(fileStream);
       }

问题是StreamContent只有在下载完成后才开始写入文件流。当它开始编写进度报告时，它工作正常。

我已经尝试过不同的方法，例如：

• ReadAsStreamAsync 然后将响应流复制到文件流
• ReadAsStreamAsync 手动读取缓冲区，然后写入文件流
• _httpClient = new System.Net.Http.HttpClient(){MaxResponseContentBufferSize = 4096};来限制 BufferSize

任何想法如何ContentStream在仍在下载时强制写入文件流？

更新：按照 Luaans 的建议，我尝试覆盖WriteAsync并实现了 StreamContent Extensions 方法：

//CountingInputStream
public Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
    {
        _bytesRead += count;
        _progress.Report(_bytesRead);

        if (_cancellationToken.IsCancellationRequested)
        {
            _cancellationToken.ThrowIfCancellationRequested();
        }
        return _stream.WriteAsync(buffer, offset, count, cancellationToken);
    }
//static Extensions Class
public static async Task CopyToAs(this StreamContent source, Stream targetStream)
    {
        int read;
        byte[] buffer = new byte[4096];
        using(Stream responseStream = await source.ReadAsStreamAsync()) {
            while ((read = await responseStream.ReadAsync(buffer,0,buffer.Length))>0) {
                await targetStream.WriteAsync(buffer, 0, read);
            }
        }
    }

它仍然等到下载完成，直到它ReadAsync第一次调用。任何提示我做错了什么？

Answer 1

事实ReadAsStreamAsync是，嗯async，使这相当可疑。为什么要异步等待获取流？您应该异步读取它，但您应该立即准备好流本身。

阅读文档使这一点显而易见：

这个操作不会阻塞。读取整个响应（包括内容）后，返回的任务对象将完成。

但是，您可以使用重载使其在读取标头后返回。这仍然意味着您需要等待服务器处理请求，然后才能开始获得进展，但对于下载本身，您很幸运。

示例代码：

var response = 
 await 
 (
   new HttpClient()
   .GetAsync("http://www.microsoft.com/", HttpCompletionOption.ResponseHeadersRead)
 );

var stream = await response.Content.ReadAsStreamAsync();
var buffer = new byte[2048];    

while (await stream.ReadAsync(buffer, 0, buffer.Length) > 0)
{
  // Report progress and write to a different stream
}

编辑：

听起来你应该使用Windows.Web.Http.HttpClient而不是System.Net.Http.HttpClient：

async Task DownloadWithProgress()
{
 var awaitable = httpClient.GetAsync(yourUrl)

 awaitable.Progress = (res, progress) =>
 {
   // Report progress
 }

 await awaitable;   
}