.NET实现REST GET流式数据持续接收的方法咨询

完整实现方案 #

你当前的.NET代码已经开启了流式响应的基础配置（使用HttpCompletionOption.ResponseHeadersRead），但缺少持续读取流内容的核心逻辑。以下是对应你Python流式读取行为的完整实现：

完整代码示例 #

using (var request = new HttpRequestMessage
{
    Method = HttpMethod.Get,
    RequestUri = new Uri("http://myCompany.com/v1/streamingdata"),
    Headers =
    {
        { "Accept-Encoding", "identity" } // 禁用压缩，确保流式内容可逐段读取
    }
})
{
    await GetStream(session, request);
}

public static async Task GetStream(HttpClient session, HttpRequestMessage request)
{
    var response = HandleResponse(await session.SendAsync(request, HttpCompletionOption.ResponseHeadersRead));
    var content = response.Content;

    // 获取响应的流对象
    using var stream = await content.ReadAsStreamAsync();
    // 使用StreamReader按行读取（对应Python的iter_lines）
    using var reader = new StreamReader(stream);

    string line;
    // 循环读取每一行，直到流结束（服务器断开连接）
    while ((line = await reader.ReadLineAsync()) != null)
    {
        if (string.IsNullOrWhiteSpace(line))
            continue; // 跳过空行

        // 处理读取到的内容，对应Python的json.loads和print
        if (line.Equals("heartbeat", StringComparison.OrdinalIgnoreCase))
        {
            // 处理心跳包逻辑
            Console.WriteLine("Received heartbeat");
        }
        else
        {
            // 解析JSON数据，替换<object>为你的实际数据类型
            try
            {
                var data = JsonSerializer.Deserialize<object>(line);
                Console.WriteLine($"Received data: {JsonSerializer.Serialize(data)}");
            }
            catch (JsonException ex)
            {
                Console.WriteLine($"Failed to parse JSON: {ex.Message}, Content: {line}");
            }
        }
    }
}

核心逻辑说明 #

• HttpCompletionOption.ResponseHeadersRead：告诉HttpClient无需等待整个响应完成，拿到响应头后立即开始处理内容，这是流式读取的核心前提，你已正确配置。
• StreamReader.ReadLineAsync：对应Python的iter_lines方法，逐行读取服务器分批返回的内容（假设服务器每批数据以单独一行返回，与你的Python代码逻辑匹配）。
• 禁用压缩：请求头中的Accept-Encoding: identity确保服务器不返回压缩内容，避免流式读取时出现解析错误。
• 异常与心跳处理：针对心跳包做单独逻辑分支，同时捕获JSON解析异常，避免程序因格式错误崩溃。

额外注意事项 #

• 如果服务器返回的分块不是按行分隔，而是固定长度或自定义分隔符，需调整读取逻辑（比如使用Stream.ReadAsync读取固定字节数后处理分隔符）。
• 若需处理连接中断重连，可在循环中增加异常捕获逻辑，实现自动重试。
• 确保HttpClient实例复用，避免频繁创建TCP连接导致性能损耗。

内容的提问来源于stack exchange，提问作者Jack