具名管道用戶端
具名管道用戶端會使用 CreateFile 函式來開啟具名管道的控制碼。 如果管道存在但其所有實例忙碌中， CreateFile 會 傳回INVALID_HANDLE_VALUE ，而 GetLastError 函 式會傳回ERROR_PIPE_BUSY。 發生這種情況時，具名管道用戶端會使用 WaitNamedPipe 函式來等候具名管道的實例可供使用。
如果指定的存取與伺服器建立管道時指定的存取 (雙工、輸出或輸入) 不相容， CreateFile 函式就會失敗。 針對雙工管道，用戶端可以指定讀取、寫入或讀取/寫入存取權;對於輸出管道 (唯讀伺服器) ，用戶端必須指定唯讀存取權;對於輸入管道 (唯讀伺服器) ，用戶端必須指定唯讀存取權。
CreateFile傳回的控制碼預設為位元組讀取模式、封鎖等候模式、停用重迭模式，以及停用寫入模式。 管道用戶端可以使用 CreateFile ，藉由指定FILE_FLAG_OVERLAPPED或指定 FILE_FLAG_WRITE_THROUGH來啟用寫入模式來啟用重迭模式。 用戶端可以使用 SetNamedPipeHandleState 函式，藉由指定PIPE_NOWAIT啟用非封鎖模式，或藉由指定 PIPE_READMODE_MESSAGE 來啟用訊息讀取模式。
下列範例顯示開啟具名管道的管道用戶端、將管道控制碼設定為訊息讀取模式、使用 WriteFile 函式將要求傳送至伺服器，並使用 ReadFile 函式讀取伺服器的回復。 此管道用戶端可以與本主題底部所列的任何訊息類型伺服器搭配使用。 不過，使用位元組類型伺服器時，此管道用戶端會在呼叫 SetNamedPipeHandleState 以變更為訊息讀取模式時失敗。 由於用戶端正在讀取訊息讀取模式中的管道，因此 ReadFile 作業可以在讀取部分訊息之後傳回零。 當訊息大於讀取緩衝區時，就會發生這種情況。 在此情況下， GetLastError 會傳回ERROR_MORE_DATA，而用戶端可以使用 其他 ReadFile呼叫來讀取訊息的其餘部分。
此管道用戶端可以與 [另請參閱] 底下所列的任何管道伺服器搭配使用。
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <tchar.h>
#define BUFSIZE 512
int _tmain(int argc, TCHAR *argv[])
{
HANDLE hPipe;
LPTSTR lpvMessage=TEXT("Default message from client.");
TCHAR chBuf[BUFSIZE];
BOOL fSuccess = FALSE;
DWORD cbRead, cbToWrite, cbWritten, dwMode;
LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\mynamedpipe");
if( argc > 1 )
lpvMessage = argv[1];
// Try to open a named pipe; wait for it, if necessary.
while (1)
{
hPipe = CreateFile(
lpszPipename, // pipe name
GENERIC_READ | // read and write access
GENERIC_WRITE,
0, // no sharing
NULL, // default security attributes
OPEN_EXISTING, // opens existing pipe
0, // default attributes
NULL); // no template file
// Break if the pipe handle is valid.
if (hPipe != INVALID_HANDLE_VALUE)
break;
// Exit if an error other than ERROR_PIPE_BUSY occurs.
if (GetLastError() != ERROR_PIPE_BUSY)
{
_tprintf( TEXT("Could not open pipe. GLE=%d\n"), GetLastError() );
return -1;
}
// All pipe instances are busy, so wait for 20 seconds.
if ( ! WaitNamedPipe(lpszPipename, 20000))
{
printf("Could not open pipe: 20 second wait timed out.");
return -1;
}
}
// The pipe connected; change to message-read mode.
dwMode = PIPE_READMODE_MESSAGE;
fSuccess = SetNamedPipeHandleState(
hPipe, // pipe handle
&dwMode, // new pipe mode
NULL, // don't set maximum bytes
NULL); // don't set maximum time
if ( ! fSuccess)
{
_tprintf( TEXT("SetNamedPipeHandleState failed. GLE=%d\n"), GetLastError() );
return -1;
}
// Send a message to the pipe server.
cbToWrite = (lstrlen(lpvMessage)+1)*sizeof(TCHAR);
_tprintf( TEXT("Sending %d byte message: \"%s\"\n"), cbToWrite, lpvMessage);
fSuccess = WriteFile(
hPipe, // pipe handle
lpvMessage, // message
cbToWrite, // message length
&cbWritten, // bytes written
NULL); // not overlapped
if ( ! fSuccess)
{
_tprintf( TEXT("WriteFile to pipe failed. GLE=%d\n"), GetLastError() );
return -1;
}
printf("\nMessage sent to server, receiving reply as follows:\n");
do
{
// Read from the pipe.
fSuccess = ReadFile(
hPipe, // pipe handle
chBuf, // buffer to receive reply
BUFSIZE*sizeof(TCHAR), // size of buffer
&cbRead, // number of bytes read
NULL); // not overlapped
if ( ! fSuccess && GetLastError() != ERROR_MORE_DATA )
break;
_tprintf( TEXT("\"%s\"\n"), chBuf );
} while ( ! fSuccess); // repeat loop if ERROR_MORE_DATA
if ( ! fSuccess)
{
_tprintf( TEXT("ReadFile from pipe failed. GLE=%d\n"), GetLastError() );
return -1;
}
printf("\n<End of message, press ENTER to terminate connection and exit>");
_getch();
CloseHandle(hPipe);
return 0;
}
相關主題