Слушать udp порт

[Letnab]

Доброе время суток форумчане!
Не могу сообразить как реализовать прослушку UDP порта. Использую компонент UDPServer. помогите с кодом.

[Человек_Борща]

Слушать может только клиент.
UDPClient + TThread.

А чо кодом, а не готовой программой? Где ваши наработки?

[Letnab]

Оо! не знал. я с этим первый раз сталкиваюсь.
примером не поможете?

[Человек_Борща]

Разбирайтесь.

unit ServerPingThread;

interface

uses
  IdSocketHandle,
  IdUDPServer,
  sysUtils,
  Classes,
  Windows;

type
  TlolThread = class(TThread)
  private
    fResult: Boolean;
    fTimeout: Integer;
    fMaxAttempts: Integer;
    fIP: string;
    fPort: Integer;
    fEvent: THandle;
    fOnTimeOut: TOnTimeout;
    fWaitStart: Integer;
    procedure SetProc(aVal: TOnTimeout);
  protected
    procedure Execute; override;
  public
    UDP: TIdUDPServer;
    property IP: string read fIP write fIP;
    property Port: Integer read fPort write fPort;
    property WaitStartSec: Integer read fWaitStart write fWaitStart;
    procedure UDPRead(Sender: TObject; AData: TStream;
      ABinding: TIdSocketHandle);
    constructor Create; virtual;
    destructor Destroy; override;
  end;

implementation

uses
  MainDMUnit, HLRTypes;

procedure TlolThread.UDPRead(Sender: TObject; AData: TStream;
  ABinding: TIdSocketHandle);
var
  Buff: array [0 .. 255] of Char;
  s: string;
begin
  AData.Read(Buff, Length(Buff));
  s := StrPas(Buff);
  if (s = Server_Answer) then // если ответ сервера правельный.
  begin
    Result := True;
    SetEvent(fEvent); // Сигнальное состояние
  end
  else
    Result := False;
end;

{ TPingThread }


procedure TlolThread.Execute;
var
  Data: array of Char;
  Attemptcount: Integer;
begin
  if fWaitStart > 0 then
  begin
    Sleep(fWaitStart * 1000); // ; ждём запуска MainThread
  end;
  SetLength(Data, Length(Server_Request));
  StrPCopy(@Data[0], Server_Request);
  Attemptcount := 0;

  while not terminated do
  begin
    if terminated then
      Exit;
    Sleep(1000);
    try
      // UDP.SendBuffer(fIP, fPort, Data[0], Length(Data));
    except
      On E: Exception do
      begin
        Log.AddItem('Ошибка отправки запроса на сервер: ' + fIP + ':' +
          IntToStr(fPort) + #10#13 + E.ClassName + ' ' + E.Message, laError);
        Break; // Пропустим эту интерацию цикла.
      end;
    end;
    if WaitForSingleObject(fEvent, fTimeout * 1000) = WAIT_TIMEOUT then
    begin
      if (Attemptcount < fMaxAttempts) then
        Inc(Attemptcount);

      if terminated then
        Exit;

      if (Attemptcount = fMaxAttempts) then
      begin
        Terminate;
        Synchronize(fOnTimeOut);
      end;

      ResetEvent(fEvent); // НЕ сигнальное состояние
    end;
  end;
end;

constructor TPingThread.Create;
begin
  inherited Create(True);
  FreeOnTerminate := True;
  fEvent := CreateEvent(nil, True, False, nil);
  UDP := TIdUDPServer.Create(nil);
  UDP.ThreadedEvent := True;
  UDP.OnUDPRead := UDPRead;
end;

destructor TPingThread.Destroy;
begin
  FreeAndNil(UDP);
  CloseHandle(fEvent);
  inherited;
end;

end.

Удачи.

[Letnab]

Спасибо большое за код. Буду ковыряться!

[veniside]

разница между UDPClient и UDPServer чисто условная, в юдп нет ни клиентов, ни серверов (в понимании TCP).

А начать слушать юдп порт можно тремя строчками:

socket();
bind();
recv();

Если нужно отправить данные, после bind() используем sendto(). Вот и всё, где тут сервер, где клиент?

Использовать для этого сторонние компоненты — себе вредить. Оправданием может служить только поднятие какого-то условно сложного протокола.