Python：win32pipe 库高级用法举例和应用详解

import win32pipe  # 导入win32pipe模块
import win32file  # 导入win32file模块
import time  # 导入time模块以进行延时

# 创建一个命名管道
pipe_name = r'\\.\pipe\my_named_pipe'
hPipe = win32pipe.CreateNamedPipe(
    pipe_name,  # 管道名称
    win32pipe.PIPE_ACCESS_DUPLEX,  # 双向访问管道
    win32pipe.PIPE_TYPE_MESSAGE | win32pipe.PIPE_READMODE_MESSAGE | win32pipe.PIPE_WAIT,  # 消息类型管道
    1,  # 允许连接的最大实例数量
    512,  # 输出缓冲区大小
    512,  # 输入缓冲区大小
    0,  # 默认超时
    None  # 默认安全属性
)

print("等待客户端连接...")
win32pipe.ConnectNamedPipe(hPipe, None)  # 等待客户端连接
print("客户端已连接，准备接收消息")

# 读取来自客户端的消息
msg, _ = win32file.ReadFile(hPipe, 512)
print("接收到的消息:", msg.decode())  # 打印接收到的消息

# 写回反馈消息
feedback = b"消息接收成功"
win32file.WriteFile(hPipe, feedback)  # 写入反馈消息

win32pipe.DisconnectNamedPipe(hPipe)  # 断开管道连接
win32pipe.CloseHandle(hPipe)  # 关闭管道句柄

import win32pipe  # 导入win32pipe模块
import win32file  # 导入win32file模块
import subprocess  # 导入subprocess模块以便启动新进程

# 创建一个匿名管道
hReadPipe, hWritePipe = win32pipe.CreatePipe()  # 创建读写管道

# 启动一个子进程
proc = subprocess.Popen(
    ["python", "child_process.py"],  # 被调用的子进程脚本
    stdin=hWritePipe,  # 设置子进程标准输入为管道写入端
    stdout=hReadPipe  # 设置子进程标准输出为管道读取端
)

# 关闭写管道端
win32file.CloseHandle(hWritePipe)

# 从子进程读取数据
data = win32file.ReadFile(hReadPipe, 1024)[1]  # 读取管道中的数据
print("从子进程接收到的数据:", data.decode())  # 打印从子进程接收到的数据

# 关闭读管道端
win32file.CloseHandle(hReadPipe)

import win32pipe  # 导入win32pipe模块
import win32file  # 导入win32file模块
import threading  # 导入threading模块以支持线程

def pipe_server():
    pipe_name = r'\\.\pipe\my_named_pipe'  # 管道名称
    hPipe = win32pipe.CreateNamedPipe(
        pipe_name,
        win32pipe.PIPE_ACCESS_DUPLEX,
        win32pipe.PIPE_TYPE_MESSAGE | win32pipe.PIPE_READMODE_MESSAGE | win32pipe.PIPE_WAIT,
        1,
        512,
        512,
        0,
        None
    )
    win32pipe.ConnectNamedPipe(hPipe, None)  # 等待客户端连接
    while True:
        msg, _ = win32file.ReadFile(hPipe, 512)  # 读取客户端消息
        if not msg:  # 如果没有消息，退出循环
            break
        print("接收到的消息:", msg.decode())  # 打印接收到的消息
        response = b"收到: " + msg  # 创建反馈消息
        win32file.WriteFile(hPipe, response)  # 发送反馈消息
    win32pipe.DisconnectNamedPipe(hPipe)  # 断开连接
    win32pipe.CloseHandle(hPipe)  # 关闭管道句柄

# 启动管道服务器线程
server_thread = threading.Thread(target=pipe_server)
server_thread.start()  # 启动线程

# 该例中只展示了服务器部分，客户端可以通过调用相同的命名管道名进行交互