Indy TCP Client/Server

[mjustin]

Zitat von sx2008:

Dein Sender schickt immer 4 Byte Länge + Nutzdatenblock.
Der Empfänger muss folgende Strategie anwenden.
...
Nur so gelingt eine saubere Kommunikation!

Im Prinzip ja, aber der Indy TIdTCPServer kapselt den Low-level Teil dieses Vorgehens bereits. Man muss also nur noch das Protokoll (Länge lesen, dann Daten lesen) behandeln.

[BlackSeven]

Zitat:

Im Prinzip ja, aber der Indy TIdTCPServer kapselt den Low-level Teil dieses Vorgehens bereits

Ich kann die Befehle + Daten in eine threadsichere Queue packen und dann versenden.
Ändert das überhaupt was?

Delphi-Quellcode:

procedure Invoke(const ACommandID: Integer; const AData: TBytes);
begin

  Queue.Push(TCommand.Create(ACommandID, AData);
  
  EventSend.SetEvent;

end;

Im Thread, der für das Versenden zuständig ist:

Delphi-Quellcode:

procedure TSendThread.Execute;
var
  
  Command : TCommand;

begin

  WaitForSingleObject(EventSendHandle, INFINITE);

  Command := Queue.Pop;

  // Daten versenden

end;

[BlackSeven]

So funktioniert es:

Delphi-Quellcode:

var

  DataSize : LongInt;
  Data     : TBytes;
  Value    : Integer;

begin

  AContext.Connection.IOHandler.CheckForDataOnSource(10);

  if not AContext.Connection.IOHandler.InputBufferIsEmpty then
  begin

    DataSize := AContext.Connection.IOHandler.ReadLongInt;
    AContext.Connection.IOHandler.ReadBytes(Data, DataSize);

    Value := 0;
    Move(Data[0], PByte(Value), SizeOf(Integer));

    TThread.Queue
    (

      TThread.CurrentThread,

      procedure
      begin

        UI.Caption := IntToStr(Value);

      end

    );

  end;

end;

Zitat:

AContext.Connection.IOHandler.CheckForDataOnSource (10);

[shmia]

Zitat von mjustin:

Im Prinzip ja, aber der Indy TIdTCPServer kapselt den Low-level Teil dieses Vorgehens bereits

Da habe ich meine Zweifel.
Angenommen es treffen 1500 frische Bytes beim Empfänger ein.
Dann wird folgender Code ausgeführt

Delphi-Quellcode:

  if not AContext.Connection.IOHandler.InputBufferIsEmpty then
  begin
    // 4 Bytes auslesen
    DataSize := AContext.Connection.IOHandler.ReadLongInt;
    // Nutzdaten lesen    
    AContext.Connection.IOHandler.ReadBytes(Data, DataSize);

Was aber wenn Datasize=2000 aber es sind nur 1496 Bytes im Puffer?
Dann werden bei ReadBytes auch nur 1496 Bytes gelesen.
(Sollte man nicht den Rückgabewert von ReadBytes() auswerten?)
Alle folgende Datenpakete werden dann falsch interpretiert!!
Denn sobald die restlichen Daten eintreffen "denkt" der Empfänger er würde
wieder eine Längenangabe bekommen, in Wirklichkeit sind es aber 4 Byte aus der Mitte
eines Nutzdatenblocks.

[mjustin]

Zitat von shmia:

Was aber wenn Datasize=2000 aber es sind nur 1496 Bytes im Puffer?
Dann werden bei ReadBytes auch nur 1496 Bytes gelesen.

ReadBytes blockiert bis die gewünschte Anzahl Bytes gelesen wurde, oder ein TimeOut auftritt.

 procedure ReadBytes(var VBuffer: TIdBytes; AByteCount: Integer; AAppend: Boolean = True); virtual; ist eine Prozedur, daher ist der Rückgabewert unproblematisch.

Aber der dritte Parameter ist verdächtig: wenn VBuffer bereits Daten enthält, werden neue Daten angehängt.

Nach ReadBytes sollten die Daten doch bereits in Data stehen, was macht dann diese Zeile?

 Move(Data[0], PByte(Value), SizeOf(Integer));

[bernhard_LA]

PS: ich habe einfache demos auf source forge zu TCP IP INDY 10

[BlackSeven]

Zitat von bernhard_LA:

PS: ich habe einfache demos auf source forge zu TCP IP INDY 10

Sehr interessant. Gibt es dazu einen Link? Wäre nämlich sehr hilfreich.

[bernhard_LA]

unter http://sourceforge.net/projects/indy10clieservr/ sind die demos


arbeite zur zeit an dem Komplex sample mit GENERIC RECORD TYPE im Datenaustausch un INDY 10 mit SSL

[BlackSeven]

Zitat:

unter http://sourceforge.net/projects/indy10clieservr/ sind die demos

Vielen Dank!

[BlackSeven]

Zitat:

Nach ReadBytes sollten die Daten doch bereits in Data stehen, was macht dann diese Zeile?

 Move(Data[0], PByte(Value), SizeOf(Integer));

Kopiert den Integer-Wert aus dem Byte Array in die lokale Variable "Value".

So besser?

Move(Data[0], PByte(@Value)[0], Length(Data));