.NET中Network Stream读取时如何判断流结束？

问题本质：TCP是流式协议，无“消息边界” #

你遇到的行为是完全正常的，和Linux Ubuntu环境无关。TCP是面向流的协议，它不会主动告知你“当前数据已发送完毕”——ReadAsync返回0的唯一场景是对方主动关闭了TCP连接（发送FIN包）。如果对方只是停止发送数据但保持连接，ReadAsync会一直阻塞等待新数据，这是TCP的核心特性。

你的第一个代码为何无法触发received == 0？ #

只有当客户端主动调用Socket.Close()或NetworkStream.Dispose()关闭连接时，服务端的ReadAsync才会返回0。如果客户端只是发送完数据但没关闭连接，服务端会一直等待，永远到不了received == 0的分支。

用received < buffer.Length判断结束的问题 #

这种逻辑是错误的，因为TCP会根据网络状况自动拆分包：

• 比如客户端发送100字节数据，你用64字节缓冲区，第一次读取64字节，第二次读取36字节（36<64），但此时客户端可能还会继续发送后续数据，你直接break会丢失后续内容。
• 这种逻辑仅适用于“客户端只发送一次固定长度数据，且长度不超过缓冲区”的极端场景，不具备通用性。

PipeReader的正确处理方式 #

你的PipeReader代码方向是对的，但有两个细节需要修正：

1. 判断流结束的核心是result.IsCompleted：当对方关闭连接时，result.IsCompleted会被设为true，这是PipeReader告知你流已结束的标准方式，result.Buffer.Length == 0是流结束的伴随状态，可以作为补充判断，但主要依赖IsCompleted。
2. 处理UTF8字符时避免拆分Segment：ReadOnlySequence<byte>可能包含多个Segment，直接遍历每个Segment转字符串会破坏跨Segment的多字节UTF8字符（比如中文、emoji）。正确的做法是将整个ReadOnlySequence<byte>转换为完整的字符串。

修正后的PipeReader代码示例：

private static async Task ProcessWithPipes(NetworkStream stream)
{
    var reader = PipeReader.Create(stream);

    try
    {
        while (true)
        {
            var result = await reader.ReadAsync();    
            var buffer = result.Buffer;

            // 处理接收到的数据：将整个ReadOnlySequence转为字符串，避免拆分多字节字符
            if (buffer.Length > 0)
            {
                var message = Encoding.UTF8.GetString(buffer);
                Console.WriteLine(message);
            }

            // 判断流是否结束
            if (result.IsCompleted)
            {
                Console.WriteLine("Stream Reading Completed, Client Closed");
                break;
            }

            // 告知PipeReader已处理完当前缓冲区
            reader.AdvanceTo(buffer.End);
        }
        await reader.CompleteAsync();
    }
    catch (Exception ex)
    {
        Console.WriteLine($"Error: {ex.Message}");
        await reader.CompleteAsync(ex);
    }
}

额外说明：如果需要“消息边界”怎么办？ #

如果你的场景需要区分“单次消息”（而非无限流），TCP本身不提供这个能力，需要自己在应用层定义协议：

• 固定长度消息：每次发送固定字节数，接收端按固定长度读取。
• 前缀长度：每个消息前加4字节表示消息总长度，接收端先读长度再读对应字节数。
• 分隔符：用特殊字符（如\n）分隔消息，接收端按分隔符拆分。

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