Delphi-PRAXiS
Seite 1 von 2  1 2   

Delphi-PRAXiS (https://www.delphipraxis.net/forum.php)
-   Netzwerke (https://www.delphipraxis.net/14-netzwerke/)
-   -   Indy 10 / streams via tcp ip senden (https://www.delphipraxis.net/164430-indy-10-streams-via-tcp-ip-senden.html)

bernhard_LA 12. Nov 2011 01:09

Indy 10 / streams via tcp ip senden
 
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 12. Nov 2011 07:35

AW: Indy 10 / streams via tcp ip senden
 
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 12. Nov 2011 09:23

AW: Indy 10 / streams via tcp ip senden
 
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 12. Nov 2011 18:16

AW: Indy 10 / streams via tcp ip senden
 
Liste der Anhänge anzeigen (Anzahl: 1)
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 23. Nov 2011 22:04

AW: Indy 10 / streams via tcp ip senden
 
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 23. Nov 2011 22:39

AW: Indy 10 / streams via tcp ip senden
 
Liste der Anhänge anzeigen (Anzahl: 1)
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 23. Nov 2011 22:55

AW: Indy 10 / streams via tcp ip senden
 
Und wo läuft das in dem Code auf?

bernhard_LA 23. Nov 2011 23:34

AW: Indy 10 / streams via tcp ip senden
 
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 24. Nov 2011 08:30

AW: Indy 10 / streams via tcp ip senden
 
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 24. Nov 2011 09:07

AW: Indy 10 / streams via tcp ip senden
 
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


Alle Zeitangaben in WEZ +1. Es ist jetzt 03:04 Uhr.
Seite 1 von 2  1 2   

Powered by vBulletin® Copyright ©2000 - 2024, Jelsoft Enterprises Ltd.
LinkBacks Enabled by vBSEO © 2011, Crawlability, Inc.
Delphi-PRAXiS (c) 2002 - 2023 by Daniel R. Wolf, 2024 by Thomas Breitkreuz