UWP应用调用RandomAccessStream.CopyAndCloseAsync因网络问题冻结的排查修复

嘿，我来帮你拆解下这个问题！

首先解答你的第一个疑问：RandomAccessStream.CopyAndCloseAsync本身需要联网吗？ #

答案是不需要——这个方法本质是把数据从输入流复制到输出流的异步操作，本身不直接依赖网络。但你的场景里，inputStream是从HTTP响应内容获取的流，这个流背后其实和网络连接是绑定的：当网络被防火墙拦截或断开时，读取这个流的底层操作会卡住，而CopyAndCloseAsync在执行时需要持续从inputStream读取数据，最终导致这个异步方法无限挂起，看起来就像应用冻结了。

怎么跳过/避免这个冻结问题？ #

核心思路是给异步操作添加超时控制或取消机制，防止因流读取阻塞导致整个应用无响应。下面给你几个具体的解决方案：

1. 给CopyAndCloseAsync添加超时包装

用Task.WhenAny结合Task.Delay，设定一个超时时间，超过时间就主动终止操作并清理资源：

async public Task DownloadFile(Uri url, string filename)
{
    Windows.Web.Http.HttpResponseMessage response = await client.GetAsync(url, Windows.Web.Http.HttpCompletionOption.ResponseHeadersRead);
    response.EnsureSuccessStatusCode();
    
    // 注意：原代码里多余的responseBody变量可以删掉，避免重复获取流
    IInputStream inputStream = await response.Content.ReadAsInputStreamAsync();
    StorageFolder folder = await App.GetDocumentFolder();
    StorageFile file = await folder.CreateFileAsync(filename, CreationCollisionOption.ReplaceExisting);
    IOutputStream outputStream = await file.OpenAsync(FileAccessMode.ReadWrite);

    // 包装超时逻辑
    var copyTask = RandomAccessStream.CopyAndCloseAsync(inputStream, outputStream).AsTask();
    var timeoutTask = Task.Delay(TimeSpan.FromSeconds(30)); // 设定30秒超时

    var completedTask = await Task.WhenAny(copyTask, timeoutTask);
    if (completedTask == timeoutTask)
    {
        // 超时后清理资源，避免内存泄漏
        inputStream.Dispose();
        outputStream.Dispose();
        throw new TimeoutException("下载超时，请检查网络连接是否正常");
    }

    await copyTask;
}

2. 使用CancellationToken主动取消操作

可以创建CancellationTokenSource，既可以设置超时自动取消，也可以在检测到网络断开时手动触发取消：

async public Task DownloadFile(Uri url, string filename)
{
    using var cts = new CancellationTokenSource();
    // 自动30秒超时取消，也可以绑定网络状态变化事件手动取消
    cts.CancelAfter(TimeSpan.FromSeconds(30));

    try
    {
        Windows.Web.Http.HttpResponseMessage response = await client.GetAsync(url, Windows.Web.Http.HttpCompletionOption.ResponseHeadersRead, cts.Token);
        response.EnsureSuccessStatusCode();
        
        IInputStream inputStream = await response.Content.ReadAsInputStreamAsync();
        StorageFolder folder = await App.GetDocumentFolder();
        StorageFile file = await folder.CreateFileAsync(filename, CreationCollisionOption.ReplaceExisting);
        IOutputStream outputStream = await file.OpenAsync(FileAccessMode.ReadWrite);

        // 把取消令牌传入异步操作
        await RandomAccessStream.CopyAndCloseAsync(inputStream, outputStream).AsTask(cts.Token);
    }
    catch (OperationCanceledException)
    {
        // 处理取消逻辑，提示用户
        throw new Exception("下载已取消，请检查网络后重试");
    }
}

3. 手动分块读取流（更灵活的控制）

如果想要更精细地控制每一步的读取操作，可以放弃CopyAndCloseAsync，手动分块读取和写入，每一步都添加超时检查：

async public Task DownloadFile(Uri url, string filename)
{
    Windows.Web.Http.HttpResponseMessage response = await client.GetAsync(url, Windows.Web.Http.HttpCompletionOption.ResponseHeadersRead);
    response.EnsureSuccessStatusCode();
    
    using IInputStream inputStream = await response.Content.ReadAsInputStreamAsync();
    StorageFolder folder = await App.GetDocumentFolder();
    StorageFile file = await folder.CreateFileAsync(filename, CreationCollisionOption.ReplaceExisting);
    using IOutputStream outputStream = await file.OpenAsync(FileAccessMode.ReadWrite);

    var buffer = new byte[4096]; // 4KB分块读取
    var reader = new DataReader(inputStream);

    while (true)
    {
        // 给每一次读取操作加10秒超时
        var loadTask = reader.LoadAsync((uint)buffer.Length).AsTask();
        var timeoutTask = Task.Delay(TimeSpan.FromSeconds(10));
        var completed = await Task.WhenAny(loadTask, timeoutTask);

        if (completed == timeoutTask)
        {
            throw new TimeoutException("读取数据超时，请检查网络");
        }

        uint bytesRead = await loadTask;
        if (bytesRead == 0) break; // 读取完毕

        reader.ReadBytes(buffer);
        await outputStream.WriteAsync(buffer.AsBuffer(0, (int)bytesRead));
    }

    await outputStream.FlushAsync(); // 确保所有数据写入文件
}

额外小提示 #

原代码里有一行多余的代码：var responseBody = await response.Content.ReadAsInputStreamAsync();，这行重复获取了响应流，不仅浪费资源，还可能导致后续流读取异常，建议直接删掉。

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