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

ЖАНРЫ

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

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

Шрифт:

NewConnection.ClientAddr);

 end;

end;

Для каждого подключившегося клиента создается запись типа

TConnection
, указатель на которую добавляется в список
FConnections
— здесь полная аналогия с сервером на неблокирующих сокетах. Отличие заключается в том, что в типе
TConnection
по сравнению с тем сервером (см. листинг 2.31) добавилось поле
SendRead
логического типа. Оно равно
True
, если возникло событие
FD_READ
в то время, как сервер находится на этапе отправки данных.

Каждый сокет, созданный функцией

accept
, связывается с сообщением
WM_SOCKETMESSAGE
. Обработчик этого сообщения приведен в листинге 2.54. 

Листинг 2.54. Обработчик сообщения
WM_SOCKETMESSAGE

// Метод GetConnectionBySocket находит в списке FConnections

// запись, соответствующую данному сокету

function TServerForm.GetConnectionBySocket(S: TSocket): PConnection;

var

 I: Integer;

begin

 for I := 0 to FConnections.Count - 1 do

if PConnection(FConnections[I]).ClientSocket = S then

begin

Result := FConnections[I];

Exit;

end;

 Result := nil;

end;

procedure TServerForm.WMSocketMessage(var Msg: TWMSocketMessage);

var

 Connection: PConnection;

 Res: Integer;

 // Вспомогательная процедура, освобождающая ресурсы, связанные

 // с клиентом и удаляющая запись подключения из списка

 procedure RemoveConnection;

 begin

closesocket(Connection.ClientSocket);

FConnections.Remove(Connection);

Dispose(Connection);

 end;

begin

 // Ищем соединение по сокету

 Connection := GetConnectionBySocket(Msg.Socket);

 if Connection = nil then

 begin

AddMessageToLog(

'Внутренняя ошибка сервера — не найдено соединение для сокета');

Exit;

 end;

 // Проверяем, были ли ошибки при взаимодействии

 if Msg.SockError <> 0 then

 begin

AddMessageToLog('Ошибка при взаимодействии с клиентом ' +

Connection.ClientAddr + ': ' + GetErrorString(Msg.SockError));

RemoveConnection;

Exit;

 end;

 //
Анализируем, какое событие произошло

 case Msg.SockEvent of

 FD_READ: begin

// Проверяем, на каком этапе находится взаимодействие с клиентом.

if Connection.Phase = tpReceiveLength then

begin

// Этап получения от клиента длины строки. При выполнении этого

// этапа сервер получает от клиента длину строки и размещает ее

// в поле Connection.MsgSize. Здесь приходится учитывать, что

// теоретически даже такая маленькая (4 байта) посылка может

// быть разбита на несколько пакетов, поэтому за один раз этот

// этап не будет завершен, и второй раз его придется

// продолжать, загружая оставшиеся байты. Connection.Offset -

// количество уже прочитанных на данном этапе байтов -

// одновременно является смещением, начиная с которого

// заполняется буфер.

Res := recv(Connection.ClientSocket,

(PChar((PConnection.MsgSize + Connection.Offset)^, Connection.BytesLeft, 0);

if Res > 0 then

begin

// Если Res > 0, это означает, что получено Res байтов.

// Соответственно, увеличиваем на Res количество прочитанных

// на данном этапе байтов и на такую же величину уменьшаем

// количество оставшихся.

Inc(Connection.Offset, Res);

Dec(Connection.BytesLeft, Res);

// Если количество оставшихся байтов равно нулю, нужно

// переходить к следующему этапу.

if Connection.BytesLeft = 0 then

begin

// Проверяем корректность принятой длины строки

if Connection.MsgSize <= 0 then

begin

AddMessageToLog('Неверная длина строки, от клиента ' +

Connection.ClientAddr + ': ' + IntToStr(Connection.MsgSize));

RemoveConnection;

Exit;

end;

// Следующий этап - это чтение самой строки

Connection.Phase := tpReceiveString;

// Пока на этом этапе не прочитано ни одного байта

Connection.Offset := 0;

// Осталось прочитать Connection.MsgSize байтов

Connection.BytesLeft := Connection.MsgSize;

// Сразу выделяем память под строку

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