如何检查NamedPipeClientStream是否存在可读数据？

你提到的这个阻塞问题确实是NamedPipeClientStream同步读取的常见痛点——StreamReader的ReadLine()本质还是依赖底层流的同步读取逻辑，没有数据时自然会卡住线程。好在我们有几种可靠的方式来规避这个问题，结合PipeStream的特性实现非阻塞或预检查的读取：

方法1：利用Available属性预检查可读字节 #

虽然PipeStream不支持Length、ReadTimeout这些属性，但它提供了**Available**属性，能直接获取当前流中可立即读取的字节数。我们可以在读取前先判断这个值，彻底避免阻塞：

NamedPipeClientStream myPipe = // 初始化你的管道实例
byte[] buffer = new byte[1024]; // 根据实际传输数据大小调整缓冲区
while (true)
{
    // 先检查是否有可读取的字节
    if (myPipe.Available > 0)
    {
        int bytesRead = myPipe.Read(buffer, 0, buffer.Length);
        // 根据你的实际编码格式调整，这里以UTF-8为例
        string receivedText = Encoding.UTF8.GetString(buffer, 0, bytesRead);
        Console.WriteLine("Received from server: {0}", receivedText);
    }

    // 加入短暂休眠，避免无数据时CPU空转
    System.Threading.Thread.Sleep(100);
    // 这里可以插入你需要线程持续处理的其他业务逻辑
}

注意：当管道被远端关闭时，Read()方法会返回0，你可以在此时退出循环，避免程序无限运行。

方法2：使用异步读取（推荐） #

如果你的线程需要同时处理其他任务，异步读取是更优雅的方案——StreamReader.ReadLineAsync()不会阻塞当前线程，线程可以在等待数据时去执行其他逻辑：

StreamReader sr = new StreamReader(myPipe);
while (true)
{
    // 异步读取，线程不会被挂起阻塞
    string temp = await sr.ReadLineAsync();
    if (temp != null)
    {
        Console.WriteLine("Received from server: {0}", temp);
    }

    // 可以加入短暂延迟，或者直接处理其他异步任务
    await Task.Delay(100);
}

这种方式更贴合现代.NET的异步编程模型，能更高效地利用线程资源，避免线程被闲置浪费。

为什么直接用StreamReader会阻塞？ #

因为StreamReader.ReadLine()的同步实现会一直等待，直到读到换行符或者流结束——它不会主动检查底层流是否有可用数据，所以当管道没有数据时，线程就会被挂起。而我们上面的两种方法，要么提前检查可用字节，要么用异步方式让线程去处理其他任务，完美解决了你的需求。

内容的提问来源于stack exchange，提问作者Kapten-N