А. Григорьев - О чём не пишут в книгах по Delphi

if Connection. Phase := tpReceiveString then

begin

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

// по реализации от этапа чтения длины строки, за исключением

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

// данные, служит не Connection.MsgSize, a Connection.Msg.

Res :=

recv(Connection.ClientSocket,

Connection.Msg[Connection.Offset + 1], Connection.BytesLeft, 0);

if Res > 0 then begin

Inc(Connection.Offset, Res);

Dec(Connection.BytesLeft, Res);

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

// к следующему этапу.

if Connection.BytesLeft = 0 then

begin

AddMessageToLog('От клиента ' + Connection.ClientAddr +

' получена строка: ' + Connection.Msg);

// Преобразуем строку. В отличие от предыдущих примеров, здесь

// мы явно добавляем к строке #0. Это связано с тем, что при

// отправке, которая тоже может быть выполнена не за один раз,

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

// нужно отправлять данные. И (хотя теоретически вероятность

// этого очень мала) может возникнуть ситуация, когда за

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

// завершающего #0, и тогда при следующей отправке начинать

// придется с него. Если мы будем использовать тот #0, который

// добавляется к концу строки автоматически, то в этом случае

// индекс выйдет за пределы диапазона. Поэтому мы вручную

// добавляем еще один #0 к строке, чтобы он стал законной

// ее частью.

Connection.Msg :=

AnsiUpperCase(StringReplace(Connection.Msg, #0,

'#0', [rfReplaceAll])) + ' (Non-blocking server)'#0;

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

Connection.Phase := tpSendString;

// Отправлено на этом этапе 0 байт

Connection.Offset := 0;

// Осталось отправить Length(Connection.Msg) байт.

// Единицу к длине строки, в отличие от предыдущих примеров,

// не добавляем, т.к. там эта единица нужна была для того,

// чтобы учесть добавляемый к строке автоматически символ #0.

// Здесь мы еще один #0 добавили к строке явно, поэтому

// он уже учтен в функции Length.

Connection.BytesLeft := Length(Connection.Msg);

end;

end

else if Res = 0 then

begin

AddMessageToLog('Клиент ' + Connection.ClientAddr +

' закрыл соединение');

RemoveConnection;

Exit;

end

else

// Как обычно, "ошибку" WSAEWOULDBLOCK просто игнорируем

if WSAGetLastError <> WSAEWOULDBLOCK then

begin

AddMessageToLog('Ошибка при получении данных от клиента ' +

Connection.ClientAddr + ': ' + GetErrorString);

RemoveConnection;

Exit;

end;

end;

if Connection.Phase = tpSendString then

begin

// Следующий этап — отправка строки. Код примерно такой же,

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

// Кроме того, отсутствует проверка на Res = 0, т.к. при

// использовании TCP send никогда не возвращает 0.

Res :=

send(Connection.ClientSocket, Connection.Msg[Connection.Offset + 1],

Connection.BytesLeft, 0);

if Res > 0 then

begin

Inc(Connection.Offset, Res);

Dec(Connection.BytesLeft, Res);

// Если Connection.BytesLeft = 0, значит, строка отправлена

// полностью.

if Connection.BytesLeft = 0 then

begin

AddMessageToLog('Клиенту ' + Connection.ClientAddr +

' отправлена строка: ' + Connection.Msg);

// Очищаем строку, престо сэкономить память

Connection.Msg := '';

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

Connection.Phase := tpReceiveLength;

// Получено - 0 байт

Connection.Offset := 0;

// Осталось прочитать столько, сколько занимает целое число

Connection.BytesLeft := SizeOf(Integer);

end;

end

else

if WSAGetLastError <> WSAEWOULDBLOCK then

begin

AddMessageToLog('Ошибка при отправке данных клиенту ' +

Connection.ClientAddr + ': ' + GetErrorString);

RemoveConnection;

Exit;

end;

end;

end;

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

Каждый сокет обладает рядом параметров (опций), которые влияют на его работу. Существуют параметры уровня сокета, которые относятся к сокету как к объекту безотносительно используемого протокола и его уровня. Впрочем, некоторые параметры уровня сокета применимы не ко всем протоколам. Здесь мы не будем рассматривать все параметры сокета, а ограничимся лишь изложением методов доступа к ним и познакомимся с некоторыми самыми интересными параметрами.

Для получения текущего значения параметров сокета предусмотрена функция getsockopt, для изменения — setsockopt. Прототипы этих функций выглядят следующим образом:

function getsockopt(s: TSocket; level, optname: Integer; optval: PChar; var optlen: Integer): Integer;

function setsockopt(s: TSocket; level, optname: Integer; optval: PChar; optlen: Integer): Integer;

Параметры у функций почти одинаковы. Первый задает сокет, параметры которого следует узнать или изменить. Второй указывает, параметр какого уровня следует узнать или изменить. Третий задает сам параметр сокета. Параметр optvalсодержит указатель на буфер, в котором хранится значение параметра, a optlen— размер этого буфера (разные параметры имеют различные типы и поэтому размер буфера может быть разным). Функция getsockoptсохраняет значение параметра в буфере, заданном указателем optval. Длина буфера передается через параметр optlen, и через него же возвращается размер, реально понадобившийся для хранения параметра. У функции setsockoptпараметр optvalсодержит указатель на буфер, хранящий новое значение параметра сокета, a optlen— размер этого буфера.

Чаще всего параметры сокета имеют целый или логический тип. В обоих случаях параметр optvalдолжен содержать указатель на значение типа Integer. Для логического типа любое ненулевое значение интерпретируется True, нулевое — как False. Два достаточно важных параметра сокета — размеры входного и выходного буфера. Это параметры уровня сокета ( SOL_SOCKET), их номера задаются константами SO_RCVBUFи SO_SNDBUF. Например, чтобы получить размер входного буфера сокета, нужно выполнить код листинга 2.34.