我试图在 DataSnap 服务器/客户端之间传输一些大流(~1Mb),但无济于事。我试图理解吉姆·蒂尔尼的代码(http://blogs.embarcadero.com/jimtierney/2009/04/06/31461)运气不好,我什至无法编译代码,因为缺少库,无论如何......
我能够接收的流的最大大小是 64k,所以any您可以提供的提示/想法/代码示例周末程序员像我这样的人会很受欢迎。谢谢你!
我的服务器代码:
function TsrvMethods.getStream(iCount: integer): TStream;
begin
Result := dummyStream('0123456789', iCount);
end;
function dummyStream(sCnt: string; iCount: integer): TStream;
begin
Result := TMemoryStream.Create;
while iCount > 1 do begin
Result.Write(Pointer(sCnt)^, Length(sCnt));
Dec(iCount);
end;
Result.Seek(0, TSeekOrigin.soBeginning);
end;
我的客户调用代码:
procedure TfrmMain.butStreamClick(Sender: TObject);
var
sStr : TStream;
begin
cycleConnection; //make sure we have an active connection
with TsrvMethodsClient.Create( SQLConn.DBXConnection, False ) do begin
sStr := getStream( Integer(SpinCount.Value) );
Free;
end;
FreeAndNil(sStr);
end;
事实上,我想我已经明白了。我将此作为答案发布,也许其他人也需要这个。
procedure TfrmMain.butStreamClick(Sender: TObject);
const
iBufSize = 128;
var
sStr : TStream;
sMem : TMemoryStream;
buf: PByte;
iRead: integer;
begin
cycleConnection;
with TsrvMethodsClient.Create( SQLConn.DBXConnection, False ) do begin
sStr := getStream( 500000 ); //500k stream
GetMem(buf, iBufSize);
sMem := TMemoryStream.Create;
try
repeat
iRead := sStr.Read( Pointer(buf)^, iBufSize);
if iRead > 0 then sMem.WriteBuffer( Pointer(buf)^, iRead);
if iRead < iBufSize then break;
until iRead < iBufSize;
finally
FreeMem(buf, iBufSize);
end;
Free;
end;
FreeAndNil(sStr);
FreeAndNil(sMem);
end;
P.S.
通过搜索 DataSnap 代码示例,我发现一个(与速度相关的)改进是将 iBufSize 设置为 61440(或等效的十六进制值 $F000),这似乎是一次性可以接收的最大大小。如果接收流更大,则报告的大小将为 -1,并且需要上面的代码来读取整个流。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)