命名管道客户端
命名管道客户端使用 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;
}
相关主题