Indy 10 / streams via tcp ip senden

[chaosben]

Delphi-Quellcode:

function SendStream(AContext: TIdContext; AStream: TStream): Boolean; overload; begin
   Result := False;
   try
     AContext.Connection.IOHandler.Write(LongInt(SizeOf(AStream))); //<-- sendet 4, da die Größe eines Objektes 4 Byte sind (unter 32bit)
     AContext.Connection.IOHandler.WriteBufferOpen;
     AContext.Connection.IOHandler.Write(AStream, SizeOf(AStream)); //<-- da wolltest du bestimmt den Inhalt senden und nicht schon wieder 4 ;)
     AContext.Connection.IOHandler.WriteBufferFlush;
   finally
     AContext.Connection.IOHandler.WriteBufferClose;
   end;
   Result := True;
end;

Anbei mal ein kleines Beispiel, wie ich es machen würde.

[bernhard_LA]

Danke für die Antwort, Du verwendest "sockets2 und nicht den IOhandler warum ?

Delphi-Quellcode:

procedure TForm15.Button1Click(Sender: TObject);
var
  ms : TMemoryStream;
  g : TGraphic;
begin
  if not IdTCPClient1.Connected then
    IdTCPClient1.Connect;

  ms := TMemoryStream.Create;
  g := TGraphic(Image1.Picture.Graphic.ClassType.Create);
  try
    Image1.Picture.Graphic.SaveToStream(ms);

    ms.Seek(0,soFromBeginning);
    IdTCPClient1.Socket.Write(ms, ms.Size, true);
    ms.Clear;
    IdTCPClient1.Socket.ReadStream(ms, IdTCPClient1.Socket.ReadLongInt);

    ms.Seek(0, soFromBeginning);
    g.LoadFromStream(ms);
    Image2.Picture.Graphic := g;
  finally
    ms.Free;
    g.Free;
  end;
end;

procedure TForm15.IdTCPServer1Connect(AContext: TIdContext);
begin
  AContext.Connection.Socket.ReadTimeout := 50;
end;

procedure TForm15.IdTCPServer1Execute(AContext: TIdContext);
var
  ms : TMemoryStream;
begin
  ms := TMemoryStream.Create;
  try

    try
      AContext.Connection.Socket.ReadStream (ms, AContext.Connection.Socket.ReadLongInt);
    except
      on E: EIdReadTimeout do begin end;
    end;

    if ms.Size > 0 then
    begin
      ms.Seek(0, soFromBeginning);
      AContext.Connection.Socket.Write(ms, ms.Size, true);
    end;

  finally
    ms.Free;
  end;
end;

[bernhard_LA]

Nachtrag : mit folgendem Code bekomme ich eine AV (siehe screen dump) warum kann ich auf den Stream nicht zugreifen ?

Delphi-Quellcode:

///  server read stream
function ReceiveStream(AContext: TIdContext; var AStream: TStream): Boolean; overload;
var
  LSize: LongInt;
begin
  try
  LSize := AContext.Connection.IOHandler.ReadLongInt();
  AContext.Connection.IOHandler.ReadStream(AStream, LSize);
  Result := True;
  except
  Result := False;
  end;
end;





///  client send stream 
function SendStream(AClient: TIdTCPClient; AStream: TStream): Boolean;  overload;
var StreamSize   : LongInt;
begin

  Result := True;
  try
    StreamSize := (AStream.Size);

    AStream.Seek(0, soFromBeginning);

    AClient.IOHandler.LargeStream := True;
    AClient.IOHandler.SendBufferSize := 32768;
    AClient.IOHandler.Write(LongInt(StreamSize));
    AClient.IOHandler.WriteBufferOpen;
    AClient.IOHandler.Write(AStream, StreamSize);
    AClient.IOHandler.WriteBufferFlush;
  finally
    AClient.IOHandler.WriteBufferClose;
  end;
  Result := True;
end;

[daywalker9]

Und wo läuft das in dem Code auf?

[bernhard_LA]

die AV ist auf der Server seite bei *** AContext.Connection.IOHandler.ReadStream(AStream, LSize);
LSize ist richtig übertragen


ich habe folgende Links zu meinem Problem gefunden:

http://stackoverflow.com/questions/3...o-server-in-in

http://stackoverflow.com/questions/8...riting-streams

leider sehe ich nur nicht meinen Fehler entweder ist mein Stream schreibgeschützt oder meine Kombination auf READSTEAM (SERVER) und WRITESTREAM (CLIENT) stimmt immer noch nicht

[chaosben]

Sorry ... hab erst jetzt deine Frage gesehen: ich nehme Socket weil, ich das mal so bei den Indys gelesen habe. Ob und was der "richtige" Weg ist, weiß ich nicht.

[bernhard_LA]

die links weiter oben geben halt leider keine komplette Anleitung wie man send and receive stream aufeinander anpasst,
bin immer noich auf der such nach meinem Fehler