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

ЖАНРЫ

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

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

Шрифт:

// Принимаем подключившегося клиента. Для общения с ним создается

// новый сокет, дескриптор которого помещается в ClientSocket.

ClientSocket :=

accept(MainSocket, @ClientSockAddr, @ClientSockAddrLen);

if ClientSocket = INVALID_SOCKET then raise

ESocketException.Create(

'Ошибка при ожидании подключения клиента: ' + GetErrorString);

// Создаем в динамической памяти новый экземпляр TConnection

//
и заполняем его данными, соответствующими подключившемуся клиенту

New(NewConnection);

NewConnection.ClientSocket := ClientSocket;

NewConnection.ClientAddr :=

Format('%u.%u.%u.%u:%u',

Ord(ClientSockAddr.sin_addr.S_un_b.s_bl),

Ord(ClientSockAddr.sin_addr.S_un_b.s_b2),

Ord(ClientSockAddr.sin_addr.S_un_b.s_b3),

Ord(ClientSockAddr.sin_addr.S_un_b.s_b4),

ntohs(ClientSockAddr.sin_port));

NewConnection.Deleted := False;

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

Connections.Add(NewConnection);

WriteLn(OemString('Зафиксировано подключение с адреса ' +

NewConnection.ClientAddr));

 end;

 // Теперь проверяем готовность всех сокетов подключившихся клиентов.

 // Так как множество SockSet не может содержать более чем FT_SETSIZE

 // элементов, а размер списка Connections мы нигде не ограничиваем,

 // приходится разбивать Connections на "куски" размером не более

 // FD_SETSIZE и обрабатывать этот список по частям.

 // Поэтому у нас появляется два цикла - внешний, который повторяется

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

 // повторяется столько раз, сколько элементов в одном куске.

 for J := 0 to Ceil(Connections.Count, FD_SETSIZE) - 1 do

 begin

FD_ZERO(SockSet);

for I := FD_SETSIZE * J to Min(FD_SETSIZE * (J + 1) - 1, Connections.Count - 1) do

FD_SET(PConnection(Connections[I])^.ClientSocket, SockSet);

if select(0, @SockSet, nil, nil, @Timeout) = SOCKET_ERROR then

raise ESocketException.Create(

'Ошибка при проверке готовности сокетов: ' + GetErrorString);

// Проверяем, какие сокеты функция select оставила в множестве,

// и вызываем для них ProcessSocketMessage. В этом есть некоторый

// риск, т.к. для того, чтобы select оставила сокет в множестве,

// достаточно, чтобы он получил хотя бы один байт от клиента,

// а не все сообщение. Поэтому может возникнуть такая ситуация,

// когда сервер получил только часть сообщения, но уже пытается

//
прочитать сообщение целиком. Это приведет к блокированию нити,

// но вероятность блокирования на долгое время мы оцениваем как

// крайне низкую, т.к. оставшаяся часть сообщения, скорее всего,

// придет достаточно быстро, и поэтому идем на такой риск.

for I := FD_SETSIZE * J to Min(FD_SETSIZE * (J + 1) - 1, Connections.Count - 1) do

if FD_ISSET(PConnection(Connections[I])^.ClientSocket, SockSet) then

ProcessSocketMessage(PConnection(Connections[I])^);

 end;

 // Проверяем поле Deleted у всех соединений. Те, у которых

 // оно равно True, закрываем: закрываем сокет, освобождаем память,

 // удаляем указатель из списка. Цикл идет с конца списка к началу,

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

 // может меняться, и цикл for снизу вверх мог бы привести

 // к появлению индексов вне диапазона.

 for I := Connections.Count - 1 downto 0 do

if PConnection(Connections[I])^.Deleted then

begin

closesocket(PConnection(Connections[I])^.ClientSocket);

Dispose(PConnection(Connections[I]));

Connections.Delete(I);

end;

 Sleep(100);

until False;
 

Функции

Ceil
и
Min
, которые встречаются здесь, можно было бы заменить одноимёнными функциями из модуля
Math
. Но этот модуль входит не во все варианты поставки Delphi, и чтобы пример можно было откомпилировать в любом варианте поставки Delphi, мы описали их здесь самостоятельно (листинг 2.27).

Листинг 2.27. Функции
Ceil
и
Min

// Функция Ceil возвращает наименьшее целое число X, удовлетворяющее

// неравенству X >= А / В

function Ceil(A, B: Integer): Integer;

begin

 Result := A div B;

 if A mod В <> 0 then Inc(Result);

end;

// Функция Min возвращает меньшее из двух чисел

function Min(А, В: Integer): Integer;

begin

 if A < В then Result := A

 else Result := B;

end;

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

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