通过匿名管道在进程间双向通信

最新推荐文章于 2021-04-01 18:34:20 发布

syd_programming

最新推荐文章于 2021-04-01 18:34:20 发布

阅读量886

点赞数

分类专栏： Visual C++ 文章标签： null attributes security buffer string output

本文链接：https://blog.csdn.net/syd_programming/article/details/4286158

版权

Visual C++ 专栏收录该内容

1 篇文章

订阅专栏

本文介绍如何使用匿名管道在父进程与子进程间建立双向通信。通过创建两个管道分别用于输入和输出，父进程能够接收子进程的数据并发送指令给子进程。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

由于匿名管道只能是单向的，因此要建立双向通信必须建立2个管道。

父程序代码：

int main() { //定义四个句炳保留两个管道的信息 HANDLE hReadPipe1, hWritePipe1, hReadPipe2, hWritePipe2; SECURITY_ATTRIBUTES sat; STARTUPINFO startupinfo; PROCESS_INFORMATION pinfo; BYTE buffer[1024]; DWORD byteRead, byteWrite; string rString; string m_Host= "Client.exe"; sat.nLength=sizeof(SECURITY_ATTRIBUTES); sat.bInheritHandle=true; sat.lpSecurityDescriptor=NULL; //创建管道，它用来做子进程的输出 if(!CreatePipe(&hReadPipe1, &hWritePipe1, &sat, NULL)) { cout<<("Create Pipe Error!")<<endl; return 1; } //创建管道，它用来做子进程的输入 if(!CreatePipe(&hReadPipe2, &hWritePipe2, &sat, NULL)) { cout<<"Create Pipe Error!"<<endl; return 1; } startupinfo.cb=sizeof(STARTUPINFO); //用GetStartupInfo获得当前进程的参数，否则STARTUPINFO参数太多，会让人抓狂 GetStartupInfo(&startupinfo); startupinfo.hStdInput = hReadPipe2; startupinfo.hStdError=hWritePipe1; startupinfo.hStdOutput=hWritePipe1; //要有STARTF_USESTDHANDLES，否则hStdInput, hStdOutput, hStdError无效 startupinfo.dwFlags=STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES; startupinfo.wShowWindow=SW_HIDE; if(!CreateProcess(NULL, (char*)m_Host.c_str(), NULL, NULL, TRUE, NULL, NULL, NULL, &startupinfo, &pinfo)) { cout<<("create process error!")<<endl; return 1; } RtlZeroMemory(buffer,1024); //进程的输出重定向到hWritePipe1，所以从hReadPipe1读取 // 在从管道中读取到数据前父进程将发生阻塞 if (ReadFile(hReadPipe1,buffer,1023,&byteRead,NULL)) { cout<<buffer; } string csWrite = "ping www.sina.com.cn/r/n"; //进程的输入重定向到hReadPipe2，所以从hWritePipe2写入 // 向管道中写数据不会发生阻塞，此循环会一直执行下去。 while (WriteFile(hWritePipe2, (LPCVOID)csWrite.c_str(), csWrite.length() + 1, &byteWrite, NULL)) { cout << "write " << byteWrite << endl; } CloseHandle(hReadPipe1); CloseHandle(hReadPipe2); CloseHandle(hWritePipe1); CloseHandle(hWritePipe2); return 0; }

子进程代码：

int main(int argc, char* argv[]) { hRead = GetStdHandle(STD_INPUT_HANDLE); hWrite = GetStdHandle(STD_OUTPUT_HANDLE); char s[] = "Hello, I am child process/n"; DWORD dwWrite; if (!WriteFile(hWrite, s, strlen(s) + 1, &dwWrite, NULL)) { out << "Write to pipe failed!" << endl; return -1; } char buf[100]; DWORD dwRead; if(!ReadFile(hRead, buf, 100, &dwRead, NULL)) { out << "Read from pipe failed!" << endl; return -1; } }