Moin !

Wenn ich einen TIdTcpServer einsetze und es connecten sich Clients, dann kann ich mit folgendem Konstrukt:

zusammenfalten · markieren

Delphi-Quellcode:

procedure TMainFormServer.Button1Click(Sender: TObject);
var
  AContextList : TList;
  AContext : TIdContext;
  AIndex, _i : Integer;
  AClient : PClient;
begin
  AContextList := TCPServer.Contexts.LockList;
  try
    for AIndex := 0 to Pred(AContextList.Count) do
    begin
      AContext := TIdContext(AContextList[AIndex]);
      AContext.Connection.IOHandler.WriteLn('*CLOSE')
    end;
  finally
    TCPServer.Contexts.UnLockList;
  end;
end;

... eine Message an alle angebundenen Clients senden. Aber wenn ich nicht irre passiert das im Kontext des MainThreads, oder?

Nun existiert aber für jeden angeschlossenen Client ein eigener Thread. Gibt es nicht eine Möglichkeit das ich diesem Thread Daten übergebe und der Thread dann selbstständig die Übermittlung der Daten an den jeweiligen Client übernimmt?

Die Daten kann man dem jeweiligen Thread mittels AContext.Data bereitstellen (so würde ich es jedenfalls versuchen). Jetzt müsste man dem Thread nur etwas Code an die Hand geben um die Daten zum Client zu senden. Denn wenn ich die oben gezeigte Methode nutze, dann blockt mir das bei großen Datenmengen, oder vielen Aufrufen meinen Hauptthread.

Any ideas

Hallo Dominik,

vielleicht könnte es so funktionieren.

zusammenfalten · markieren

Delphi-Quellcode:

type
  TDataDeliveryThread = class(TThread)
    private
      FtcpServer: TidTcpServer;
      FdataStack : TStringList;
    public
      constructor Create(tcpServer: TidTcpServer);
      destructor Destroy:
      procedure execute;
      procedure addToStack(s: String);
      
  end;

  procedure TDataDeliveryThread.execute;
  var
    i: Byte;
  begin
    while not terminated do
      begin
        while FdataStack.count > 0 do
          begin
            for i:=0 to Ftcpserver.contexts.lockList.count -1 do
              begin
                (FtcpServer.contexts.lockList[i] as TidContext).connection.IOHandler.writeLn(FdataStack[0]);
             end;
            FdataStack.delete(0);
          end;
        FTcpServer.contexts.unlockList;
        sleep(100);
      end;
  end;

(nicht geteste).

Grüße
Klaus

Moin Klaus,

in einem extra Thread. Ok das sollte gehen.

Ich hatte gehofft das man den (eh vorhandenen) Client Thread aus "Ftcpserver.contexts" nutzen könnte.
Aber wenn ich es recht überlege brauche ich ja nur einen Zusatzthread der dann alle Clients "abklappern" kann.

Werde das morgen mal testen und berichten.