HarmonyOS 鸿蒙Next中求助,后端接口是分段的流式返回,怎么实现实时获取

可以使用HTTP流式传输，HTTP流式传输请求是指在处理HTTP响应时，可以一次只处理响应内容的一小部分，而不是一次性将整个响应加载到内存，这对于处理大文件、实时数据流等场景非常有用。

完整示例代码见：Http_case

1. 导入HTTP流式传输所需模块

import { http } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { common } from '@kit.AbilityKit';

1. 创建HTTP流式传输HttpRequest对象

调用createHttp()方法，创建HttpRequest对象。

// 每一个httpRequest对应一个HTTP请求任务，不可复用。
let httpRequest = http.createHttp();

1. 按需订阅HTTP流式响应事件

服务器响应的数据在dataReceive回调中返回，可通过订阅该信息获取服务器响应的数据，其他流式响应事件可按需进行订阅。

// 用于订阅HTTP流式响应数据接收事件。
let res = new ArrayBuffer(0);
httpRequest.on('dataReceive', (data: ArrayBuffer) => {
  const newRes = new ArrayBuffer(res.byteLength + data.byteLength);
  const resView = new Uint8Array(newRes);
  resView.set(new Uint8Array(res));
  resView.set(new Uint8Array(data), res.byteLength);
  res = newRes;
  console.info('res length: ' + res.byteLength);
});

// 用于订阅HTTP流式响应数据接收完毕事件。
httpRequest.on('dataEnd', () => {
  console.info('No more data in response, data receive end');
});

// 订阅HTTP流式响应数据接收进度事件，下载服务器的数据时，可以通过该回调获取数据下载进度。
httpRequest.on('dataReceiveProgress', (data: http.DataReceiveProgressInfo) => {
  console.log("dataReceiveProgress receiveSize:" + data.receiveSize + ", totalSize:" + data.totalSize);
});

// 订阅HTTP流式响应数据发送进度事件，向服务器上传数据时，可以通过该回调获取数据上传进度。
httpRequest.on('dataSendProgress', (data: http.DataSendProgressInfo) => {
  console.log("dataSendProgress receiveSize:" + data.sendSize + ", totalSize:" + data.totalSize);
});

1. 发起HTTP流式请求，获取服务端数据。

let streamInfo: http.HttpRequestOptions = {
  method: http.RequestMethod.POST, // 可选，默认为http.RequestMethod.GET，用于向服务器获取数据，而POST方法用于向服务器上传数据。
  // 开发者根据自身业务需要添加header字段。
     header: {
    'Content-Type': 'application/json'
     },
     // 当使用POST请求时此字段用于传递请求体内容，具体格式与服务端协商确定。
  extraData: "data to send",
  expectDataType: http.HttpDataType.STRING,// 可选，指定返回数据的类型。
  usingCache: true, // 可选，默认为true。
  priority: 1, // 可选，默认为1。
  connectTimeout: 60000, // 可选，默认为60000ms。
  readTimeout: 60000, // 可选，默认为60000ms。若传输的数据较大，需要较长的时间，建议增大该参数以保证数据传输正常终止。
  usingProtocol: http.HttpProtocol.HTTP1_1, // 可选，协议类型默认值由系统自动指定。
}

// 填写HTTP请求的URL地址，可以带参数也可以不带参数。URL地址需要开发者自定义。请求的参数可以在extraData中指定。
httpRequest.requestInStream("EXAMPLE_URL", streamInfo).then((data: number) => {
  console.info("requestInStream OK!");
  console.info('ResponseCode :' + JSON.stringify(data));
  // 取消订阅步骤3中订阅的事件，并调用destroy方法主动销毁。
  this.destroyRequest(httpRequest);
}).catch((err: Error) => {
  console.error("requestInStream ERROR : err = " + JSON.stringify(err));
  // 取消订阅步骤3中订阅的事件，并调用destroy方法主动销毁。
  this.destroyRequest(httpRequest); 
});

1. 取消步骤3中订阅HTTP流式响应事件，并调用destroy()方法销毁流式HTTP请求

调用该对象的off()方法，取消订阅步骤3中的事件，并且当该请求使用完毕时，调用destroy()方法销毁，该方法调用的时机，可以参考步骤4中的示例代码。

public destroyRequest(httpRequest: http.HttpRequest) {
  // 取消订阅HTTP流式响应数据接收事件。
  httpRequest.off('dataReceive');
  // 取消订阅HTTP流式响应数据发送进度事件。
  httpRequest.off('dataSendProgress');
  // 取消订阅HTTP流式响应数据接收进度事件。
  httpRequest.off('dataReceiveProgress');
  // 取消订阅HTTP流式响应数据接收完毕事件。
  httpRequest.off('dataEnd');
  // 当该请求使用完毕时，调用destroy方法主动销毁。
  httpRequest.destroy();
}