命名管道是Windows系统下一种基于文件系统实现的进程间通讯机制,它会在系统中创建一个有唯一名称的管道对象,不同进程可以通过这个名称打开管道完成数据读写,支持同一台机器上的进程通讯,也支持跨网络的进程通讯,相比匿名管道使用场景更广泛。

命名管道跨进程通讯的核心原理
命名管道的工作模式是典型的一对多服务端客户端模式,整体流程可以分为几个核心步骤:
- 服务端首先创建命名管道对象,指定管道的名称、传输方向、缓冲区大小等参数,然后进入监听状态等待客户端连接
- 客户端通过管道名称发起连接请求,服务端接收到请求后建立连接,此时双方就可以进行数据交互
- 通讯完成后,服务端可以选择关闭当前连接继续等待新的客户端连接,或者关闭整个管道对象,客户端也需要关闭对应的管道句柄
命名管道的名称有固定的格式,本地管道的命名格式为\.pipe管道名称,如果是跨网络访问,格式为\远程机器IPpipe管道名称,管道名称需要全局唯一,否则创建会失败。
Windows下C++实现命名管道跨进程通讯
服务端实现
服务端需要先创建管道,然后等待客户端连接,连接成功后就可以进行读写操作,以下是完整的服务端示例代码:
#include <windows.h>
#include <iostream>
#include <cstring>
#define PIPE_NAME L"\\.\pipe\TestNamedPipe"
#define BUFFER_SIZE 1024
int main() {
HANDLE hPipe;
char buffer[BUFFER_SIZE];
DWORD dwRead, dwWritten;
// 创建命名管道
hPipe = CreateNamedPipe(
PIPE_NAME,
PIPE_ACCESS_DUPLEX, // 双向访问
PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT, // 字节模式,阻塞读写
1, // 最大实例数
BUFFER_SIZE, // 输出缓冲区大小
BUFFER_SIZE, // 输入缓冲区大小
0,
NULL
);
if (hPipe == INVALID_HANDLE_VALUE) {
std::cout << "创建命名管道失败,错误码:" << GetLastError() << std::endl;
return 1;
}
std::cout << "命名管道创建成功,等待客户端连接..." << std::endl;
// 等待客户端连接
if (ConnectNamedPipe(hPipe, NULL)) {
std::cout << "客户端连接成功" << std::endl;
// 读取客户端发送的数据
if (ReadFile(hPipe, buffer, BUFFER_SIZE, &dwRead, NULL)) {
buffer[dwRead] = ' ';
std::cout << "接收到客户端数据:" << buffer << std::endl;
// 向客户端发送响应数据
const char* response = "服务端已收到你的消息";
WriteFile(hPipe, response, strlen(response), &dwWritten, NULL);
} else {
std::cout << "读取数据失败,错误码:" << GetLastError() << std::endl;
}
// 断开客户端连接
DisconnectNamedPipe(hPipe);
} else {
std::cout << "客户端连接失败,错误码:" << GetLastError() << std::endl;
}
// 关闭管道句柄
CloseHandle(hPipe);
return 0;
}
客户端实现
客户端需要先尝试连接服务端创建的命名管道,连接成功后就可以和服务端进行数据交互,以下是客户端示例代码:
#include <windows.h>
#include <iostream>
#include <cstring>
#define PIPE_NAME L"\\.\pipe\TestNamedPipe"
#define BUFFER_SIZE 1024
int main() {
HANDLE hPipe;
char buffer[BUFFER_SIZE];
DWORD dwRead, dwWritten;
// 等待命名管道实例可用
if (!WaitNamedPipe(PIPE_NAME, 5000)) {
std::cout << "等待命名管道超时" << std::endl;
return 1;
}
// 打开命名管道
hPipe = CreateFile(
PIPE_NAME,
GENERIC_READ | GENERIC_WRITE,
0,
NULL,
OPEN_EXISTING,
0,
NULL
);
if (hPipe == INVALID_HANDLE_VALUE) {
std::cout << "打开命名管道失败,错误码:" << GetLastError() << std::endl;
return 1;
}
std::cout << "成功连接到服务端" << std::endl;
// 向服务端发送数据
const char* sendData = "这是客户端发送的消息";
if (WriteFile(hPipe, sendData, strlen(sendData), &dwWritten, NULL)) {
std::cout << "数据发送成功" << std::endl;
// 读取服务端响应
if (ReadFile(hPipe, buffer, BUFFER_SIZE, &dwRead, NULL)) {
buffer[dwRead] = ' ';
std::cout << "接收到服务端响应:" << buffer << std::endl;
} else {
std::cout << "读取响应失败,错误码:" << GetLastError() << std::endl;
}
} else {
std::cout << "发送数据失败,错误码:" << GetLastError() << std::endl;
}
// 关闭管道句柄
CloseHandle(hPipe);
return 0;
}
使用命名管道跨进程通讯的注意事项
- 管道名称必须全局唯一,否则服务端创建管道时会返回错误,建议名称包含业务标识避免冲突
- CreateNamedPipe的第二个参数可以设置管道的访问权限,如果涉及跨网络通讯,需要确保防火墙允许对应的端口访问
- 读写操作可以选择阻塞模式或者非阻塞模式,阻塞模式下ReadFile和WriteFile会一直等待直到操作完成,非阻塞模式需要配合重叠IO使用
- 多个客户端连接同一个服务端时,服务端需要创建多个管道实例,或者在一个客户端断开后重新进入监听状态
- 进程退出前一定要关闭管道句柄,否则会导致管道资源泄漏,其他进程无法正常创建同名管道
命名管道与其他跨进程通讯方式对比
以下是命名管道和常见跨进程通讯方式的简单对比:
| 通讯方式 | 适用场景 | 优点 | 缺点 |
|---|---|---|---|
| 命名管道 | 本地或跨网络进程通讯,数据量中等 | 使用简单,支持双向传输,可跨网络 | 传输效率不如共享内存,不支持多对多广播 |
| 共享内存 | 本地大文件、大数据量传输 | 传输效率最高,无需内核拷贝 | 需要自己处理同步问题,不支持跨网络 |
| 消息队列 | 异步消息传递场景 | 支持异步,解耦发送和接收方 | 数据量有限制,传输效率一般 |
| Socket | 跨网络进程通讯 | 通用性强,支持跨平台 | 实现相对复杂,本地通讯效率不如命名管道 |
实际开发中可以根据具体的业务场景选择合适的跨进程通讯方式,如果是Windows平台下的本地或跨网络中等数据量通讯,命名管道是非常合适的选择。