如何优雅地将StreamReader的数据管道传输至StreamWriter？

如果你必须基于StreamReader和StreamWriter实现文本流的管道传输，结合异步与取消令牌，有两种常用的优雅方案：

1. 逐行异步传输（适合文本行场景） #

这种方式适配按行组织的文本数据，代码清晰易读：

async Task PipeReaderToWriter(StreamReader reader, StreamWriter writer, CancellationToken cancellationToken)
{
    string? line;
    // 逐行读取直到流结束
    while ((line = await reader.ReadLineAsync(cancellationToken)) != null)
    {
        // 异步写入该行
        await writer.WriteLineAsync(line.AsMemory(), cancellationToken);
        // 若需要实时同步数据到目标流，可添加刷新操作
        // await writer.FlushAsync(cancellationToken);
    }
    // 最后确保所有缓存数据写入目标流
    await writer.FlushAsync(cancellationToken);
}

2. 缓冲区批量传输（高效大文件场景） #

处理大文本文件时，用缓冲区批量读写能减少IO次数，显著提升性能：

async Task PipeReaderToWriter(StreamReader reader, StreamWriter writer, CancellationToken cancellationToken)
{
    // 4KB缓冲区，可根据实际场景调整大小（比如8KB、16KB）
    char[] buffer = new char[4096];
    int charsRead;
    // 批量读取字符到缓冲区
    while ((charsRead = await reader.ReadAsync(buffer, 0, buffer.Length, cancellationToken)) > 0)
    {
        // 将缓冲区中读取到的字符异步写入目标流
        await writer.WriteAsync(buffer, 0, charsRead, cancellationToken);
    }
    await writer.FlushAsync(cancellationToken);
}

额外优化：直接操作底层Stream #

如果你的场景不需要文本编码处理（比如单纯的字节流传输），跳过StreamReader和StreamWriter，直接用.NET内置的CopyToAsync方法是最简洁高效的方案：

// 假设randomStream1、randomStream2是底层的Stream对象
await randomStream1.CopyToAsync(randomStream2, cancellationToken);

该方法内置优化的缓冲区逻辑，无需自行实现循环，是官方推荐的流传输方式。

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