delphi - 无法从 Datasnap 服务器检索大于约 260.000 字节的 TStream

Question

我有一个 Delphi 10.1 Berlin Datasnap 服务器，它无法返回大于大约 260.000 字节的数据包(通过 TStream)。

我按照 Delphi 的 \Object Pascal\DataSnap\FireDAC 示例对其进行了编程，该示例也显示了此问题。

只需打开该示例，将 ServerMethodsUnit.pas 上 qOrders 组件的 IndexFieldName 设置为空白，并将其 SQL 属性更改为:

select * from Orders
union 
select * from Orders

现在要发送的数据量超过了 260.000 字节，这似乎是您无法从客户端检索它的点。获取 EFDException [FireDAC][Stan]-710。无效的二进制存储格式。

数据作为从服务器上的 FDSchemaAdapter 获取的 Stream 发送，然后加载到客户端上的另一个 FDSchemaAdpater 上。 Client和Server之间的连接也是FireDAC。

这就是服务器返回该流的方式:

function TServerMethods.StreamGet: TStream;
begin
  Result := TMemoryStream.Create;
  try
    qCustomers.Close;
    qCustomers.Open;
    qOrders.Close;
    qOrders.Open;
    FDSchemaAdapter.SaveToStream(Result, TFDStorageFormat.sfBinary);
    Result.Position := 0;
  except
    raise;
  end;
end;

这就是客户端检索它的方式:

procedure TClientForm.GetTables;
var
  LStringStream: TStringStream;
begin
  FDStoredProcGet.ExecProc;
  LStringStream := TStringStream.Create(FDStoredProcGet.Params[0].asBlob);
  try
    if LStringStream <> nil then
    begin
      LStringStream.Position := 0;
      DataModuleFDClient.FDSchemaAdapter.LoadFromStream(LStringStream, TFDStorageFormat.sfBinary);
    end;
  finally
    LStringStream.Free;
  end;
end;

客户端没有获取 Blob 参数的所有数据。我在Server上保存了Stream的内容，在Client上保存了到达Blob参数的内容，它们的大小相同，但是Blob参数的内容被截断了，最后几Kbytes为零.

这就是我在服务器上保存将进入流的内容的方法:

FDSchemaAdapter.SaveToFile('C:\Temp\JSON_Server.json', TFDStorageFormat.sfJSON);

这是我检查从客户端 blob 参数获得的内容的方法:

TFile.WriteAllText('C:\Temp\JSON_Client.json', FDStoredProcGet.Params[0].asBlob);

我可以看到客户端的数据被截断了。

您知道如何修复它，或者将所有流内容从 Datasnap 服务器检索到我的客户端的解决方法吗？

更新:我已更新到 Delphi 10.1 Berlin Update 2，但问题仍然存在。

谢谢。

Answer 1

我在西雅图(我没有安装柏林)使用 DataSnap 时遇到了类似的问题不涉及 FireDAC 的服务器。

在我的 DataSnap 服务器上，我有:

type
  TServerMethods1 = class(TDSServerModule)
  public
    function GetStream(Size: Integer): TStream;
    function GetString(Size: Integer): String;
  end;

[...]

uses System.StrUtils;

function BuildString(Size : Integer) : String;
var
  S : String;
  Count,
  LeftToWrite : Integer;
const
  scBlock = '%8d bytes'#13#10;
begin
  LeftToWrite := Size;
  Count := 1;
  while Count <= Size do begin
    S := Format(scBlock, [Count]);
    if LeftToWrite >= Length(S) then
    else
      S := Copy(S, 1, LeftToWrite);
    Result := Result + S;
    Inc(Count, Length(S));
    Dec(LeftToWrite, Length(S));
  end;
  if Length(Result) > 0 then
    Result[Length(Result)] := '.'
end;

function TServerMethods1.GetStream(Size : Integer): TStream;
var
  SS : TStringStream;
begin
  SS := TStringStream.Create;
  SS.WriteString(BuildString(Size));
  SS.Position := 0;
  OutputDebugString('Quality Suite:TRACING:ON');
  Result := SS;
end;

function TServerMethods1.GetString(Size : Integer): String;
begin
  Result := BuildString(Size);
end;

如您所见，这两个函数都使用以下命令构建指定大小的字符串相同的 BuildString 函数，并分别将其作为流和字符串返回。

在此处的两个 Win10 系统上，GetStream 对于最大 30716 字节的大小可以正常工作，但是除此之外，它返回一个空流和 -1 的“大小”。

Otoh，GetString 适用于我测试过的所有尺寸，包括大小为 32000000。我还没有设法追踪 GetStream 失败的原因。然而，根据 GetString 确实工作的观察，我测试了以下解决方法，将流作为字符串发送，并且工作正常也到 32M:

function TServerMethods1.GetStreamAsString(Size: Integer): String;
var
  S : TStream;
  SS : TStringStream;
begin
  S := GetStream(Size);
  S.Position := 0;
  SS := TStringStream.Create;
  SS.CopyFrom(S, S.Size);
  SS.Position := 0;
  Result := SS.DataString;
  SS.Free;
  S.Free;
end;

我很高兴您可能更喜欢自己的解决方法，以 block 的形式发送结果。

顺便说一句，我尝试通过在服务器主窗体的方法中创建 TServerMethods 实例并调用 GetStream 在服务器上调用我的 GetStream code> 直接从中获取，因此不涉及服务器的 TDSTCPServerTransport。这正确地返回了流，因此问题似乎出在传输层或其输入和/或输出接口(interface)中。