在C#和Python之间命名管道

Question

我正在尝试在两个程序之间创建一个双向通信通道(一个在Python中,另一个在C#中)

当我在两个C#程序或两个Python程序之间创建命名管道时,一切正常,但是当我尝试(例如)从Python代码连接到C#服务器时,它不起作用:

C#代码:

NamedPipeServerStream server = new NamedPipeServerStream(
    "Demo", PipeDirection.InOut, 100, PipeTransmissionMode.Byte,
    PipeOptions.None, 4096, 4096)

如果我win32pipe在Python中使用代码块ConnectNamedPipe(它永远不会返回)

p = win32pipe.CreateNamedPipe(
    r'\\.\pipe\Demo',
    win32pipe.PIPE_ACCESS_DUPLEX,
    win32pipe.PIPE_TYPE_BYTE | win32pipe.PIPE_WAIT,
    1, 65536, 65536,
    300,
    None)
win32pipe.ConnectNamedPipe(p)

如果我使用open函数,它只是建立一个连接,但没有任何反应:

open( '\\\\.\\pipe\\Demo', 'r+b' )

现在,如果我关闭Python程序,C#服务器只接收来自Python的一个数据项,并System.IO.IOException引发"管道已损坏"消息

我做错了吗？

Answer 1

根据MS，ConnectNamedPipe是“用于接受连接的服务器端功能”。这就是它永远不会返回的原因——它正在等待来自客户端的连接。下面是一些示例代码，将 C# 显示为服务器，将 python 显示为客户端：

C＃：

using (var server = new NamedPipeServerStream("Demo"))
{
    server.WaitForConnection();

    using (var stream = new MemoryStream())
    using (var writer = new BinaryWriter(stream))
    {
        writer.Write("\"hello\"");
        server.Write(stream.ToArray(), 0, stream.ToArray().Length);
    }

    server.Disconnect();
}

Python：

import win32file
fileHandle = win32file.CreateFile(
    "\\\\.\\pipe\\Demo", 
    win32file.GENERIC_READ | win32file.GENERIC_WRITE, 
    0, 
    None, 
    win32file.OPEN_EXISTING, 
    0, 
    None)
left, data = win32file.ReadFile(fileHandle, 4096)
print(data)  # "hello"

Answer 2

好的，我解决了问题。我应该寻找缓冲区的位置 0。

我的Python代码：

    win32file.WriteFile(CLIENT_PIPE,"%d\r\n"%i ,None)
    win32file.FlushFileBuffers(CLIENT_PIPE)
    win32file.SetFilePointer(CLIENT_PIPE,0,win32file.FILE_BEGIN)
    i,s = win32file.ReadFile(CLIENT_PIPE,10,None)