Delphi TNetHTTPClient使用递归方式取所有分页数据
业务系统提供的一个查询数据接口，可以通过分页方式取得数据，如果一次性取得所有数据，将页大小增大即可，但如果数据太多怕会造成内存溢出。
综合考虑每次只取一个分页，分页数据不要太大，用递归方式来获取是比较合理的解决方案，当页码大到一个数量，取不出数据即结束递归。
具体的实践代码示例：
uses
System.Net.URLClient, System.Net.HttpClient, System.Net.HttpClientComponent,
DateUtils,
System.JSON;
procedure httpGetCustomer(pageNum: Integer; pageSize: Integer);
var
xh: Integer;
s: String;
str: String;
url: String;
client: TNetHTTPClient;
// vParams: TStringList; // 参数
vParams: TStringStream; // 接收值
vResponse: IHTTPResponse; // 接收参数
jsonData: TJSONObject;
retData: String;
code: String;
jsonRetData: TJSONObject;
total: Integer;
jv: TJSONValue;
rows: TJSONArray;
jsonCustomer: TJSONValue; // TJSONObject;
json2: TJSONObject;
beginTime, endTime: String;
token: String;
begin
token:=httpGetToken();
beginTime := FormatDateTime('yyyy-MM-dd', incDay(now, 0));
endTime := FormatDateTime('yyyy-MM-dd', incDay(now, 1));
//组装接
url := 'http://localhost/sys/customer/list?pageNum=' + IntToStr(pageNum) + '&pageSize=' + IntToStr(pageSize) + '&beginTime=' + beginTime + '&endTime=' + endTime;
log('取列表URL');
log(url);
client := TNetHTTPClient.Create(nil);
vParams := TStringStream.Create(); // 接收值
try
client.SecureProtocols := [THTTPSecureProtocol.TLS12];
client.ContentType := 'application/json;charset=UTF-8';
client.CustomHeaders['Authorization'] := token;
// vResponse := client.Get(url, vParams);
vResponse := client.Get(url);
if vResponse.StatusCode = 200 then
begin
log('取得列表返回');
log('---------');
log(vResponse.ContentAsString);
log('---------');
retData := vResponse.ContentAsString;
if retData <> '' then
begin
jsonData := TJSONObject.ParseJSONValue(Trim(vResponse.ContentAsString)) as TJSONObject;
code := '';
code := jsonData.Get('code').JsonValue.Value;
if code = '200' then
begin
s := jsonData.Get('data').ToString;
log('取得列表');
log('---------');
if ((jsonData.GetValue('data') as TJSONObject).TryGetValue('rows', jv)) then
begin
// 如果rows节点不存在 会报异常的
rows := ((jsonData.GetValue('data') as TJSONObject).GetValue('rows') as TJSONArray); // 不可以多级？？？
if rows.Size <= 0 then
begin
// Showmessage('为空的列表');
log('已取完，为空的列表');
end;
log('取到数据数量：' + IntToStr(rows.Size));
if rows.Size > 0 then
begin
// getCustomersData(rows);
for jsonCustomer in rows do
begin
application.ProcessMessages;
xh := xh + 1;
//log(IntToStr(xh));
var
json6: TJSONObject := jsonCustomer as TJSONObject;
log(json6.GetValue('customerId').Value);
end;
//递归 继续取下一页
httpGetCustomer(pageNum + 1, pageSize);
end;
end;
end;
end;
end
else
begin
log('获取列表失败:' + IntToStr(vResponse.StatusCode));
log('获取列表失败原因:' + vResponse.StatusText);
end;
finally
client.Free;
vParams.Free;
end;
end;效果
