程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> C語言 >> VC >> vc教程 >> VC++下實現匿名管道

VC++下實現匿名管道

編輯:vc教程

概述

  管道(Pipe)實際是用於進程間通信的一段共享內存,創建管道的進程稱為管道服務器,連接到一個管道的進程為管道客戶機。一個進程在向管道寫入數據後,另一進程就可以從管道的另一端將其讀取出來。匿名管道(Anonymous Pipes)是在父進程和子進程間單向傳輸數據的一種未命名的管道,只能在本地計算機中使用,而不可用於網絡間的通信。

  匿名管道實施細則

  匿名管道由CreatePipe()函數創建,該函數在創建匿名管道的同時返回兩個句柄:管道讀句柄和管道寫句柄。CreatePipe()的函數原型為:  

  BOOL CreatePipe(PHANDLE hReadPipe, // 指向讀句柄的指針

   PHANDLE hWritePipe, // 指向寫句柄的指針

   LPSECURITY_ATTRIBUTES lpPipeAttributes, // 指向安全屬性的指針

   DWORD nSize // 管道大小

  );

  通過hReadPipe和hWritePipe所指向的句柄可分別以只讀、只寫的方式去訪問管道。在使用匿名管道通信時,服務器進程必須將其中的一個句柄傳送給客戶機進程。句柄的傳遞多通過繼承來完成,服務器進程也允許這些句柄為子進程所繼承。除此之外,進程也可以通過諸如DDE或共享內存等形式的進程間通信將句柄發送給與其不相關聯的進程。

  在調用CreatePipe()函數時,如果管道服務器將lpPipeAttributes 指向的SECURITY_ATTRIBUTES數據結構的數據成員bInheritHandle設置為TRUE,那麼CreatePipe()創建的管道讀、寫句柄將會被繼承。管道服務器可調用DuplicateHandle()函數改變管道句柄的繼承。管道服務器可以為一個可繼承的管道句柄創建一個不可繼承的副本或是為一個不可繼承的管道句柄創建一個可繼承的副本。CreateProcess()函數還可以使管道服務器有能力決定子進程對其可繼承句柄是全部繼承還是不繼承。

  在生成子進程之前,父進程首先調用Win32 API SetStdHandle()使子進程、父進程可共用標准輸入、標准輸出和標准錯誤句柄。當父進程向子進程發送數據時,用SetStdHandle()將管道的讀句柄賦予標准輸入句柄;在從子進程接收數據時,則用SetStdHandle()將管道的寫句柄賦予標准輸出(或標准錯誤)句柄。然後,父進程可以調用進程創建函數CreateProcess()生成子進程。如果父進程要發送數據到子進程,父進程可調用WriteFile()將數據寫入到管道(傳遞管道寫句柄給函數),子進程則調用GetStdHandle()取得管道的讀句柄,將該句柄傳入ReadFile()後從管道讀取數據。

  如果是父進程從子進程讀取數據,那麼由子進程調用GetStdHandle()取得管道的寫入句柄,並調用WriteFile()將數據寫入到管道。然後,父進程調用ReadFile()從管道讀取出數據(傳遞管道讀句柄給函數)。

  在用WriteFile()函數向管道寫入數據時,只有在向管道寫完指定字節的數據後或是在有錯誤發生時函數才會返回。如管道緩沖已滿而數據還沒有寫完,WriteFile()將要等到另一進程對管道中數據讀取以釋放出更多可用空間後才能夠返回。管道服務器在調用CreatePipe()創建管道時以參數nSize對管道的緩沖大小作了設定。

  匿名管道並不支持異步讀、寫操作,這也就意味著不能在匿名管道中使用ReadFileEx()和WriteFileEx(),而且ReadFile()和WriteFile()中的lpOverLapped參數也將被忽略。匿名管道將在讀、寫句柄都被關閉後退出,也可以在進程中調用CloseHandle()函數來關閉此句柄。
  總的來說,匿名管道程序是比較簡單的。在下面將要給出的程序示例中,將由父進程(管道服務器)創建一個子進程(管道客戶機),子進程回見個其全部的標准輸出發送到匿名管道中,父進程再從管道讀取數據,一直到子進程關閉管道的寫句柄。其中,匿名管道服務器程序的實現清單如下:  

  STARTUPINFO si;

  PROCESS_INFORMATION pi;

  char ReadBuf[100];

  DWORD ReadNum;

  HANDLE hRead; // 管道讀句柄

  HANDLE hWrite; // 管道寫句柄

  BOOL bRet = CreatePipe(&hRead, &hWrite, NULL, 0); // 創建匿名管道

  if (bRet == TRUE)

   printf("成功創建匿名管道! ");

  else

   printf("創建匿名管道失敗,錯誤代碼:%d ", GetLastError());

   // 得到本進程的當前標准輸出

   HANDLE hTemp = GetStdHandle(STD_OUTPUT_HANDLE);

   // 設置標准輸出到匿名管道

   SetStdHandle(STD_OUTPUT_HANDLE, hWrite);

   GetStartupInfo(&si); // 獲取本進程的STARTUPINFO結構信息

   bRet = CreateProcess(NULL, "Client.exe", NULL, NULL, TRUE, NULL, NULL, NULL, &si, &pi); // 創建子進程

   SetStdHandle(STD_OUTPUT_HANDLE, hTemp); // 恢復本進程的標准輸出

   if (bRet == TRUE) // 輸入信息

    printf("成功創建子進程! ");

   else

    printf("創建子進程失敗,錯誤代碼:%d ", GetLastError());

    CloseHandle(hWrite); // 關閉寫句柄

    // 讀管道直至管道關閉

    while (ReadFile(hRead, ReadBuf, 100, &ReadNum, NULL))

    {

     ReadBuf[ReadNum] = '

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved