О чём не пишут в книгах по 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;
// Сразу выделяем память под строку
Поделиться с друзьями: