命名管道

我們會對命名管道已知的所有問題及限制進行總結.

在一個程序中實現(xiàn)命名管道的創(chuàng)建與使用

此示例代碼意在體現(xiàn)出命名管道與普通管道的區(qū)別，命名管道是以一個普通文件的形式出現(xiàn)的，包括三個文件，創(chuàng)建命名管道、寫管道、讀管道

1. 創(chuàng)建命名管道

#include<sys/types.h>

#include<sys/stat.h>

#include<unistd.h>

#include<fcntl.h>

int main(void){

char buf[80];

int fd;

unlink("zieckey_fifo");

mkfifo("zieckey_fifo",0777);}寫命名管道代碼

#include<sys/types.h>

#include<sys/stat.h>

#include<unistd.h>

#include<fcntl.h>

int main(void){

int fd;

char s[]="Hello!\n";

fd=open("zieckey_fifo",O_WRONLY);

while(1){

write(fd,s,sizeof(s));

sleep(1);}

return0;

}

讀命名管道代碼

#include<sys/types.h>

#include<sys/stat.h>

#include<unistd.h>

#include<fcntl.h>

int main(void){

int fd;

char buf[80];

fd = open("zieckey_fifo",O_RDONLY);

while(1){

read(fd,buf,sizeof(buf));

printf("%s\n",buf);

sleep(1); }

return0;

}

命名管道是由服務器端的進程建立的，管道的命名必須遵循特定的命名方法，就是 "\\.\pipe\管道名"，當作為客戶端的進程要使用時，使用"\\計算機名\\pipe\管道名" 來打開使用，具體步驟如下:

服務端通過函數(shù) CreateNamedPipe 創(chuàng)建一個命名管道的實例并返回用于今后操作的句柄，或為已存在的管道創(chuàng)建新的實例。 服務端偵聽來自客戶端的連接請求，該功能通過 ConnectNamedPipe 函數(shù)實現(xiàn)。 客戶端通過函數(shù) WaitNamedPipe 來等待管道的出現(xiàn)，如果在超時值變?yōu)榱阋郧埃幸粋€管道可以使用，則 WaitNamedPipe 將返回 True，并通過調用 CreateFile 或 CallNamedPipe 來呼叫對服務端的連接。 此時服務端將接受客戶端的連接請求，成功建立連接，服務端 ConnectNamedPipe 返回 True 建立連接之后，客戶端與服務器端即可通過 ReadFile 和 WriteFile，利用得到的管道文件句柄，彼此間進行信息交換。 當客戶端與服務端的通信結束，客戶端調用 CloseFile，服務端接著調用 DisconnectNamedPipe。最后調用函數(shù)CloseHandle來關閉該管道。 由于命名管道使用時作為客戶端的程序必須知道管道的名稱，所以更多的用在同一"作者"編寫的服務器/工作站程序中，你不可能隨便找出一個程序來要求它和你寫的程序來通過命名管道通信。而匿名管道的使用則完全不同，它允許你和完全不相干的進程通信，條件是這個進程通過控制臺"console"來輸入輸出，典型的例子是老的 Dos 應用程序，它們在運行時 Windows 為它們開了個 Dos 窗口，它們的輸入輸出就是 console 方式的。還有一些標準的 Win32 程序也使用控制臺輸入輸出，如果在 Win32 編程中不想使用圖形界面，你照樣可以使用 AllocConsole 得到一個控制臺，然后通過 GetStdHandle 得到輸入或輸出句柄，再通過 WriteConsole 或 WriteFile 把結果輸出到控制臺(通常是一個象 Dos 窗口)的屏幕上。雖然這些程序看起來象 Dos 程序，但它們是不折不扣的 Win32 程序，如果你在純 Dos 下使用，就會顯示"The program must run under Windows!"。

一個控制臺有三個句柄:標準輸入、標準輸出和和標準錯誤句柄，標準輸入、標準輸出句柄是可以重新定向的，你可以用匿名管道來代替它，這樣一來，你可以在管道的另一端用別的進程來接收或輸入，而控制臺一方并沒有感到什么不同，就象 Dos 下的 > 或者 < 可以重新定向輸出或輸入一樣。通?？刂婆_程序的輸入輸出如下:

(控制臺進程output) write ----> 標準輸出設備(一般是屏幕)

(控制臺進程input) read <---- 標準輸入設備(一般是鍵盤)

而用管道代替后:

(作為子進程的控制臺進程output) write ----> 管道1 ----> read (父進程)

(作為子進程的控制臺進程input) read <----> 管道2 <---- write (父進程)

