Indy TIdTCPServer i TIdTCPClient – odbiór i wysyłanie odpowiedzi, obsługa komunikacji TCP Delphi

Pytanie

IdTCPServer, odpowiedź do serwera . IdTCPClient , odbiór od serwera

Odpowiedź Sztucznej Inteligencji

Bezpośrednia odpowiedź na pytanie

• Komponent TIdTCPServer wysyła odpowiedź do konkretnego klienta za pomocą
  AContext.Connection.IOHandler.WriteLn(...) wewnątrz zdarzenia OnExecute, OnConnect lub w dowolnym wątku, w którym dysponujemy kontekstem danego klienta.
• Klient TIdTCPClient odbiera tę odpowiedź synchronicznie wywołując jedną z metod odczytu (najczęściej ReadLn, ReadBytes, ReadStream) po wysłaniu zapytania albo w dedykowanym wątku/Timerze, gdy połączenie ma pozostawać otwarte.

Kluczowe punkty
• Serwer i klient muszą uzgodnić terminator (np. CRLF) lub długość ramki.
• Read* i Write* są operacjami blokującymi – stosuj wątki albo asynchroniczne wywołania, by nie zamrozić GUI.
• Każde połączenie klienta ma własny kontekst (TIdContext); serwer może wysłać wiadomość do wszystkich lub wybranego klienta iterując po IdTCPServer.Contexts.
• Obsługuj wyjątki (EIdConnClosedGracefully, EIdReadTimeout, EIdSocketError) i zawsze zamykaj połączenie w bloku finally.

Szczegółowa analiza problemu

1. Topologia komunikacji

TCP zapewnia dwukierunkowy strumień bajtów. W Indy:

• Serwer (listener) = TIdTCPServer.
• Dla każdego klienta ‑ Indy tworzy osobny wątek i przekazuje go w parametrze AContext.
• Klient = TIdTCPClient. Po Connect obiekt działa synchronicznie.

2. Implementacja – serwer

procedure TMainFrm.IdTCPServerExecute(AContext: TIdContext);
var
  Cmd, Resp: string;
begin
  try
    Cmd := AContext.Connection.IOHandler.ReadLn;       // blokujące
    Resp := ProcessCommand(Cmd);                       // własna logika
    AContext.Connection.IOHandler.WriteLn(Resp);       // odpowiedź
  except
    on E: EIdConnClosedGracefully do
      Exit;                                            // klient zamknął
    on E: Exception do
    begin
      AContext.Connection.IOHandler.WriteLn('ERROR:' + E.Message);
      AContext.Connection.Disconnect;
    end;
  end;
end;

Procesowanie pakietów binarnych: najpierw wyślij długość (Int32 w sieciowym porządku bajtów), potem WriteBuffer.

3. Implementacja – klient

function TClientCore.QueryServer(const ACmd: string): string;
begin
  IdTCPClient.Host := '127.0.0.1';
  IdTCPClient.Port := 8080;
  IdTCPClient.ReadTimeout := 5000;   // ms
  IdTCPClient.Connect;
  try
    IdTCPClient.IOHandler.WriteLn(ACmd);      // zapytanie
    Result := IdTCPClient.IOHandler.ReadLn;   // odpowiedź (blokuje)
  finally
    IdTCPClient.Disconnect;
  end;
end;

Długotrwałe połączenie: utwórz wątek TThread i pętlę

while not Terminated do
  if IdTCPClient.IOHandler.InputBufferIsEmpty then
    Sleep(10)
  else
    HandleData(IdTCPClient.IOHandler.ReadLn);

4. Wysyłanie „push” z serwera

procedure TBroadcaster.Broadcast(const AMsg: string);
var
  LList: TList;
  Ctx : TIdContext;
begin
  LList := IdTCPServer.Contexts.LockList;
  try
    for Ctx in LList do
      TThread.Queue(nil, procedure      // wysyłanie z wątku GUI opcjonalne
      begin
        Ctx.Connection.IOHandler.WriteLn(AMsg);
      end);
  finally
    IdTCPServer.Contexts.UnlockList;
  end;
end;

Dbaj o synchronizację – Contexts.LockList/UnlockList zabezpiecza dostęp.

5. Zarządzanie czasem i wielowątkowością

• ReadTimeout/ConnectTimeout – unikasz wiecznego blokowania.
• GUI ↔ Worker: TThread.Synchronize / TThread.Queue.
• Logger wątków: scentralizowany TThreadSafeStringList.

Aktualne informacje i trendy

• Indy 10.8.4 (Berlin → Rad Studio 12) wprowadza klasy TIdIOTATCPServer z poprawkami bezpieczeństwa TLS 1.3.
• Rosnące użycie protokołów message-oriented (MQTT, WebSockets) – przy bogatszych scenariuszach warto rozważyć gotowe biblioteki.
• Standardem staje się domyślne szyfrowanie (TLS) – w Indy dodaj TIdSSLIOHandlerSocketOpenSSL.

Wspierające wyjaśnienia i detale

• Terminator linii: Indy domyślnie CRLF; gdy obie strony są pod Twoją kontrolą jest to najprostsze.
• Gdy potrzebujesz binariów lub dużych plików: wysyłasz długość → WriteStream / ReadStream.
• Kwestie kodowania: IOHandler.DefStringEncoding := IndyTextEncoding_UTF8;.

Aspekty etyczne i prawne

• Szyfruj dane osobowe (RODO / GDPR).
• Przy nasłuchu na nietypowych portach upewnij się, że zapora systemowa jest odpowiednio skonfigurowana i użytkownik świadomie zezwala na ruch.
• Dzienniki połączeń mogą zawierać IP – chroń je przed nieautoryzowanym dostępem.

Praktyczne wskazówki

• Zawsze obsługuj finally IdTCPClient.Disconnect i OnDisconnect po stronie serwera.
• Testuj localhost → następnie w sieci LAN; użyj telnet lub openssl s_client do prostego sniffingu.
• Przy debugowaniu wielowątkowym pamiętaj o GStack.CheckSocketsInitialized.
• Nie manipuluj VCL z wątków serwera; loguj poprzez TThread.Queue.

Ewentualne zastrzeżenia lub uwagi dodatkowe

• Indy nie jest w pełni asynchroniczne (brak zdarzeń danych w TIdTCPClient). W bardzo obciążonych systemach rozważ AsyncIO (np. libuv) albo IOCP na Windows.
• W starszych wersjach OpenSSL > 3 wymaga ręcznej aktualizacji plików DLL; brak – skutkuje błędem „Could not load SSL library”.

Sugestie dalszych badań

• Wzorce framingu (STX/ETX, PrefixLength, JSON-RPC).
• Integracja z protokołami wyższego poziomu (gRPC, WebSockets).
• Implementacja własnych filtrów szyfrujących w TIdConnectionIntercept.

Krótkie podsumowanie

Komunikacja Indy jest prosta: serwer w OnExecute odczytuje komendę, generuje i wysyła odpowiedź przez WriteLn; klient po Connect wykonuje WriteLn i synchronizacyjnie ReadLn, lub trwale nasłuchuje w osobnym wątku. Klucz do stabilności – poprawne zamykanie połączeń, timeouty oraz nieblokowanie wątku GUI. Dzięki tym zasadom zbudujesz bezpieczny i responsywny system klient-serwer w Delphi.