如何在.net core中读取ChunkedEncodingReadStream

Question

我正在使用 HttpClient 下载一个文件并尝试以 4MB 的块来处理它。客户端 returns 流为 ChunkedEncodingReadStream。我要下载的文件大小为 50MB。但是，当我尝试使用 ReadAsync 在 4MB 缓冲区中读取它时，我注意到它 returns 读取计数仅为 1321 字节。

我的问题是：如何正确读取流？

我的代码：

var client = _httpClientFactory.CreateClient();
var response = await client.GetAsync(fileUrl, HttpCompletionOption.ResponseHeadersRead);
stream = await response.Content.ReadAsStreamAsync().ConfigureAwait(false);

var chunkSize = 4096 * 1024;
var buffer = new byte[chunkSize];

var byteRead = stream.Read(buffer, 0, chunkSize);

if (byteRead < chunkSize)
{
    // process the buffer as the only chunk
}
else
{
    // process initial chunk

    while (byteRead < chunkSize)
    {
        byteRead = stream.Read(buffer, 0, chunkSize);
        // process next chunks
    }
}

显然，此代码假定响应流将继续提供 4MB 块，直到到达最后一个块。但是我收到的流不是那样工作的。在这种情况下，处理此流的正确方法是什么？

Answer 1

我意识到流可以 return 任意数量的字节，只有当它 return 为 0 字节时，流才可以被认为已完成，如评论中所述。但是由于我的用例需要读取指定块大小的流，所以我想出了以下代码来读取它 -

public static async Task<(int readCount, byte[] buffer)> ReadChunkAsync(Stream stream, int chunkSize)
{
    var buffer = new byte[chunkSize];
    var readCount = 0;

    while (readCount < chunkSize)
    {
        var bytesRead = await stream.ReadAsync(buffer, readCount, chunkSize - readCount);

        if (bytesRead == 0)
        {
            break;
        }

        readCount += bytesRead;
    }

    return (readCount, buffer);
}

如何在.net core中读取ChunkedEncodingReadStream

How to read ChunkedEncodingReadStream in .net core

.net

c#

stream

dotnet-httpclient

asp.net-core