System.IO.Exception：管道损坏

Question

我有两个通过命名管道相互通信的 .NET 应用程序。第一次一切都很好，但是在发送第一条消息之后，服务器将再次侦听，WaitForConnection() 方法抛出 System.IO.Exception 消息 Pipe is broken.
为什么我在这里得到这个异常？这是我第一次使用管道，但过去使用套接字的类似模式也适用于我。

代码啊！
服务器：

using System.IO.Pipes;

static void main()
{
    var pipe = new NamedPipeServerStream("pipename", PipeDirection.In);
    while (true)
    {
        pipe.Listen();
        string str = new StreamReader(pipe).ReadToEnd();
        Console.Write("{0}", str);
    }
}

客户：

public void sendDownPipe(string str)
{
    using (var pipe = new NamedPipeClientStream(".", "pipename", PipeDirection.Out))
    {
        using (var stream = new StreamWriter(pipe))
        {
            stream.Write(str);
        }
    }
}

对 sendDownPipe 的第一次调用让服务器打印我发送的消息就好了，但是当它循环回来再次收听时，它便便。

Answer 1

我将发布我的似乎可以工作的代码 - 我很好奇，因为我从未对管道做过任何事情。我在相关命名空间中没有找到你为服务器端命名的类，所以这里是基于 NamedPipeServerStream 的代码。回调的东西只是因为我不能为两个项目而烦恼。

NamedPipeServerStream s = new NamedPipeServerStream("p", PipeDirection.In);
Action<NamedPipeServerStream> a = callBack;
a.BeginInvoke(s, ar => { }, null);
...
private void callBack(NamedPipeServerStream pipe)
{
  while (true)
  {
    pipe.WaitForConnection();
    StreamReader sr = new StreamReader(pipe);
    Console.WriteLine(sr.ReadToEnd());
    pipe.Disconnect();
  }
}

客户端会这样做：

using (var pipe = new NamedPipeClientStream(".", "p", PipeDirection.Out))
using (var stream = new StreamWriter(pipe))
{
  pipe.Connect();
  stream.Write("Hello");
}

我可以在服务器运行的情况下多次重复上面的块，没有问题。

Answer 2

在客户端断开连接后，我从服务器调用 pipe.WaitForConnection() 时出现了问题。解决方法是捕获IOException并调用pipe.Disconnect()，然后再次调用pipe.WaitForConnection()：

while (true)
{
    try
    {
        _pipeServer.WaitForConnection();
        break;
    }
    catch (IOException)
    {
        _pipeServer.Disconnect();
        continue;
    }            
 }

Answer 3

我遇到了同样的问题 - 它是由 Using...End Using 处理服务器的 StreamReader 引起的，这也取消了 NamedPipeServerStream。解决方案就是不要使用...结束使用它并信任垃圾收集器。