使用匿名管道的步驟如下:

使用 CreatePipe 建立兩個管道，得到管道句柄，一個用來輸入，一個用來輸出 準備執(zhí)行控制臺子進程，首先使用 GetStartupInfo 得到 StartupInfo 使用第一個管道句柄代替 StartupInfo 中的 hStdInput，第二個代替 hStdOutput、hStdError，即標準輸入、輸出、錯誤句柄 使用 CreateProcess 執(zhí)行子進程，這樣建立的子進程輸入和輸出就被定向到管道中 父進程通過 ReadFile 讀第二個管道來獲得子進程的輸出，通過 WriteFile 寫第一個管道來將輸入寫到子進程 父進程可以通過 PeekNamedPipe 來查詢子進程有沒有輸出 子進程結束后，要通過 CloseHandle 來關閉兩個管道。 下面是具體的說明和定義:

1. 建立匿名管道使用 CreatePipe 原形如下:

BOOL CreatePipe(

PHANDLE hReadPipe, // address of variable for read handle

PHANDLE hWritePipe, // address of variable for write handle

LPSECURITY_ATTRIBUTES lpPipeAttributes, // pointer to security attributes

DWORD nSize // number of bytes reserved for pipe

);

當管道建立后，結構中指向的 hReadPipe 和 hWritePipe 可用來讀寫管道，當然由于匿名管道是單向的，你只能使用其中的一個句柄，參數(shù)中的 SECURITY_ATTRIBUTES 的結構必須填寫，定義如下:

typedef struct_SECURITY_ATTRIBUTES{

DWORD nLength: //定義以字節(jié)為單位的此結構的長度

LPVOID lpSecurityDescriptor; //指向控制這個對象共享的安全描述符,如果為NULL這個對象將被分配一個缺省的安全描述

BOOL bInheritHandle; //當一個新過程被創(chuàng)建時,定義其返回是否是繼承的.供系統(tǒng)API函數(shù)使用.

}SECURITY_ATTRIBUTES;

2. 填寫創(chuàng)建子進程用的 STARTUPINFO 結構，一般我們可以先用 GetStartupInfo 來填寫一個缺省的結構，然后改動我們用得到的地方，它們是:

hStdInput -- 用其中一個管道的 hWritePipe 代替 hStdOutput、hStdError -- 用另一個管道的 hReadPipe 代替 dwFlags -- 設置為 STARTF_USESTDHANDLES or STARTF_USESHOWWINDOW 表示輸入輸出句柄及 wShowWindow 字段有效 wShowWindow -- 設置為 SW_HIDE，這樣子進程執(zhí)行時不顯示窗口。 填寫好以后，就可以用 CreateProcess 來執(zhí)行子進程了，具體有關執(zhí)行子進程的操作可以參考上一篇教程《進程控制》

3. 在程序中可以用 PeekNamedPipe 查詢子進程有沒有輸出，原形如下:

BOOL PeekNamedPipe(

HANDLE hNamedPipe, // handle to pipe to copy from

LPVOID lpBuffer, // pointer to data buffer

DWORD nBufferSize, // size, in bytes, of data buffer

LPDWORD lpBytesRead, // pointer to number of bytes read

LPDWORD lpTotalBytesAvail, // pointer to total number of bytes available

LPDWORD lpBytesLeftThisMessage // pointer to unread bytes in this message

);

我們可以將嘗試讀取 nBuffersize 大小的數(shù)據(jù)，然后可以通過返回的 BytesRead 得到管道中有多少數(shù)據(jù)，如果不等于零，則表示有數(shù)據(jù)可以讀取。

4. 用 ReadFile 和 WriteFile 來讀寫管道，它們的參數(shù)是完全一樣的，原形如下:

ReadFile or WriteFile(

HANDLE hFile, // handle of file to read 在這里使用管道句柄

LPVOID lpBuffer, // address of buffer that receives data 緩沖區(qū)地址

DWORD nNumberOfBytesToRead, // number of bytes to read 準備讀寫的字節(jié)數(shù)

LPDWORD lpNumberOfBytesRead, // address of number of bytes read，實際讀到的或寫入的字節(jié)數(shù)

LPOVERLAPPED lpOverlapped // address of structure for data 在這里用 NULL

);

5. 用 CloseHandle 關閉管道一和管道二的 hReadPipe和 hWritePipe 這四個句柄。

下面給出了一個例子程序，這個程序是上篇教程《進程控制》的例子的擴充，如果你對有的 api 感到陌生的話，請先閱讀上一篇教程。