进程间的管道通信分为匿名管道(“Anonymous Pipe”)和命名管道(“Named Pipe”)两类,匿名管道在博客文章http://blog.csdn.net/ezhchai/article/details/74974682已经进行了讨论,从上一篇文章的叙述中可以看出,匿名管道有很多缺点,比如:必须在父子进程中实现,且管道是半双工的,也就是单向的,只能一个发,另一个收。这些都给匿名管道的应用带来了很多不方便的地方。
命名管道的应用,正是为了克服匿名管道存在的这些缺陷。命名管道可以在没有亲缘关系的进程中应用,甚至在不同计算上的两个进程也可以通过命名管道实现通信,这是因为命名管道实际上是windows在网络接口上封装的进程间通信形式。命名管道可以实现一对多的通信,同时也能实现双向读写通信。
结合例子进行讲解,例程如下。首先说服务器端。命名管道服务器端负责建立命名管道通信,首先通过CreateNamedPipe函数建立管道文件,文件名作为其他程序索引此管道文件的唯一标识,如果在不同计算机上,可用网络标识代替“.”。建立网络成功后,通过ConnectNamedPipe函数在阻塞状态等待客户端链接。当客户端程序链接成功后,就可以通过ReadFile和WriteFile函数读写管道缓冲区了。显而易见,要首先启动服务器端程序。
文章中示例代码的完整工程文件可在http://download.csdn.net/download/ezhchai/9895832中下载。
服务器端代码:
// NamedPipeSrv.cpp : 定义控制台应用程序的入口点。 // #include "stdafx.h" #include<Windows.h> #include<iostream> using namespace std; int main() { char buf[256] = ""; DWORD rLen = 0; DWORD wLen = 0; HANDLE hPipe = NULL; hPipe = CreateNamedPipe( TEXT("\\\\.\\Pipe\\pipeTest"), //管道名 PIPE_ACCESS_DUPLEX, //管道类型,双向通信 PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, //管道参数 PIPE_UNLIMITED_INSTANCES, //管道能创建的最大实例数量 0, //输出缓冲区长度 0表示默认 0, //输入缓冲区长度 0表示默认 NMPWAIT_WAIT_FOREVER, //超时时间,NMPWAIT_WAIT_FOREVER为不限时等待 NULL); //指定一个SECURITY_ATTRIBUTES结构,或者传递零值. if (INVALID_HANDLE_VALUE == hPipe) cout << "Create Pipe Error: " << GetLastError() << endl; else { cout << "Waiting For Client Connection..." << endl; if (!ConnectNamedPipe(hPipe, NULL)) //阻塞等待客户端连接。 { cout << "Connection failed!" << endl; return 1; } else cout << "Connection Success!" << endl; if (!ReadFile(hPipe, buf, 256, &rLen, NULL)) //接受客户端发送数据 { cout << "Read Data From Pipe Failed!" << endl; return 2; } else cout << "From Client: data = " << buf << endl << "size = " << rLen << endl; char strMessage[] = "Server recived ezhchai!"; WriteFile(hPipe, strMessage, sizeof(strMessage), &wLen, 0); //向客户端发送数据 CloseHandle(hPipe); //关闭管道句柄 } system("pause"); return 0; }在客户端程序中,通过WaitNamedPipe函数等待管道创建成功,通过CreateFile函数连接到管道文件,当链接成功后,就和服务器端一样,通过ReadFile和WriteFile函数读写管道缓冲区了。
客户端代码:
// NamedPipeClt.cpp : 定义控制台应用程序的入口点。 // #include "stdafx.h" #include<Windows.h> #include<iostream> using namespace std; int main() { char buf[256] = ""; DWORD rLen = 0; DWORD wLen = 0; Sleep(1000); //等待管道创建成功! if (!WaitNamedPipe(TEXT("\\\\.\\Pipe\\pipeTest"), NMPWAIT_WAIT_FOREVER)) { cout << "connect the namedPipe failed!" << endl; return 1; } HANDLE hPipe = CreateFile( //创建管道文件,即链接管道 TEXT("\\\\.\\Pipe\\pipeTest"), //管道名称 GENERIC_READ | GENERIC_WRITE, //文件模式 0, //是否共享 NULL, //指向一个SECURITY_ATTRIBUTES结构的指针 OPEN_EXISTING, //创建参数 FILE_ATTRIBUTE_NORMAL, //文件属性,NORMAL为默认属性 NULL); //模板创建文件的句柄 if (INVALID_HANDLE_VALUE == hPipe) { cout << "open the exit pipe failed!" << endl; return 2; } char strMessage[] = "Send ezhchai!"; if (!WriteFile(hPipe, strMessage, sizeof(strMessage), &wLen, 0)) //向管道发送数据 { cout << "write to pipe failed!" << endl; return 3; } if (!ReadFile(hPipe, buf, 256, &rLen, NULL)) //读取管道数据 { cout << "Read Data From Pipe Failed!" << endl; return 4; } else cout << "From Server: data = " << buf << endl << "size =" << rLen <<endl; Sleep(1000); CloseHandle(hPipe); //关闭管道 system("pause"); return 0; }