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

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

Ord(ClientAddr.sin_addr.S_un_b.s_b4),

ntohs(ClientAddr.sin_port)]);

NewConnection.Phase := tpReceiveLength;

NewConnection.Offset := 0;

NewConnection.BytesLeft := SizeOf(Integer);

NewConnection.SendRead := False;

// Добавляем запись нового соединения в список

FConnections.Add(NewConnection);

AddMessageToLog('Зафиксировано

подключение с адреса ' +

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);

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