Hallo Zusammen,

ich versuche mich gerade an einem kleinen Webserver für eine Datenbankabfrage. Da der Webserver "Multitasking" fähig ist muss ich die Datenbankabfrage in einem Thread verbuchen.

Jetzt finde ich nicht wirklich sinnvolle Infos wie ich das genau anstellen muss...
Die Anfragen kommen als body im JSon Format rein und sollen auch als JSON in der ResponseInfo wieder raus.

in der IdHTTPServer1CommandGet(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo); kommen ja vom Server alle Daten an.

Wie bekomme ich die Sinnvoll in meinen Thread übergeben und vor allem die AResponseInfo wieder zurück?
ist denn wenigstens die CommandGet Routine (mit CreatePostStream & DoneWithPostStream) Threadsave ??

hier die einfache CommandGet Routine. Also wie übergebe ich die Daten an den Thread und wie bekomm ich die passende Antwort für den dazugehörigen IDContext?
Hat das schon mal jemand erfolgreich erledigt... ?

markieren

Code:

 

procedure TAct2DDM.IdHTTPServer1CommandGet(AContext: TIdContext;  ARequestInfo: TIdHTTPRequestInfo; AResponseInfo: TIdHTTPResponseInfo);
var
   Stream : TStream;
   sr : TStreamReader;
begin
  If ARequestInfo.CommandType = hcPOST then
  begin
   
    Stream := ARequestInfo.PostStream;
    SR := TStreamReader.Create(Stream);
    if Assigned(Stream) then
    begin
    try
        while not SR.EndOfStream do
        begin
          s:= s + SR.ReadLine;
        end;
     SR.Free;
     finally
    end;
    end;

    try
      Access := _Json(s);
      meinThread;
    except
    end;

  AResponseInfo.ContentType := 'applicaton/json';
  AResponseInfo.ResponseNo := iResponse;
  AResponseInfo.CharSet    := 'utf-8';
  AResponseInfo.ContentEncoding := 'utf-8';
  AResponseInfo.ContentText := (meinThread_Antwort);
end;

Vielen Dank für die Umgehung meine Gehirnbremse
Stevie

.. läuft denn die ganze Abarbeitung des Webrequest nicht eh schon in einem Thread.
OnCommandGet ist doch meines Wissens nicht blockierend.

Grüße
Klaus

Zitat von Klaus01:

.. läuft denn die ganze Abarbeitung des Webrequest nicht eh schon in einem Thread.
OnCommandGet ist doch meines Wissens nicht blockierend.

Grüße
Klaus

Klar, aber das die Abfrage doch recht umfangreich ist würde ich das gerne als Thread machen... Die Routine würde sonst den Editor sprengen
Das hieße ja dass alles an Code in die eine Schleife muss... Was ja theoretisch gehen würde.

Und es macht ja Sinn es als eigenen Thread laufen zu lassen. Pro Abfrage auf großen DB's braucht die schon mal bis zu 500ms und wenn 4 oder 5 pro Sekunde reinkommen reicht das nicht es nacheinander zu machen.

Btw. interessiert mich die Lösung wie ich das übergebe und zurück bekomme...

.. wenn Du hier:

markieren

Delphi-Quellcode:

    try
      Access := _Json(s);
      meinThread;
    except
    end;

Deinen Thread startest musst Du irgendwie darauf warten bis er beendet ist
um Deine verarbeiteten Daten der responseInfo zu übergeben.

markieren

Delphi-Quellcode:

  AResponseInfo.ContentType := 'applicaton/json';
  AResponseInfo.ResponseNo := iResponse;
  AResponseInfo.CharSet := 'utf-8';
  AResponseInfo.ContentEncoding := 'utf-8';
  AResponseInfo.ContentText := (meinThread_Antwort);

Also, warum dann einen Thread verwenden.
Wenn Dir der Code die onCommandget Routine zu groß aufbläst, lagere ihn in eine Methode aus.

Grüße
Klaus

Wie bereits erwähnt wurde, erzeugt der HTTP-Server schon Threads. Ein weiterer Thread ist also nicht nötig.

Du musst lediglich darauf achten, dass jeder Thread seine eigene Connection (und natürlich eigene Queries) hat.

Am einfachsten und strukturiertesten geht das, wenn du dir ein Webbroker-Projekt erstellst und dort dann im "WebModul" deine Pfade definierst und ausprogrammierst. Je Thread kriegst du auch ein Webmodul automatisch erzeugt, du kannst dein Connection und Queries auch drauf legen... Du darfst nur keine globalen Variablen verwenden und Felder/Properties sind nur für die eine Abfrage zu verwenden, da die nächste Abfrage in einem anderen Thread/Webmodul-Instanz landen kann.

Hallo Zusammen,

danke Euch. Habe durch die Anregungen eine Lösung gefunden!

Grüße Stevie