Windows 命名管道问题：错误代码 233 交替出现

Question

我正在申请的申请需要帮助。这是一个响应命令行参数的简单程序。如果第一次调用应用程序，它会在专用于它的另一个线程上作为管道服务器（阻塞、非重叠）启动，而主线程则执行其他操作。现在，用户仍然可以使用相同的应用程序可执行文件和命令行参数来调用应用程序，但由于它不是应用程序的第一个实例，因此它使用管道将命令行参数传递给第一个实例，然后终止其自身。所以，它就像模式术语中的单例进程。

理想情况下，它应该是这样的：

app.exe "first"    // starts app.exe as a pipe server and prints "first"
app.exe "second"   // client process causes server instance to print "second"
app.exe "third"    // client process causes server instance to print "third"
app.exe "fourth"   // client process causes server instance to print "fourth"
app.exe "fifth"    // client process causes server instance to print "fifth"
app.exe -quit      // client process causes server instance to terminate.

现在，我唯一的问题是，当我执行上述行时，会发生这种情况：

app.exe "first"    // starts app.exe as a pipe server and prints "first"
app.exe "second"   // client process returns a GetLastError code of 233
app.exe "third"    // client process causes server instance to print "third"
app.exe "fourth"   // client process returns a GetLastError code of 233
app.exe "fifth"    // client process causes server instance to print "fifth"
app.exe -quit      // client process returns a GetLastError code of 233

我的管道服务器代码是这样的（伪代码）：

CreateNamedPipe();
// Code below now runs on a separate thread...
while( !Quit )
{
    if( ConnectNamedPipe() is successful )
    {
        if( PeekNamedPipe() has a message )
        {
            ReadFile();
            ProcessReceivedMessage();
        }
        FileFlushBuffers();
        DisconnectNamedPipe();
    }
}
CloseHandle( the pipe );

我的客户端版本是这样的（伪代码）：

if( WaitNamedPipe( FOREVER ) != 0 )
{
    GetParametersAndFormAMessage();
    CreateFile();
    WriteFile(); // Sends message to the pipe server
}
CloseHandle();

根据MSDN，如果服务器使用 DisconnectNamedPipe()，客户端将被强制断开连接，并且在客户端下次尝试时，它们将收到错误。你认为是这个原因吗？如果是这样，我如何断开客户端连接而不发生额外的错误？否则，我应该知道什么才能使这项工作成功？？？花了很多时间来解决这个问题。

Answer 1

您应该在管道的不同服务器端实例上处理与每个客户端实例的通信，为每个客户端实例使用单独的线程。因此，当 ConnectNamedPipe() 返回时，立即生成一个新的侦听器线程来等待下一个客户端，然后再处理来自刚刚连接的客户端的消息。

然后，每个客户端都将通过新创建的管道实例进行通信，并且您不会看到 ERROR_PIPE_NOT_CONNECTED 错误。

即伪代码如下：

Main Thread
{
    CreateListenerThread();
    WaitForQuitEvent();
}

ListenerThread
{
    ConnectNamedPipe();
    if (no error)
    {
        CreateListenerThread();
        if( PeekNamedPipe() has a message )
        {
            ReadFile();
            ProcessReceivedMessage(); // if -quit signal quit event
        }
        FileFlushBuffers();
        DisconnectNamedPipe();
        CloseHandle();
    }
    else
    {
        // handle/report error
    }
}