具名管道上的交易
具名管道交易是用戶端/伺服器通訊，可將寫入作業和讀取作業結合成單一網路作業。 交易只能在雙工訊息類型管道上使用。 交易可改善用戶端與遠端伺服器之間的網路通訊效能。 進程可以使用 TransactNamedPipe 和 CallNamedPipe 函式來執行具名管道交易。
TransactNamedPipe函式最常由管道用戶端用來將要求訊息寫入具名管道伺服器，並讀取伺服器的回應訊息。 管道用戶端必須指定GENERIC_READ |GENERIC_WRITE呼叫 CreateFile 函式來開啟管道控制碼時存取。 然後，管道用戶端會呼叫 SetNamedPipeHandleState 函式，將管道控制碼設定為訊息讀取模式。 如果在呼叫 TransactNamedPipe 中指定的讀取緩衝區不夠大，無法保存伺服器所寫入的整個訊息，則函式會傳回零，而 GetLastError 會傳回ERROR_MORE_DATA。 用戶端可以呼叫ReadFile、ReadFileEx或PeekNamedPipe函式來讀取訊息的其餘部分。
TransactNamedPipe 通常是由管道用戶端呼叫，但也可以由管道伺服器使用。
下列範例示範使用 TransactNamedPipe的管道用戶端。 此管道用戶端可以與 [另請參閱] 底下所列的任何管道伺服器搭配使用。
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <tchar.h>
#define BUFSIZE 512
int _tmain(int argc, TCHAR *argv[])
{
HANDLE hPipe;
LPTSTR lpszWrite = TEXT("Default message from client");
TCHAR chReadBuf[BUFSIZE];
BOOL fSuccess;
DWORD cbRead, dwMode;
LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\mynamedpipe");
if( argc > 1)
{
lpszWrite = 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)
{
printf("Could not open pipe\n");
return 0;
}
// All pipe instances are busy, so wait for 20 seconds.
if (! WaitNamedPipe(lpszPipename, 20000) )
{
printf("Could not open pipe\n");
return 0;
}
}
// 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)
{
printf("SetNamedPipeHandleState failed.\n");
return 0;
}
// Send a message to the pipe server and read the response.
fSuccess = TransactNamedPipe(
hPipe, // pipe handle
lpszWrite, // message to server
(lstrlen(lpszWrite)+1)*sizeof(TCHAR), // message length
chReadBuf, // buffer to receive reply
BUFSIZE*sizeof(TCHAR), // size of read buffer
&cbRead, // bytes read
NULL); // not overlapped
if (!fSuccess && (GetLastError() != ERROR_MORE_DATA))
{
printf("TransactNamedPipe failed.\n");
return 0;
}
while(1)
{
_tprintf(TEXT("%s\n"), chReadBuf);
// Break if TransactNamedPipe or ReadFile is successful
if(fSuccess)
break;
// Read from the pipe if there is more data in the message.
fSuccess = ReadFile(
hPipe, // pipe handle
chReadBuf, // buffer to receive reply
BUFSIZE*sizeof(TCHAR), // size of buffer
&cbRead, // number of bytes read
NULL); // not overlapped
// Exit if an error other than ERROR_MORE_DATA occurs.
if( !fSuccess && (GetLastError() != ERROR_MORE_DATA))
break;
else _tprintf( TEXT("%s\n"), chReadBuf);
}
_getch();
CloseHandle(hPipe);
return 0;
}
管道用戶端會使用 CallNamedPipe ，視需要將 CreateFile、 WaitNamedPipe (結合在單一呼叫中) 、 TransactNamedPipe和 CloseHandle 函式呼叫。 因為管道控制碼會在函式傳回之前關閉，所以如果訊息大於讀取緩衝區的指定大小，訊息中的任何額外位元組就會遺失。 下列範例是先前重寫為使用 CallNamedPipe的範例。
#include <windows.h>
#include <stdio.h>
#include <conio.h>
#include <tchar.h>
#define BUFSIZE 512
int _tmain(int argc, TCHAR *argv[])
{
LPTSTR lpszWrite = TEXT("Default message from client");
TCHAR chReadBuf[BUFSIZE];
BOOL fSuccess;
DWORD cbRead;
LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\mynamedpipe");
if( argc > 1)
{
lpszWrite = argv[1];
}
fSuccess = CallNamedPipe(
lpszPipename, // pipe name
lpszWrite, // message to server
(lstrlen(lpszWrite)+1)*sizeof(TCHAR), // message length
chReadBuf, // buffer to receive reply
BUFSIZE*sizeof(TCHAR), // size of read buffer
&cbRead, // number of bytes read
20000); // waits for 20 seconds
if (fSuccess || GetLastError() == ERROR_MORE_DATA)
{
_tprintf( TEXT("%s\n"), chReadBuf );
// The pipe is closed; no more data can be read.
if (! fSuccess)
{
printf("\nExtra data in message was lost\n");
}
}
_getch();
return 0;
}
相關主題