OANDA网站提供的REST API可以读取账户信息("https://api-fxtrade.oanda.com/v1/accounts),以及提供流报价(streaming,比如"https://stream-fxtrade.oanda.com/v1/prices?accountId=12345&instruments=AUD_CAD%2CAUD_CHF" )。
目前在XE7版本,使用Delphi提供的RestClient组件可以实现读取账户信息。但是,对于服务端的流数据,由于其传输方式是 chunked transfer encoding,按照账户数据读取方式则会在停在最后Excute无法获得返回的Json字符串。
代码如下:
function GetStreamingPrices:TQJson
var
....
begin
Result := TQJson.Create;
// Get
_RESTRequest.Method := rmGET;
//指定资源位置:'/prices'
_RESTRequest.Resource := TRequestSourceURITemplate.Prices;
//生成query串:accountId=12345&instruments=AUD_CAD%2CAUD_CHF
_RESTRequest.AddParameter(TQueryPairKey.AccountID,accountlist[0],pkGETorPOST);
_RESTRequest.AddParameter(TQueryPairKey.Instruments,'EUR_USD',pkGETorPOST);
//URL
._RestClient.BaseURL := 'https://stream-fxtrade.oanda.com/v1';
//执行
_RestRequest.Execute;
//解析为Json
Result.tryParse(_RESTResponse);
end;
so,请教,如何使用Delphi XE7 的RestClient 获取 chunked transfer encoding 的流数据?请不吝赐教。
多谢一楼 @caozhy 提供的信息,不过没有没有解决此问题。我再描述一下:
1、上面的代码用于正常的request-response过程,是没有问题的。
2、 问题出在,报价流的获取上。报价服务器在工作时段实际是持续传输,一直没有结束,采取chunked transfer encoding模式持续地向外传输当时的即时价格信息。使用上面代码,就会处在一直等待状态下。
因此,需要达到的目标就是:一,不能等到结束标志才去解析收到的字符串。二,即便间歇获取数据,如果中间的缓冲时间过长,也不能忍受。