c# - NamedPipeServerStream.BeginWaitForConnection 因 System.IO.Exception : The pipe is being closed 失败

我用 C# 编写了一个简单的异步 NamedPipeStreamServer 进程，其核心是:

public void Listen()
{
    bool shuttingDown = false;
    while (!shuttingDown)
    {
        NamedPipeServerStream serverStream =
            new NamedPipeServerStream(
                "bobasdfpipe",
                PipeDirection.InOut,
                254,
                PipeTransmissionMode.Message,
                PipeOptions.Asynchronous);

        IAsyncResult connectionResult =
                serverStream.BeginWaitForConnection(
                    this.HandleConnection,
                    serverStream);

        int waitResult =
            WaitHandle.WaitAny(
                new[]
                    {
                        this.ShutdownEvent,
                        connectionResult.AsyncWaitHandle
                    });
        switch (waitResult)
        {
            case 0:
                // this.ShutdownEvent
                shuttingDown = true;
                break;

            case 1:
                // connectionResult.AsyncWaitHandle
                serverStream.EndWaitForConnection(connectionResult);
                break;
        }
    }
}

我还为它编写了一个简单的客户端。客户端(不是异步的)只是打开管道然后退出:

static void Main(string[] args)
{
    using (
        NamedPipeClientStream clientStream =
            new NamedPipeClientStream(
                ".",
                "bobasdfpipe",
                PipeDirection.InOut))
    {
        clientStream.Connect();
    }
}

如果我启动服务器，然后启动一个或多个客户端，一切似乎都正常。

如果我在没有启动服务器的情况下启动客户端，客户端会挂起 Connect() 调用，直到我启动服务器，但是当我启动服务器时，服务器崩溃并在 BeginWaitForConnection( ) 调用，说“管道正在关闭”。

我发现其他人在 BeginWaitForConnection() 上有“管道正在关闭”错误，但它们都是由于在同一个 NamedPipeServerStream 实例上尝试第二次 BeginWaitForConnection() 调用引起的。这不是这里发生的事情 - 我为每个 BeginWaitForConnection() 调用创建了一个不同的 NamedPipeServerStream 实例，即使我没有，它还是在第一个 BeginWaitForConnection() 调用中失败。

难道我做错了什么？或者这只是正常的 - 等待服务器启动的命名管道客户端会在服务器的第一个 BeginWaitForConnection() 调用中导致“管道正在关闭”？

我注意到，如果我再试一次 - 即吸收异常并执行另一个 BeginWaitForConnection() - 那么对于每个一直在等待服务器启动的客户端，我都会得到一个这样的异常，但是在处理完所有这些之后，此后服务器似乎工作正常。

编辑: 这是 HandleConnection 方法，但我认为它甚至没有命中以下代码:

private void HandleConnection(IAsyncResult iar)
{
    NamedPipeServerStream serverStream =
        (NamedPipeServerStream)iar.AsyncState;

    Log.Info("So, that happened.");
    Thread.Sleep(1000);
    Log.Info("Giving up.");
}

最佳答案

看起来客户端在服务器完全处理之前关闭了连接。发生这种情况是因为 clientStream.Dispose() 在 clientStream.Connect() 之后被调用，并且即将建立的连接被终止。
提示:尝试在 Thread.Sleep(100) 之后添加 clientStream.Connect() 。



无论客户端做什么，服务器代码都应该能够通过捕获 IOException 和 丢弃服务器的管道句柄来优雅地处理这一系列事件。

   NamedPipeServerStream serverStream =
        new NamedPipeServerStream(
            "bobasdfpipe",
            PipeDirection.InOut,
            254,
            PipeTransmissionMode.Message,
            PipeOptions.Asynchronous);

    try
    {
        IAsyncResult connectionResult = serverStream.BeginWaitForConnection(
                this.HandleConnection,
                serverStream);


       int waitResult =
           WaitHandle.WaitAny(
               new[]
                {
                    this.ShutdownEvent,
                    connectionResult.AsyncWaitHandle
                });
        switch (waitResult)
        {
          case 0:
            // this.ShutdownEvent
            shuttingDown = true;
            break;

          case 1:
            // connectionResult.AsyncWaitHandle
               serverStream.EndWaitForConnection(connectionResult);
               break;
         }

    }
    catch(IOException)
    {
        // Connection terminated by client, close server pipe's handle
        serverStream.Close();
        continue;
    }

关于c# - NamedPipeServerStream.BeginWaitForConnection 因 System.IO.Exception : The pipe is being closed 失败，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/36314004/