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

 В этом модуле реализуется дополнительная нить UDP-чата, отвечающая за прием сообщений.

}

interface

uses

 SysUtils, Classes, WinSock;

type

 TReceiveThread = class(TThread)

 private

  // Сообщение, которое нужно добавить в лог,

  // хранится в отдельном поле, т.к. метод, вызывающийся через

  // Synchronize, не может иметь параметров.

  FMessage: string;

  // Сокет, получающий сообщения

  FSocket: TSocket;

  // Вспомогательный метод для вызова через Synchronize

  procedure DoLogMessage;

 protected

  procedure Execute; override;

  // Вывод сообщения в лог главной формы

  procedure LogMessage(const Msg: string);

 public

  constructor Create(ServerSocket: TSocket);

 end;

implementation

uses ChatMainUnit;

{TReceiveThread}

// Сокет, получающий сообщения, создается в главной нити,

// а сюда передаётся через параметр конструктора

constructor TReceiveThread.Create(ServerSocket: TSocket);

begin

 FSocket := ServerSocket;

 inherited Create(False);

end;

procedure TReceiveThread.Execute;

var

 // Буфер для получения сообщения.

 // Размер равен максимальному размеру UDP-дейтаграммы

 Buffer: array[0..65506] of Byte;

 // Адрес, с которого пришло сообщение

 RecvAddr: TSockAddr;

 RecvLen, AddrLen: Integer;

 Msg: string;

begin

 // Начинаем бесконечный цикл, на каждой итерации которого

 // читается одна дейтаграмма

 repeat

  AddrLen := SizeOf(RecvAddr);

  // Получаем дейтаграмму

  RecvLen :=

   recvfrom(FSocket, Buffer, SizeOf(Buffer), 0, RecvAddr, AddrLen);

  // Так как UDP не поддерживает соединение, ошибку при вызове recvfrom

  // мы можем получить, только если случилось что-то совсем

  // экстраординарное. В этом случае завершаем работу нити.

  if RecvLen < 0 then

  begin

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

   // Перевод элементов управления главной формы

   // в состояние "Сервер не работает"

   Synchronizе(ChatForm.OnStopServer);

   Break;

  end;

  // Устанавливаем нужный размер строки

  SetLength(Msg, RecvLen);

  // и копируем в нее дейтаграмму из буфера

  if RecvLen > 0 then Move(Buffer, Msg[1], RecvLen);

  LogMessage('Сообщение с адреса ' + inet_ntoa(RecvAddr.sin_addr) + ':' +

   IntToStr(ntohs(RecvAddr.sin_port)) + ':' + Msg);

 until False;

 closesocket(FSocket);

end;

procedure TReceiveThread.LogMessage(const Msg: string);

begin

 FMessage := Msg;

 Synchronize(DoLogMessage);

end;

procedure TReceiveThread.DoLogMessage;

begin

 ChatForm.AddMessageToLog(FMessage);

end;

end.