如何使用命名管道客户端/服务器检测客户端断开连接？

Question

我正在学习命名管道，并正在使用 MSDN 文档中的命名管道客户端和服务器示例：

命名管道服务器

命名管道客户端

我修改了客户端，以便可以在控制台中输入消息，并将它们发送到服务器，在服务器上显示消息并发回回复。本质上，我添加了一个循环，该循环在 SetNamedPipeHandleState() 调用之后开始，在 CloseHandle() 调用之前结束（即打开和关闭发生在循环外部，因此我在循环内使用相同的管道句柄）。

我的问题是，如果我杀死客户端（通过关闭客户端或通过任务管理器结束它），服务器端是否有任何方法可以检测到断开连接？

我尝试使用 GetNamedPipeHandleState() 希望它返回失败，并且调用 GetLastError() 将返回 ERROR_PIPE_NOT_CONNECTED，但事实并非如此。由于该服务器的设置方式，我必须在 CompletedReadRoutine 函数中执行此操作并创建“受控”故障。我所做的是，在服务器中的 CompletedReadRoutine 上设置断点：

1. 启动服务器
2. 启动客户端
3. 通过客户端发送消息（在此处命中服务器中的断点）
4. 杀死客户端
5. 单步执行到 GetNamedPipeHandleState

对 GetNamedPipeHandleState() 的调用返回成功，所以我永远不需要执行 GetLastError() 调用。当它到达 WriteFileEx 调用时，它失败并且此时对 GetLastError 的调用返回 ERROR_NO_DATA。

看看管道函数，我看不到任何其他可能有帮助的东西。我丢失了一些东西，或者客户端断开连接无法检测到。

我唯一能想到的另一件事是收集连接客户端的 pid（通过 GetNamedPipeClientProcessId）并分离看门狗线程以检查它们是否仍然存在。不过，光是想到这么做就让我产生了一种蜘蛛侠般的感觉。

使用命名管道时有没有办法检测断开连接的客户端？

Answer 1

ReadFile() 不会返回错误，然后 GetLastError() 返回 ERROR_BROKEN_PIPE 吗？

Answer 2

ReadFile() + GetLastError() 做得很好。以下是它们如何与 I/O 完成端口一起使用（我的实现是在 python+ctypes 中，但想法应该很清楚）：

def connect():
    GetQueuedCompletionStatus()
    receive()

def receive():
    while True:
        ret_code = ReadFile()
        if ret_code == 0 and GetLastError() == ERROR_BROKEN_PIPE:
            # client disconnected
        GetQueuedCompletionStatus()

我们正在等待完成数据包，当客户端连接时，我们切换到主循环。在主循环中，我们读取管道并通过查看 ReadFile() 返回代码和 GetLastError() 来检查客户端是否已断开连接。然后，我们将再次等待完成数据包。

客户端可以在任何阶段断开连接。完成数据包将排队，我们将收到ERROR_BROKEN_PIPE。