### C# 与 Python 的 IPC 通信实现方法及示例代码 在实际开发中，C# 和 Python 应用之间可以通过多种方式进行进程间通信（Inter-Process Communication, IPC）。以下是基于管道（Pipe）、命名管道（Named Pipe）以及共享内存等方式的具体实现方案。 --- #### 1. **使用匿名管道（Anonymous Pipe）进行 IPC** 匿名管道适用于父子进程间的简单通信。下面是一个利用 `multiprocessing.Pipe` 的 Python 示例，展示如何通过管道实现单向或全双工的数据交换[^2]。 ##### 示例代码（Python 端） ```python from multiprocessing.connection import Pipe def python_sender(conn): conn.send("Hello from Python!") conn.close() if __name__ == "__main__": parent_conn, child_conn = Pipe() sender_process = Process(target=python_sender, args=(child_conn,)) sender_process.start() message = parent_conn.recv() print(f"Received in main process: {message}") sender_process.join() ``` 对于 C# 端，则需借助 `System.IO.Pipes` 命名空间下的类来读取来自 Python 的数据流。 ##### 示例代码（C# 端） ```csharp using System; using System.IO.Pipes; using System.Text; class Program { static void Main() { using (var pipeClient = new AnonymousPipeServerStream(PipeDirection.Out, HandleInheritability.Inheritable)) { string pipeHandle = pipeClient.GetClientHandleAsString(); Console.WriteLine($"Pipe handle: {pipeHandle}"); var readTask = Task.Run(() => { byte[] buffer = new byte[1024]; int bytesRead = pipeClient.Read(buffer, 0, buffer.Length); if (bytesRead > 0) { string data = Encoding.UTF8.GetString(buffer, 0, bytesRead); Console.WriteLine($"Data received from Python: {data}"); } }); readTask.Wait(); } } } ``` 注意：上述例子仅演示了基本概念；真实环境中可能还需要额外处理超时、异常等情况。 --- #### 2. **使用命名管道（Named Pipe）进行 IPC** 相比匿名管道，命名管道更适合跨机器甚至网络环境下的远程过程调用。它允许多个客户端连接同一个服务器端点，并支持双向通讯。 ##### 示例代码（Python 客户端） 安装必要的库： ```bash pip install pywin32 ``` 编写如下脚本模拟访问服务端： ```python import win32file import pywintypes PIPE_NAME = r'\\.\pipe\my_named_pipe' try: hPipe = win32file.CreateFile( PIPE_NAME, win32file.GENERIC_READ | win32file.GENERIC_WRITE, 0, None, win32file.OPEN_EXISTING, 0, None ) except pywintypes.error as e: print(e) else: msg_to_send = b"Request from Python" win32file.WriteFile(hPipe, msg_to_send) finally: try: response_buffer = bytearray(1024) _, resp_data = win32file.ReadFile(hPipe, len(response_buffer)) print(f"Response from server: {resp_data.decode('utf-8')}") except Exception as ex: print(ex) finally: win32file.CloseHandle(hPipe) ``` ##### 示例代码（C# 服务端） ```csharp using System; using System.IO.Pipes; using System.Text; using System.Threading.Tasks; class NamedPipeServerExample { public static async Task StartServerAsync() { using (NamedPipeServerStream pipeServer = new NamedPipeServerStream("my_named_pipe", PipeDirection.InOut)) { Console.WriteLine("Waiting for client connection..."); await pipeServer.WaitForConnectionAsync(); try { StreamString ss = new StreamString(pipeServer); ss.WriteString("Connected to C# Server."); string requestFromClient = ss.ReadString(); Console.WriteLine($"Message Received From Client: {requestFromClient}"); ss.WriteString("Acknowledged by the server!"); } catch (IOException err) { Console.Error.WriteLine(err.Message); } } } internal sealed class StreamString { private readonly Stream ioStream; private readonly UnicodeEncoding streamEncoding; public StreamString(Stream ioStream) { this.ioStream = ioStream; streamEncoding = new UnicodeEncoding(); } public string ReadString() { byte[] bytesBuffer = new byte[4]; ioStream.Read(bytesBuffer, 0, 4); int length = BitConverter.ToInt32(bytesBuffer, 0); bytesBuffer = new byte[length]; ioStream.Read(bytesBuffer, 0, length); return streamEncoding.GetString(bytesBuffer); } public void WriteString(string outString) { byte[] stringBytes = streamEncoding.GetBytes(outString); byte[] lengthBytes = BitConverter.GetBytes(stringBytes.Length); ioStream.Write(lengthBytes, 0, 4); ioStream.Write(stringBytes, 0, stringBytes.Length); } } static void Main() { while (true) { StartServerAsync().Wait(); } } } ``` 以上片段展示了完整的请求响应循环[^3]。 --- #### 3. **其他 IPC 方式简介** 除了管道外，还有诸如套接字(Socket)、文件映射(File Mapping)/共享内存(Shared Memory)等技术可供选择。每种方式各有优劣，请依据具体需求权衡选用。 ---