管道正在关闭异常

Question

有时，在某些机器上，使用我的程序的客户端经常出现“管道正在关闭”异常，但很少见。这发生在 .WaitForConnection() 上的 NamedPipeServerStream 上。之后，应用程序完全崩溃并释放 Windows 异常。当 NamedPipeClientStream 将信息传输到独立应用程序时会发生这种情况。

主要功能： 我编写了几个与 NamedPipes 通信的工具（Office 工具栏、一个服务、一个独立的 .net 应用程序和一个小启动 exe）。 服务运行一个始终打开的 NamedPipeServerStream（处于状态 .WaitForConnection();），独立应用程序也有一个 NamedPipeServerStream。 工具栏和启动程序 .exe 与服务通信。然后服务与独立应用程序。

什么样的问题可以释放管道被关闭的异常？ 服务器是否有可能将信息发送到独立应用程序但由于独立应用程序未准备好或其他原因而提前关闭流？在每个 NamedPipeClientStream 上，如果 pipeClient.IsConnected 在我关闭 pipeclient 之前，我会执行 waitforpipedrain ..

感谢帮助

编辑：这里是客户端流的示例

using (NamedPipeClientStream pipeClient =
        new NamedPipeClientStream(".", pipename, PipeDirection.Out))
{
    // Wait for a client to connect
    try
    {                            
        pipeClient.Connect(3000);

        // send params to the form
        using (StreamWriter sw = new StreamWriter(pipeClient))
        {
            sw.AutoFlush = true;
            sw.WriteLine(sendtext);
        }
    }
    // Catch the IOException that is raised if the pipe is
    // broken or disconnected.
    catch (Exception e)
    {
        if (sid != "")
        {
            connections.Remove(conName);
        }
        eventLog1.WriteEntry("SendText Fehler 1 " + e.Message);
    }
    finally
    {
        if (pipeClient.IsConnected)
        {
            pipeClient.WaitForPipeDrain();
        }
        pipeClient.Close();
        pipeClient.Dispose();
    }

管道服务器示例（在单独的线程中运行）

NamedPipeServerStream pipeServer;
PipeSecurity pipe_security = CreateSystemIoPipeSecurity();
do
    string pipename = global::TOfficeCenter.Properties.Settings.Default.pipename;
    string aText = "";
    pipeServer = new NamedPipeServerStream(pipename, PipeDirection.In, ONE_INSTANCE, PipeTransmissionMode.Byte,
                                    PipeOptions.None, IN_BUF_SIZE, OUT_BUF_SIZE, pipe_security);
    try
    {
        // Verbindung zu TOfficeCenter.exe aufbauen
        try
        {
            IsWaiting = true;
            pipeServer.WaitForConnection();
            IsWaiting = false;

            using (StreamReader sr = new StreamReader(pipeServer))
            {
                string temp;
                while ((temp = sr.ReadLine()) != null)
                {
                    aText = aText + temp;
                }
            }

            try
            {
                if (aText == "")
                {
                    empfang(null);
                }
                else
                {
                    if (aText != "KillPipe")
                    {  // XML empfangen
                        XmlDocumentTC xml = new XmlDocumentTC();
                        xml.LoadXml(aText);
                        empfang(xml);
                    }
                }
            }
            catch (Exception)
            {
                empfang(null);
            }
        }
        catch 
{...........
}       
    }

    catch (Exception e)
    {...........
    }

} while (running);

pipeServer.Close();

Answer 1

有可能我终于找到了问题..

我发现在这段代码之后：

                    using (StreamWriter sw = new StreamWriter(pipeClient))
                    {
                        sw.AutoFlush = true;
                        sw.WriteLine(sendtext);
                    }

pipeClient.IsConnected();直接返回 false，因此它永远不会到达 WaitForPipeDrain。我现在就这样做了，希望客户端在服务器完成读取之前不要关闭连接..

                    using (StreamWriter sw = new StreamWriter(pipeClient))
                    {
                        sw.AutoFlush = true;
                        sw.WriteLine(sendtext);
                        pipeClient.WaitForPipeDrain();
                    }

您认为这可以解决问题吗？自从我这样做以来，我从来没有在两台测试机上遇到过错误。但无论如何，错误很少发生..

Answer 2

我的使用有点不同，但我将把服务器线程包括在内，因为它目前主要是从 MSDN 页面被黑客入侵的：

MSDN: How to Use Named Pipes

不确定我是否需要“WaitForPipeToDrain()”，但我是从您的代码中获取的 :)

我认为每次重置 pipeServer 是清理我的 IOException 的原因。

    int threadId = Thread.CurrentThread.ManagedThreadId;
    bool sentinel = true;

    while (sentinel)
    {
        NamedPipeServerStream pipeServer =
            new NamedPipeServerStream("shapspipe", PipeDirection.InOut, 1);
        // Wait for a client to connect
        pipeServer.WaitForConnection();

        Console.WriteLine("Client connected on thread[{0}].", threadId);
        try
        {
            // Read the request from the client. Once the client has
            // written to the pipe its security token will be available.

            StreamString ss = new StreamString(pipeServer);

            // Verify our identity to the connected client using a
            // string that the client anticipates.

            ss.WriteString("I am the one true server!");
            string message = ss.ReadString();

            Console.WriteLine("received from client: " + message);

            ss.WriteString("echo from server: " + message);

            Console.WriteLine("Received from client: {0} on thread[{1}] as user: {2}.",
                message, threadId, pipeServer.GetImpersonationUserName());
        }
        // Catch the IOException that is raised if the pipe is broken
        // or disconnected.
        catch (IOException e)
        {
            Console.WriteLine("ERROR: {0}", e.Message);
        }
        pipeServer.WaitForPipeDrain();
        pipeServer.Close();
    }