windows命名管道需设file_flag_overlapped实现异步通信,linux用mkfifo后两端open须配对(o_rdonly/o_wronly),跨平台推荐boost.interprocess统一封装。

Windows 上用 CreateNamedPipe 建管道,别漏掉 FILE_FLAG_OVERLAPPED
Windows 的命名管道默认是同步阻塞的,CreateNamedPipe 返回句柄后,一旦调用 ConnectNamedPipe,线程就卡住,直到客户端连上来——这在服务端逻辑里基本不可用。真正能配合多客户端、不阻塞主线程的做法,是开异步模式:dwFlagsAndAttributes 参数必须传 FILE_FLAG_OVERLAPPED,且后续所有 I/O(ReadFile、WriteFile)都得配 OVERLAPPED 结构体。
常见错误现象:ConnectNamedPipe 一直阻塞、ReadFile 突然返回 ERROR_IO_PENDING 却没做完成端口或事件等待——其实是异步启动了,但没人收结果。
- 服务端创建时,
dwOpenMode推荐用PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED - 客户端用
CreateFile连接,路径格式必须是\\.\pipe\MyPipeName,少一个反斜杠或大小写错都会报ERROR_FILE_NOT_FOUND - 异步读写后务必检查返回值:成功时返回非零;失败且
GetLastError() == ERROR_IO_PENDING才算正常异步启动
Linux 下 mkfifo 创建后,open 要配对使用 O_RDONLY/O_WRONLY
Linux 命名管道本质是文件系统节点,mkfifo("/tmp/my_pipe", 0666) 只是建个“壳”,真要通信,两端 open() 必须一读一写——不能两边都用 O_RDWR,也不能都用 O_RDONLY,否则 open 会永久阻塞。这是初学者最常栽跟头的地方。
使用场景:适合简单的一对一进程通信,比如日志收集器从子进程读结构化数据;不适合高频小包或广播。
- 服务端(reader)用
open("/tmp/my_pipe", O_RDONLY)—— 阻塞直到有 writer 打开 - 客户端(writer)用
open("/tmp/my_pipe", O_WRONLY)—— 阻塞直到有 reader 打开 - 如果想避免阻塞,writer 可加
O_NONBLOCK,但此时open在无 reader 时直接失败,返回 -1 并设errno = ENXIO -
read()返回 0 表示 writer 已关闭 fd,不是错误,该退出循环了
跨平台代码别硬写两套,优先考虑 Boost.Interprocess 的 named_mutex + message_queue
纯 C++ 标准库不提供命名管道抽象,自己封装 Windows/Linux 两套逻辑极易出错:权限位、路径格式、缓冲区语义、断连检测都不一样。与其反复踩坑,不如用 Boost.Interprocess 提供的高层封装——它底层自动适配,API 统一,且自带序列化和同步原语。
性能影响:比裸系统调用多一层序列化/反序列化,但对大多数 IPC 场景(如配置下发、状态通知)可忽略;兼容性上,Boost 1.56+ 对 Windows 和主流 Linux 发行版支持稳定。
- 发送端:
boost::interprocess::message_queue::send(),自动处理阻塞/超时 - 接收端:
message_queue::receive(),支持带优先级的消息 - 注意:队列名在 Windows 是全局内核对象名(如
"MyMQ"),Linux 是文件路径(如"/MyMQ"),但 API 完全一致 - 别忘了链接
-lboost_interprocess,且确保运行时能找到对应动态库
ERROR_PIPE_BUSY 和 EAGAIN 不是 bug,是设计信号
Windows 下 CreateNamedPipe 失败报 ERROR_PIPE_BUSY,Linux 下 open 报 EAGAIN 或 ENXIO,都不是异常,而是机制的一部分:命名管道要求两端“握手”才建立连接。强行忽略这些错误、不做重试,会导致通信永远起不来。
容易被忽略的地方:Windows 服务端收到 ERROR_PIPE_BUSY 后,应该调用 WaitNamedPipe 等待空闲实例,再重试 CreateNamedPipe;Linux 客户端遇到 ENXIO,应 sleep 后重试 open,而不是直接 abort。
- Windows 重试模板:
if (GetLastError() == ERROR_PIPE_BUSY) { WaitNamedPipe(L"\\.\pipe\MyPipe", NMPWAIT_WAIT_FOREVER); } - Linux 重试模板:
while ((fd = open("/tmp/my_pipe", O_WRONLY | O_NONBLOCK)) == -1 && errno == ENXIO) { usleep(10000); } - 别在循环里狂试,加指数退避或上限次数,否则 CPU 打满还卡死
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











