Datei über DataSnap Verbindung senden

[himitsu]

Nja, DataSnap ist halt soooooo cool und new-style, da wollten wir es mal ausprobieren.

Es kann doch nicht sein, daß soein hochbeworbenes Produkt derartig beschränkt und fehleranfällig ist.

Wenn es aber so gedacht ist, dann sollte man wenigstens solche Beschränkungen auch nennen und mit entsprechenden Fehlermeldungen behandeln.

[DSCHUCH]

ich war auch der meinung das beruht auf indy, oder liege ich da falsch?

[himitsu]

Jupp, irgendwo im Inneren kommt dann Indy und ich glaub ein DataSet war auch irgendwo mit dabei.

[himitsu]

So, hab mich nun doch nochmal an Emba gewendet.
http://qc.embarcadero.com/wc/qcmain.aspx?d=90995

Ich liebe dieses vor Datenschutz mangelnde Meldesystem, welches den Post löscht und man alle neu schreiben müßte, wenn man nicht schnell genug schreibt, bevor man wieder ausgeloggt wird.
Und wenn sich wer über das größtenteils Goggle-Translate-Englisch beschwert, dann steige ich wieder auf den Babelfish um.

[add]
noch 'ne kleine Demoanwendung

Code:

Size of Stream (0 = Exit, -1 = basic tests): -1

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 0

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 0 (0)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 100

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 100 (100)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 29000

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 29000 (29000)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 32000

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXStreamReaderStream
  Result.Size      = -1 (32000)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 64000

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXStreamReaderStream
  Result.Size      = -1 (64000)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 1000000

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXStreamReaderStream
  Result.Size      = -1 (1000000)

Size of Stream (0 = Exit, -1 = basic tests):

Code:

Starting TServerContainer1
Press ESC to stop the server

TServerMethods1.SendToServer
  Data.ClassName = TDBXBytesStream
  Data.Size      = 0 (0)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 0

TServerMethods1.SendToServer
  Data.ClassName = TDBXBytesStream
  Data.Size      = 100 (100)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 100

TServerMethods1.SendToServer
  Data.ClassName = TDBXBytesStream
  Data.Size      = 29000 (29000)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 29000

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (32000)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 32000

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (64000)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 64000

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (1000000)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 1000000

und wenn ServerContainerUnit.TServerContainer1.DSTCPServerT ransport1.BufferKBSize auf 1000 gesetzt ist, dann sieht es so aus:

Code:

**************************************************
*** Client ***************************************
**************************************************

Starting TServerContainer1
Press ESC to stop the server

TServerMethods1.SendToServer
  Data.ClassName = TDBXBytesStream
  Data.Size      = 0 (0)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 0

TServerMethods1.SendToServer
  Data.ClassName = TDBXBytesStream
  Data.Size      = 100 (100)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 100

TServerMethods1.SendToServer
  Data.ClassName = TDBXBytesStream
  Data.Size      = 29000 (29000)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 29000

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (32768)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 32768

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (65535)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 65535

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (65536)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 65536

TServerMethods1.SendToServer
  Data.ClassName = TDBXStreamReaderStream
  Data.Size      = -1 (1000000)

TServerMethods1.ReciveFromServer
  Result.ClassName = TMemoryStream
  Result.Size      = 1000000



**************************************************
*** Server ***************************************
**************************************************

Size of Stream (0 = Exit, -1 = basic tests): -1

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 0

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 0 (0)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 100

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 100 (100)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 29000

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 29000 (29000)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 32768

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 32768 (32768)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 65535

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXBytesStream
  Result.Size      = 65535 (65535)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 65536

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXStreamReaderStream
  Result.Size      = -1 (65536)

ServerMethods1Client.SendToServer
  Data.ClassName = TMemoryStream
  Data.Size      = 1000000

ServerMethods1Client.ReciveFromServer
  Result.ClassName = TDBXStreamReaderStream
  Result.Size      = -1 (1000000)

Size of Stream (0 = Exit, -1 = basic tests):

[himitsu]

Gut, das war's.

Hab mich nun mühevoll bis zur entscheidenden Stelle durchgedebuggt.

Delphi-Quellcode:

function TDBXRowBuffer.WriteBytes(const Reader: TDBXStreamReader): Integer;
var
  Count: Integer;
begin
  if (FOff + TDBXFieldHeader.FBigHeaderLength + FMaxInline) > FBufLength then
    Growbuf(TDBXFieldHeader.FBigHeaderLength + FMaxInline);
  Count := Reader.Read(FBuf, FOff + TDBXFieldHeader.FBigHeaderLength, AvailableInline);
  if Count < 1 then
    FBuf[IncrAfter(FOff)] := Byte((TDBXFieldHeader.FTinyField))
  else 
  begin
    if Reader.Eos then
      FBuf[FOff] := Byte((TDBXFieldHeader.FBigField))
    else 
      FBuf[FOff] := Byte((TDBXFieldHeader.FBigField + TDBXFieldHeader.FPositive));
    FBuf[FOff + 1] := Byte(((Count shr 8) and 255));
    FBuf[FOff + 2] := Byte(((Count) and 255));
    FOff := FOff + Count + TDBXFieldHeader.FBigHeaderLength;
  end;
  Result := Count;
end;

AvailableInline begrenzt den Stream so, daß er in den Übertragungspuffer (BufferKBSize) reinpaßt und daß dieser kleiner als 64 KB ist, da es nur 2 Byte für die Längenangabe gibt.

Heißt also, daß standardmäßig nur ~29 KB und maximal nur 64 KB pro Stream zur Verfügung stehen.

Eine passende Fehlermeldung oder ein Hinweis in der Dokumentation hätte das Ganze bestimmt vereinfacht.




Bleibt jetzt nur die Frage, ob man den Stream nur in kleine Stückchen aufteilen und dieses dann einzeln versenden/abrufen soll, oder ob man den Stream über eine alternative Route verschickt (würde da aber gerne die Datenverbindung vom DataSnap nutzen)