Чтение онлайн

ЖАНРЫ

О чём не пишут в книгах по Delphi

Григорьев Антон Борисович

Шрифт:

 if Err <> 0 then

 begin

// Произошла ошибка. Соединение нужно устанавливать заново

closesocket(S);

Connected := False;

 end;

 else

 begin

// Получены данные, обрабатываем

......

// Запускаем новую операцию перекрытого чтения

Flags := 0;

WSARecv(S, @BufPtr, 1, Cnt, Flags, OvPtr, GetData);

 end;

end;

procedure ProcessConnection;

begin

 //
Устанавливаем начальное состояние - сокет не соединен

 Connected := False;

 // Задаем буфер

 BufPtr.Buf := @RecvBuf;

 BufPtr.Len := SizeOf(RecvBuf);

 while True do

 begin

if not Connected then

begin

Connected := True;

// Создаем и подключаем сокет

S := socket(AF_INET, SOCK_STREAM, 0);

connect(S, ...);

// Запускаем первую для данного сокета операцию чтения

Flags := 0;

WSARecv(S, @BufPtr, 1, Cnt, Flags, @Overlapped, GetData);

end;

// Позволяем системе выполнить процедуру завершения,

// если это необходимо

SleepEx(0, True);

// Выполняем какие-либо дополнительные действия

......

 end;

end;

Основная процедура здесь —

ProcessConnection
. Эта процедура в бесконечном цикле устанавливает соединение, если оно не установлено, дает системе выполнить процедуру завершения, если это требуется, и выполняет какие-либо иные действия, не связанные с получением данных от сокета. Процедура завершения
GetData
получает и обрабатывает данные, а если произошла ошибка, закрывает сокет и сбрасывает флаг
Connected
, что служит для процедуры
ProcessConnection
сигналом о необходимости установить соединение заново.

Из этого примера хорошо видны достоинства и недостатки процедур заверения. Получение и обработка данных выносится в отдельную процедуру, и с одной стороны, позволяет разгрузить основную процедуру, но, с другой стороны, заставляет прибегнуть к глобальным переменным для буфера и сокета.

Для протоколов, не поддерживающих соединение, существует другая функция для перекрытого получения данных —

WSARecvFrom
. Из названия очевидно, что она позволяет узнать адрес отправителя. Прототип функции
WSARecvFrom
приведен в листинге 2.74.

Листинг 2.74. Функция
WSARecvFrom

// ***** Описание на C++ *****

int WSARecvFrom(SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount, LPDWORD lpNumberOfBytesRecvd, LPDWORD lpFlags, struct sockaddr FAR *lpFrom, LPINT lpFromlen, LPWSAOVERLAPPED lpOverlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine;

// *****
Описание на Delphi *****

function WSARecvFrom(S: TSocket; lpBuffers: PWSABuf; dwBufferCount: DWORD; var NumberOfBytesRecvd: DWORD; var Flags: DWORD; lpFrom: PSockAddr; lpFromLen: PInteger; lpOverlapped: FWSAOverlapped; lpCompletionRoutine: TWSAOverlappedCompletionRoutine): Integer;

Параметры

lpFrom
и
lpFromLen
этой функции, служащие для получения адреса отправителя, эквивалентны соответствующим параметрам функции
recvfrom
, с которой мы уже хорошо знакомы. В остальном
WSARecvFrom
ведет себя так же, как
WSARecv
, поэтому мы не будем останавливаться на ней.

Для отправки данных в режиме перекрытого ввода-вывода существуют функции

WSASend
и
WSASendTo
, имеющие следующие прототипы (листинг 2.75).

Листинг 2.75. Функции
WSASend
и
WSASendTo

// ***** Описание на C++ *****

int WSASend(SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount, LPDWORD lpNumberOfBytesSent, DWORD dwFlags, LPWSAOVERLAPPED lpOverlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine);

int WSASendTo(SOCKET s, LPWSABUF lpBuffers, DWORD dwBufferCount, LPDWORD lpNumberOfBytesSent, DWORD dwFlags, const struct sockaddr FAR *lpTo, int iToLen, LPWSAOVERLAPPED lpOverlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE lpCompletionRoutine);

// ***** Описание на Delphi *****

function WSASend(S: TSocket; lpBuffers: PWSABuf; dwBufferCount: DWORD; var NumberOfBytesRecvd: DWORD; Flags: DWORD; lpOverlapped: PWSAOverlapped; lpCompletionRoutine: TWSAOverlappedCompletionRoutine): Integer;

function WSASendTo(S: TSocket; lpBuffers: PWSABuf; dwBufferCount: DWORD; var NumberOfBytesRecvd: DWORD; Flags: DWORD; var AddrTo: TSockAddr; ToLen: Integer; lpOverlapped: PWSAOverlapped; lpCompletionRoutine: TWSAOverlappedCompletionRoutine): Integer;

Если вы разобрались с функциями

WSARecv
,
send
и
sendto
, то смысл параметров функций
WSASend
и
WSASendTo
должен быть вам очевиден, поэтому подробно разбирать мы их не будем. Но отметим, что флаги передаются по значению, и функции не могут изменять их.

Потребность в перекрытом вводе-выводе при отправке данных возникает достаточно редко. Но функции

WSASend/WSASendTo
могут оказаться удобными при подготовке многокомпонентных пакетов, которые, например, имеют фиксированный заголовок и финальную часть. Для таких пакетов можно один раз подготовить буферы с заголовком и с финальной частью и, пользуясь возможностью отправки данных из несвязных буферов, при отправке каждого пакета менять только его среднюю часть.

2.2.10. Сервер, использующий перекрытый ввод-вывод

В этом разделе мы рассмотрим создание сервера на основе перекрытого ввода-вывода на основе процедур завершения (пример кода с использованием событий есть в MSDN в описании функций

WSARecv
— и
WSASend
). Перекрытый ввод-вывод лучше подходит для обмена в режиме "запрос-ответ", поэтому мы вновь вернемся к первоначальному протоколу, который не предусматривает отправку сервером сообщений по собственному усмотрению. На компакт-диске этот пример называется OverlappedServеr.

Поделиться с друзьями: