Windows命名管道：当阅读器关闭其末端而无需写入数据时，在编写器端检测Python

Question

我的应用程序将数据流式传输（写入）到命名管道，在调用应用程序时将管道名称指定为 CLI 参数。流数据是不规则的，其中可能没有任何数据可以通过管道发送。

我想检测从管道读取的其他进程何时结束，以便快速释放我的应用程序为流式传输分配的资源。我现在的问题是甚至检测到管道的读取端已经关闭，而没有向管道中写入任何内容。

由于流数据格式是固定的并且不允许空写入或 ping，即使我没有要流式传输的内容，我也不能简单地尝试写入一些管道数据以查看管道读取器是否仍在读取。

我在 Linux 上有一个可行的解决方案，不幸的是它在 Windows 上不起作用，因为 Windows 命名管道不能像在 Linux 上一样在 select() 中统一处理。在 Linux 上，我只需检查管道的写入端是否可以读取，因为这表示管道错误，然后关闭管道并释放我分配的资源。

在 Windows 上，这是不可能的。我已经打开了这样写的管道：

fifo = open('//./pipe/somepipe', 'wb')

从管道尝试fifo.read() 不起作用（正如预期的那样）并立即抛出OSException。

正如我所说，我不能尝试一些空/nul 写入； fifo.write(b'') 什么都不做，甚至根本不戳管道以获得可写性。

在 Windows 上是否有任何方法可以测试命名管道的写入端以查看读取器（客户端）是否仍然连接？

Answer 1

正如@eryksun 上面指出的那样，实际上可以直接使用Win32 API WriteFile 编写一个探测零长度字节字符串：如果管道关闭，那么这将返回“不成功”（false/0 )，如果管道是活动的，则“成功”(true/!=0)。正是我所要求的。因为我发现这比使用NtQueryInformationFile 更简单，所以我现在使用的是空写方法；这是一个简化的例子：

import ctypes
from ctypes import byref, c_ulong, c_char_p
import msvcrt
kernel32 = ctypes.WinDLL('kernel32', use_last_error=True)

fifo = open('//./pipe/somepipe', 'wb')
data = b''
written = c_ulong(0)
if not kernel32.WriteFile(
        msvcrt.get_osfhandle(fifo.fileno()),
        c_char_p(data), 0, 
        byref(written), 
        None):
    last_error = ctypes.get_last_error()
    if last_error in (
            0x000000E8,  # ERROR_NO_DATA
            # enable as required: 0x000000E9,  # ERROR_PIPE_NOT_CONNECTED
    ):
        # pipe broken
        pass
    else:
        # something else is wrong...
        pass
else:
    # pipe still okay
    pass

有用的资源：

• Answer to: How to get a win32 handle of an open file in python?
• Answer to: How to use win32 API's with python? 然后直接链接到我的问题：
  • Example Code - Named Pipes (Python 2.4 + ctypes on Windows)
• cmets 部分 ;)