StreamWriter 在其包裹的 Pipe 未排空时无法关闭？

Question

我有一个使用命名管道的简单服务器-客户端应用程序。我在服务器中使用 StreamWriter，在客户端中使用 StreamReader。只要客户端进程不从管道读取（即不从 StreamReader 读取，包装管道），StreamWriter 就不会被释放。我想知道为什么。

详情如下：

这是服务器：

using System;
using System.IO;
using System.IO.Pipes;

class PipeServer
{
    static void Main()
    {
        using (NamedPipeServerStream pipeServer =
            new NamedPipeServerStream("testpipe"))
        {
            Console.Write("Waiting for client connection...");
            pipeServer.WaitForConnection();
            Console.WriteLine("Client connected.");

            try
            {
                StreamWriter sw = new StreamWriter(pipeServer);
                try
                {
                    sw.WriteLine("hello client!");
                }
                finally
                {
                    sw.Dispose();
                }
                // Would print only after the client finished sleeping
                // and reading from its StreamReader
                Console.WriteLine("StreamWriter is now closed"); 
            }
            catch (IOException e)
            {
                Console.WriteLine("ERROR: {0}", e.Message);
            }
        }
    }
}

这是客户：

using System;
using System.IO;
using System.IO.Pipes;
using System.Threading;

class PipeClient
{
    static void Main(string[] args)
    {
        using (NamedPipeClientStream pipeClient =
            new NamedPipeClientStream(".", "testpipe"))
        {
            Console.Write("Attempting to connect to pipe...");
            pipeClient.Connect();
            Console.WriteLine("Connected to pipe.");

            using (StreamReader sr = new StreamReader(pipeClient))
            {
                Thread.Sleep(100000);

                string temp = sr.ReadLine();
                if (temp != null)
                {
                    Console.WriteLine("Received from server: {0}", temp);
                }
            }
        }
    }
}

注意客户端中的Thread.Sleep(100000);：我添加它是为了确保只要客户端进程处于休眠状态，StreamWriter 就不会被释放到服务器中，并且服务器不会执行Console.WriteLine("StreamWriter is now closed");。为什么？

编辑：

我切断了之前的信息，我认为这些信息可能无关紧要。 我还想补充一点——多亏了 cmets 中的 Scott——我观察到这种行为发生了相反的情况：如果服务器写入，然后休眠，客户端（尝试）使用它的 StreamReader 读取——读取是'在服务器唤醒之前不会发生。

第二次编辑：

我在第一次编辑中谈到的其他方式的行为无关紧要，这是一个flush 问题。 我试着给它更多的试验，并得出结论斯科特是对的——如果不排干管道就不能处理。那为什么？这似乎也与 StreamWriter 假定它拥有流的事实相矛盾，除非另有说明（参见 here）。

以下是上面代码中添加的细节：

在服务器程序中，try-finally 现在看起来像这样：

try
{
    sw.AutoFlush = true;
    sw.WriteLine("hello client!");
    Thread.Sleep(10000);
    sw.WriteLine("hello again, client!");
}
finally
{
    sw.Dispose(); // awaits while client is sleeping
}
Console.WriteLine("StreamWriter is now closed");

在客户端程序中，using 块现在如下所示：

using (StreamReader sr = new StreamReader(pipeClient))
{
    string temp = sr.ReadLine();
    Console.WriteLine("blah"); // prints while server sleeps

    Console.WriteLine("Received from server: {0}", temp); // prints while server is sleeping
    Thread.Sleep(10000);

    temp = sr.ReadLine();
    Console.WriteLine("Received from server: {0}", temp);
}

Answer 1

所以问题在于 Windows 命名管道的工作方式。当CreateNamedPipe 被调用时，您可以指定输出缓冲区大小。现在文档是这样说的：

输入和输出缓冲区大小是建议性的。为命名管道的每一端保留的实际缓冲区大小是系统默认值、系统最小值或最大值，或者是向上舍入到下一个分配边界的指定大小。

这里的问题是 NamedPipeServerStream 构造函数将 0 作为默认输出大小传递（我们可以使用源代码验证这一点，或者在我的情况下只是启动 ILSpy）。根据注释，您可能会假设这将创建一个“默认”缓冲区大小，但事实并非如此，它实际上创建了一个 0 字节的输出缓冲区。这意味着除非有人正在读取缓冲区，否则对管道的任何写入都会阻塞。您还可以使用OutBufferSize 属性验证大小。

您看到的行为是因为当您处理 StreamWriter 时，它会在管道流上调用 Write（因为它已经缓冲了内容）。 write 调用阻塞，因此 Dispose 永远不会返回。

为了验证这一点，我们将使用 WinDBG（因为 VS 仅在 sw.Dispose 调用中显示阻塞线程）。

在 WinDBG 下运行服务器应用程序。当它阻塞时暂停调试器（例如按 CTRL+Break）并发出以下命令：

加载 SOS 调试器模块：.loadby sos clr

使用交错的托管和非托管堆栈帧转储所有正在运行的堆栈（由于 sos.dll 中的愚蠢错误，可能需要运行两次）：!eestack

您应该看到该过程中的第一个堆栈看起来像这样（为简洁起见进行了大量编辑）：

Thread   0
Current frame: ntdll!NtWriteFile+0x14
KERNELBASE!WriteFile+0x76, calling ntdll!NtWriteFile
System.IO.Pipes.PipeStream.WriteCore
System.IO.StreamWriter.Flush(Boolean, Boolean))
System.IO.StreamWriter.Dispose(Boolean))

所以我们可以看到我们被卡在了 NtWriteFile 中，这是因为它无法将字符串写入大小为 0 的缓冲区。

要解决此问题很容易，请使用 NamedPipeServerStream 构造函数之一指定显式输出缓冲区大小，例如 this 之一。例如，这将执行默认构造函数将执行的所有操作，但输出缓冲区大小合理：

new NamedPipeServerStream("testpipe", PipeDirection.InOut, 1, PipeTransmissionMode.Byte, PipeOptions.None, 0, 4096)