Indy 10 / streams via tcp ip senden

[bernhard_LA]

meine Demoprojekt zum Verschicken und Empfangen von Streams mit INDY 10 spielt leider nicht, die Verbindung wird abgebrochen, ich kann den Fehler im Code nicht erkennen ....

Delphi-Quellcode:

var aFs  : TFileStream

....
..


///
///   demo  server empfängt einen stream und sendet einen stream zurück
///


procedure TStreamServerForm.IdTCPServer1Execute(AContext: TIdContext); var
   LSize: LongInt;
begin

   Memo1.Lines.Add('Server  starting  .... ' );


    AContext.Connection.IOHandler.ReadTimeout  := 9000;

   if ( ReceiveStream(AContext, TStream(afs)) = False ) then
   begin
     TIdNotify.NotifyMethod(ShowCannotGetStreamErrorMessage);
     Exit;
   end;


   TIdNotify.NotifyMethod(StreamReceived);


   if ( SendStream(AContext,TStream(afS)) = False ) then
   begin
     TIdNotify.NotifyMethod(ShowCannotSendStreamrErrorMessage);
     Exit;
   end;

   Memo1.Lines.Add('Server  done .... ' );

end;


///
///  demo client schickt einen stream und einen bekommt einen anderen zurück ///
///

procedure TStreamExchangeClientForm.Button_SendStreamClick(Sender: TObject); var  LSize: LongInt; begin

LSize := 0;

Memo1.Lines.Add('Try send stream to server.....');

   if (SendSTream(IdTCPClient1, TStream(afs)) = False) then
   begin
     Memo1.Lines.Add('Cannot send stream/buffer to server.');
     Exit;
   end;

   if (ReceiveStream(IdTCPClient1, TStream(afs)) = False) then
   begin
     Memo1.Lines.Add('Cannot get "OK" message from server, Unknown error occured');
     Exit;
   end;

   image1.Picture.Bitmap.LoadFromStream(afs);


end;

-----------------------------------------------------------------------------

      die low level indy routinen ..... 

------------------------------------------------------------------------------

function SendStream(AContext: TIdContext; AStream: TStream): Boolean; overload; begin
   Result := False;
   try
     AContext.Connection.IOHandler.Write(LongInt(SizeOf(AStream)));
     AContext.Connection.IOHandler.WriteBufferOpen;
     AContext.Connection.IOHandler.Write(AStream, SizeOf(AStream));
     AContext.Connection.IOHandler.WriteBufferFlush;
   finally
     AContext.Connection.IOHandler.WriteBufferClose;
   end;
   Result := True;
end;



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


function ReceiveStream(AClient: TIdTCPClient; var  AStream: TStream): 
Boolean;  overload;
var
   LSize: LongInt;
begin
   Result := False;
   LSize := AClient.IOHandler.ReadLongInt();
   AClient.IOHandler.ReadStream(AStream, LSize, False);
   Result := True;

end;

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, LongInt(StreamSize));
     AClient.IOHandler.WriteBufferFlush;
   finally
     AClient.IOHandler.WriteBufferClose;
   end;
   Result := True;
end;

[mjustin]

Wie wird der Stream auch erzeugt und mit Daten gefüllt? Beides ist im Code nicht zu sehen, auch das TStream(afs) ist auffällig - das afs als Unterklasse von TStream deklariert ist, braucht man keinen Typecast.

[bernhard_LA]

ich habe eine Demo-Projekzt auf Source forge eingestellte :

http://indy10clieservr.svn.sourcefor...treamExchange/ bzw. http://sourceforge.net/projects/indy10clieservr/


String Exchange (sample #1) und Record exchange (sample#2) funktionieren, Sttream Exchange (sample #4) ist nach dem selben Konzept gesztrickt, nur leider ist hier ein Bug.

Ich bin für jede Anregung Dankbar!

[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