Читаем О чём не пишут в книгах по Delphi полностью

 LogMessage('Соединение установлено');

 ReadLength := True;

 Offset := 0;

 BytesLeft := SizeOf(Integer);

 repeat

  WaitRes := WSAWaitForMultipleEvents(3, @FEvents, False, WSA_INFINITE, False);

  case WaitRes of

  WSA_WAIT_EVENT_0: begin

   // Закрываем соединение с клиентом и останавливаем нить

   LogMessage('Получен сигнал об остановке нити');

   shutdown(FSocket, SD_BOTH);

   Break;

  end;

  WSA_WAIT_EVENT_0 + 1:

  begin

   // Сбрасываем событие и отправляем данные

   WSAResetEvent(FEvents[1]);

   if not DoSendBuf then Break;

  end;

  WSA_WAIT_EVENT_0 + 2: begin

   // Произошло событие, связанное с сокетом.

   // Проверяем, какое именно, и заодно сбрасываем его

   if WSAEnumNetworkEvents(FSocket, FEvents[2], NetEvents) = SOCKET_ERROR then

   begin

    LogMessage('Ошибка при получении списка событий: ' + GetErrorString);

    Break;

   end;

   if NetEvents.lNetworkEvents and FD_READ <> 0 then

   begin

    if NetEvents.iErrorCode[FD_READ_BIT] <> 0 then

    begin

     LogMessage('Ошибка в событии FD_READ: ' +

      GetErrorString(NetEvents.iErrorCode[FD_READ_BIT]));

     Break;

    end;

    // В буфере сокета есть данные.

    // Копируем данные из буфера сокета в свой буфер RecvBuf

    RecvRes := recv(FSocket, RecvBuf, SizeOf(RecvBuf), 0);

    if RecvRes > 0 then

    begin

     P := 0;

     // Эта переменная нужна потому, что здесь появляется

     // вложенный цикл, при возникновении ошибки в котором нужно

     // выйти и из внешнего цикла тоже. Так как в Delphi нет

     // конструкции типа Break(2) в Аде, приходится прибегать

     // к таким способам: если нужен выход из внешнего цикла,

     // во внутреннем цикле выполняется LoopExit := True,

     // а после выполнения внутреннего цикла проверяется

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

     // выход и из главного цикла.

     LoopExit := False;

     // В этом цикле мы извлекаем данные из буфера

     // и раскидываем их по приёмникам - Str и StrLen.

     while Р < RecvRes do

     begin

      // Определяем, сколько байтов нам хотелось бы скопировать

      L := BytesLeft;

      // Если в буфере нет такого количества,

      // довольствуемся тем, что есть

      if Р + L > RecvRes then L := RecvRes - P;

      // Копируем в соответствующий приемник

      if ReadLength then

Move(RecvBuf[P], (PChar(@StrLen) + Offset)^, L)

      else Move(RecvBuf[P], Str(Offset + 1), L);

      Dec(BytesLeft, L);

      // Если прочитали все, что хотели,

      // переходим к следующему

      if BytesLeft = 0 then

      begin

       ReadLength := not ReadLength;

       Offset := 0;

       // Если закончено чтение строки, нужно вывести ее

       if ReadLength then

       begin

        LogMessage('Получена строка: ' + Str);

        BytesLeft := SizeOf(Integer);

        // Формируем ответ и записываем его в буфер

        Str :=

         AnsiUpperCase(StringReplace(Str, #0, '#0',

          [rfReplaceAll])) + '(AsyncEvent server)';

Перейти на страницу:
Нет соединения с сервером, попробуйте зайти чуть позже