如何解决C# HttpClient大文件下载时的连接中断超时失效问题？

你这段代码的核心问题在于：HttpClient.Timeout仅覆盖请求发起至获取响应头的阶段，完全不包含后续的流读取过程。当执行CopyToAsync时，若网络断开后TCP连接进入静默状态（无数据传输也无重置包），流操作无法主动检测到连接中断，会一直挂起而不抛出异常。

方案1：用取消令牌控制全流程超时（推荐） #

利用CancellationTokenSource设置全局超时，将令牌传递到所有异步操作（包括流读取），确保任何阶段超时都会触发取消并抛出异常。

修改后的完整代码

async Task RunHttpDownload()
{
    var url = "https://speed.hetzner.de/1GB.bin";
    var totalTimeout = TimeSpan.FromSeconds(20);

    Console.WriteLine($"Start download {DateTime.Now}");

    try
    {
        // 创建带超时的取消令牌源
        using var cts = new CancellationTokenSource(totalTimeout);
        using var httpClient = new HttpClient { Timeout = totalTimeout };

        // 请求阶段传递令牌
        using var httpResp = await httpClient.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, cts.Token);
        httpResp.EnsureSuccessStatusCode();

        using var fileStream = new FileStream("download.bin", FileMode.OpenOrCreate, FileAccess.Write, FileShare.Read, bufferSize: 4096, useAsync: true);
        using var httpStream = await httpResp.Content.ReadAsStreamAsync(cts.Token);

        // 流复制阶段也传递令牌，超时直接触发取消
        await httpStream.CopyToAsync(fileStream, 4096, cts.Token);
    }
    catch (OperationCanceledException)
    {
        Console.WriteLine("下载超时或被取消");
    }
    catch (Exception e)
    {
        Console.WriteLine($"Exception: {e.Message}");
    }

    Console.WriteLine($"End download {DateTime.Now}");
}

方案2：检测静默连接（进阶需求） #

如果需要在长时间无数据传输时触发超时（而非总下载时长超时），可以自定义包装流监控读取间隔：

自定义超时流实现

public class TimeoutStream : Stream
{
    private readonly Stream _innerStream;
    private readonly TimeSpan _idleTimeout;
    private readonly CancellationToken _token;
    private DateTime _lastActiveTime;

    public TimeoutStream(Stream innerStream, TimeSpan idleTimeout, CancellationToken token)
    {
        _innerStream = innerStream;
        _idleTimeout = idleTimeout;
        _token = token;
        _lastActiveTime = DateTime.Now;
    }

    public override async Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
    {
        using var linkedCts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, _token);
        var readTask = _innerStream.ReadAsync(buffer, offset, count, linkedCts.Token);
        var timeoutTask = Task.Delay(_idleTimeout, linkedCts.Token);

        var completedTask = await Task.WhenAny(readTask, timeoutTask);
        if (completedTask == timeoutTask)
        {
            throw new TimeoutException("连接静默超时");
        }

        var bytesRead = await readTask;
        if (bytesRead > 0) _lastActiveTime = DateTime.Now;
        return bytesRead;
    }

    // 以下方法直接委托给内部流
    public override bool CanRead => _innerStream.CanRead;
    public override bool CanSeek => _innerStream.CanSeek;
    public override bool CanWrite => _innerStream.CanWrite;
    public override long Length => _innerStream.Length;
    public override long Position { get => _innerStream.Position; set => _innerStream.Position = value; }
    public override void Flush() => _innerStream.Flush();
    public override int Read(byte[] buffer, int offset, int count) => _innerStream.Read(buffer, offset, count);
    public override long Seek(long offset, SeekOrigin origin) => _innerStream.Seek(offset, origin);
    public override void SetLength(long value) => _innerStream.SetLength(value);
    public override void Write(byte[] buffer, int offset, int count) => _innerStream.Write(buffer, offset, count);
    public override Task FlushAsync(CancellationToken cancellationToken) => _innerStream.FlushAsync(cancellationToken);
    public override Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken) => _innerStream.WriteAsync(buffer, offset, count, cancellationToken);
}

使用示例

// 在原代码流读取部分替换为：
using var httpStream = await httpResp.Content.ReadAsStreamAsync(cts.Token);
// 设置10秒无数据传输超时
using var timeoutStream = new TimeoutStream(httpStream, TimeSpan.FromSeconds(10), cts.Token);
await timeoutStream.CopyToAsync(fileStream, 4096, cts.Token);

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