Отправлять данные можно и из основной нити, поскольку функция sendto
при наших объемах данных практически никогда не будет блокировать вызывающую ее нить (да и при больших объемах данных, как мы увидим в дальнейшем, этого практически никогда не бывает). Соответственно, нам нужно создать два сокета: один для отправки сообщений, другой для приема. Сокет для отправки сообщений создаем сразу же при запуске приложения, при обработке события OnCreate
главной (и единственной) формы. Дескриптор сокета хранится в поле FSendSocket
. Пользователю не принципиально, какой порт займет этот сокет, поэтому мы доверяем его выбор системе (листинг 2.8).
procedure TChatForm.FormCreate(Sender: TObject);
var
// Без этой переменной не удастся инициализировать библиотеку сокетов
WSAData: TWSAData;
// Адрес, к которому привязывается сокет для отправки сообщений
Addr: TSockAddr;
AddrLen: Integer;
begin
// инициализация библиотеки сокетов
if WSAStartup($101, WSAData) <> 0 then
begin
MessageDlg('Ошибка при инициализации библиотеки WinSock',
mtError, [mbOK], 0);
Application.Terminate;
end;
// Перевод элементов управления в состояние "Сервер не работает"
OnStopServer;
// Создание сокета
FSendSocket := socket(AF_INET, SOCK_DGPAM, IPROTO_UDP);
if FSendSocket = INVALID_SOCKET then
begin
MessageDlg('Ошибка при создании отправляющего сокета:'#13#10 +
GetErrorString, mtError, [mbOK], 0);
Exit;
end;
// Формирование адреса, к которому будет привязан сокет
// для отправки сообщений
FillChar(Addr.sin_zero, SizeOf(Addr.sin_zero), 0);
Addr.sin_family := AF_INET;
// Пусть система сама выбирает для него IP-адрес и порт
Addr.sin_addr.S_addr := INADDR_ANY;
Addr.sin_port := 0;
// Привязка сокета к адресу
if bind(FSendSocket, Addr, SizeOf(Addr)) = SOCKET_ERROR then
begin
MessageDlg('Ошибка при привязке отправляющего сокета к адресу:'#13#10 +
GetErrorString, mtError, [mbOK], 0);
Exit;
end;
// Узнаем, какой адрес система назначила сокету
// Это нужно для вывода информации для пользователя
AddrLen := SizeOf(Addr);
if getsockname(FSendSocket, Addr, AddrLen) = SOCKET_ERROR then
begin
MessageDlg('Ошибка при получении адреса отправляющего сокета:'#13#10 +
GetErrorString, mtError, [mbOK], 0);
Exit;
end;
// Не забываем, что номер порта возвращается в сетевом формате,
// и его нужно преобразовать к обычному функцией htons.
LabelSendPort.Caption := 'Порт отправки: ' + IntToStr(ntohs(Addr.sin_port));
end;
Сокет для получения сообщений создается при нажатии кнопки Запустить и привязывается к тому порту, который указал пользователь. В случае его успешного создания запускается нить, которой передается этот сокет, и все дальнейшие операции с ним выполняет эта нить. Нить вместе с этим сокетом мы будем условно называть сервером. Код обработчика нажатия кнопки Запустить показан в листинге 2.9.
// Реакция на кнопку "Запустить"
procedure TChatForm.BtnStartServerClick(Sender: TObject);
var
// Сокет для приема сообщений
ServerSocket: TSocket;
// Адрес, к которому привязывается сокет для приема сообщений