HarmonyOS 鸿蒙Next中一个流式请求方法

HarmonyOS 鸿蒙Next中一个流式请求方法

// 异步方法：发起HTTP请求获取数据
async getHttpData(queryData: string) {
  // 在控制台打印查询字符串，用于调试
  console.log('http getHttpData query:' + queryData);
  // 创建QueryDataBean对象，作为请求体
  let query: QueryDataBean = {
    "inputs": {
      "query": queryData  // 将用户查询字符串放入请求体
    }
  }
  // 创建HTTP请求对象
  let httpRequest = http.createHttp();
  // 监听'dataReceive'事件：当收到服务器数据时触发（流式响应）
  httpRequest.on('dataReceive', (data: ArrayBuffer) => {
    // try-catch块：捕获并处理可能出现的异常
    try {
      // 创建一个TextDecoder实例，用于将二进制数据解码为字符串
      let decoder = util.TextDecoder.create('utf-8');
      // 将ArrayBuffer转换为Uint8Array，然后解码为字符串
      let stringData = decoder.decodeToString(new Uint8Array(data));
      // 打印接收到的原始字符串数据
      console.log('http 查询字符串结果：'+stringData);
      // 检查接收到的数据是否包含"content"字段
      if (stringData.includes("content")) {
        // 清洗字符串：移除不需要的字符和前缀
        let jsonStr=stringData.replace('data:','')  // 移除SSE格式的"data:"前缀
          .replaceAll('#','')  // 移除所有#字符
          .replaceAll('*','')  // 移除所有*字符
          .replaceAll('\uD83C\uDF0D','');  // 移除地球emoji字符
        // 打印清洗后的字符串
        console.log('http 转换后的字符串：'+jsonStr);
        // 将JSON字符串解析为ResultsBean对象
        let tempRes:ResultsBean = JSON.parse(jsonStr)
        // 将解析出的content内容追加到现有的result中
        this.result = this.result + tempRes.content
      }
    } catch (e) {
      // 异常处理：当前为空，任何异常都会被静默忽略
      // 在实际开发中，这里应该添加错误处理逻辑
    }
  });
  // 配置HTTP请求选项
  let streamInfo: http.HttpRequestOptions = {
    method: http.RequestMethod.POST,  // 请求方法为POST
    header: {  // 请求头
      'Content-Type': 'application/json',  // 内容类型为JSON
      "X-Auth-Token": token  // 认证令牌
    },
    extraData: JSON.stringify(query),  // 请求体数据（转换为JSON字符串）
    remoteValidation: 'skip',  // 跳过远程验证（用于开发环境）
  }
  // 发起流式HTTP请求
  httpRequest.requestInStream(url, streamInfo)
    .then((data: number) => {
      // 请求成功时的回调
      console.log('http requestInStream ok!');
    }).catch((error: BusinessError) => {
    // 请求失败时的回调
    // 当前为空，错误被静默忽略
    // 在实际开发中，这里应该添加错误处理逻辑
  })
}