C#怎么使用System.IO.Pipelines C#高性能IO管道库用法

System.IO.Pipelines 是 .NET Core 2.1+ 内置的高性能 IO 库，核心为 Pipe、PipeReader 和 PipeWriter，支持零拷贝、背压与异步流式处理，适用于 Kestrel 等高性能场景。

System.IO.Pipelines 是 .NET Core 2.1+ 内置的高性能 IO 抽象库，专为减少内存分配、避免缓冲区拷贝、支持异步流式处理而设计，常用于实现高性能网络服务器（如 Kestrel）、协议解析器或自定义流处理器。

核心组件：Pipe、PipeReader、PipeWriter

Pipe 是管道的核心容器，内部维护读写缓冲区（可配置大小和内存池）。PipeReader 负责从管道读取数据，PipeWriter 负责向管道写入数据。二者解耦，支持背压（backpressure）——当读取端慢时，写入端会自然等待，无需手动同步。

• 创建 Pipe：var pipe = new Pipe();（可传 PipeOptions 自定义缓冲区大小、内存池等）
• 获取读写器：PipeReader reader = pipe.Reader;，PipeWriter writer = pipe.Writer;
• 读写操作全程异步，返回 ValueTask，无装箱开销

基本读取流程：ReadAsync + AdvanceTo

读取不是“拿一段字节数组”，而是获取一个 ReadOnlySequence<byte></byte>（可跨多个内存块的零拷贝视图），处理完后必须调用 AdvanceTo 告知已消费位置，否则下次 ReadAsync 不会推进。

• ReadResult result = await reader.ReadAsync();
• 检查 result.IsCompleted（对端关闭）或 result.IsCanceled
• 用 result.Buffer 获取 ReadOnlySequence<byte></byte>，遍历或用 Span<byte></byte> 解析
• 处理完成后调用 reader.AdvanceTo(consumed, examined);
  （consumed：已逻辑处理的位置；examined：已扫描但未处理的最远位置）

基本写入流程：WriteAsync + FlushAsync

写入先调用 GetMemory() 或 GetSpan() 获取可写内存，填入数据后调用 Advance() 标记写入长度，最后 FlushAsync() 推送数据到读取端。

标签： 处理器 字节 ai stream c# .net