Pipe易卡死或丢数据的根本原因是未理解其背压机制：WriteAsync()仅表示写入缓冲区完成，不保证被读取；必须配对使用ReadAsync()和AdvanceTo()，漏掉AdvanceTo()会导致缓冲区堆积、内存泄漏或静默丢弃。
为什么直接用 Pipe 容易卡死或丢数据
根本原因是没理解 Pipe 的“背压”机制——它不会自动阻塞写入，也不会主动通知读取方有新数据。调用 pipe.Writer.WriteAsync() 后，数据进缓冲区就返回，但若读端没及时 ReadAsync() 或没调用 AdvanceTo() 标记已消费位置，缓冲区就会堆积、最终触发 OperationCanceledException 或静默丢弃。
- 必须配对使用
ReadAsync()和AdvanceTo()，漏掉AdvanceTo()是最常见内存泄漏根源 -
WriteAsync()返回的ValueTask仅表示写入缓冲区完成，不表示数据已被读取或处理 - 默认
PipeOptions下，缓冲区满时WriteAsync()会 await 阻塞，但若读端永远不调用ReadAsync()，写端将永久挂起
PipeReader 读循环怎么写才不出错
标准读循环不是“读一次完事”，而是一个持续的 while (true) + await reader.ReadAsync() + AdvanceTo() 三段式结构。关键在如何决定 AdvanceTo() 的参数：第一个参数是已处理完的最后位置（consumed），第二个是准备丢弃但未处理的起始位置（examined）。
- 如果解析出完整消息（如以
\n结尾），设consumed = buffer.End，examined = buffer.End - 如果只读到半截消息（比如还没遇到
\n），设consumed = buffer.Start（没处理任何字节），examined = buffer.End（告诉管道“我看到这么多，但没消化”） - 绝不能传
buffer.Start给consumed后又传buffer.Start给examined，这会导致死锁 - 每次
ReadAsync()返回前必须调用AdvanceTo()，否则下一次读会失败
while (true)
{
var result = await reader.ReadAsync();
var buffer = result.Buffer;
var position = buffer.GetPosition(0);
// 假设按行解析
if (buffer.TryRead(out ReadOnlySequence<byte> line, ref position, (b, p) => b.Slice(p).IndexOf((byte)'\n') >= 0))
{
ProcessLine(line);
reader.AdvanceTo(position, position); // consumed = examined = position
}
else
{
reader.AdvanceTo(buffer.Start, buffer.End); // 暂存未完成行，继续等待
}
if (result.IsCompleted) break;
}
PipeWriter 写数据时要注意什么
PipeWriter 不是流式接口，它要求你先 GetMemory() 或 GetSpan() 拿缓冲区，手动拷贝数据进去，再调用 Advance() 和 FlushAsync()。跳过 FlushAsync() 就等于“写了但没送出去”。
-
GetSpan()更快但要求同步写入；GetMemory()支持异步填充（比如从Stream.ReadAsync()直接写入） - 写完必须调用
writer.Advance(bytesWritten)，否则缓冲区指针不动，下次GetSpan()还会返回同一块地址 -
FlushAsync()才真正触发数据向下游PipeReader流动，不调用它，读端永远等不到数据 - 若写入量超过单次
GetSpan().Length，需循环获取、填充、Advance、FlushAsync
和 Stream 或 NetworkStream 怎么桥接
Pipe 本身不绑定网络或文件，要对接真实 IO，得用 PipeReader.Create(stream) 或 PipeWriter.Create(stream) 包装。但注意：Create 返回的是适配器，底层仍走同步 IO，性能提升有限；真要高性能，得配合 Socket.AwaitableSocketAsyncEventArgs 或 FileStream 的异步 API 自行驱动 Pipe。
- 对
TcpClient.GetStream()，可用PipeReader.Create(networkStream)快速接入，但吞吐量受限于Stream的同步封装层 - 想榨干网卡性能，应绕过
Stream，用Socket.ReceiveAsync()读到Memory<byte>后，直接写入PipeWriter -
Pipe的优势在“零拷贝组装”和“反压协调”，不在替代底层异步机制——它是个协作中枢，不是万能加速器
实际项目里，最容易被忽略的是 AdvanceTo() 的语义精度：它不是“我读了多少”，而是“我确认能安全丢弃哪些”。错一点，轻则协议解析错位，重则整个连接卡死。别图省事用 buffer.End 硬填两个参数。
