Транзакции по именованным каналам
Транзакция именованного канала — это обмен данными между клиентом и сервером, объединяющий операцию записи и операции чтения в одну сетевую операцию. Транзакцию можно использовать только в дуплексном канале типа сообщения. Транзакции повышают производительность сетевого взаимодействия между клиентом и удаленным сервером. Процессы могут использовать функции 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;
}
Связанные темы