快捷導(dǎo)航

node使用querystring內(nèi)置模塊解決分頁返回數(shù)據(jù)太多導(dǎo)致json.parse()解析報錯問題

更新時間：2024年09月06日 09:51:12 作者：-風(fēng)過無痕

這篇文章主要介紹了node使用querystring內(nèi)置模塊解決分頁返回數(shù)據(jù)太多導(dǎo)致json.parse()解析報錯問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

前言

最近在使用node服務(wù)，http模塊調(diào)用其他服務(wù)的分頁接口有時JSON.parse（）會報錯
發(fā)現(xiàn)當(dāng)分頁返回json數(shù)據(jù)過多時，會導(dǎo)致控制臺輸出不全-數(shù)據(jù)不對-導(dǎo)致JSON.parse（）出錯
查閱資料發(fā)現(xiàn)，控制臺輸出也是相當(dāng)于開辟了一塊空間，現(xiàn)在這塊空間存不下這么多json數(shù)據(jù)
node有提供內(nèi)置模塊解決方案，使用querystring內(nèi)置模塊-把json數(shù)據(jù)以流的形式輸出轉(zhuǎn)換

代碼實現(xiàn)

// 導(dǎo)入http模塊
const http = require("http");
 
// 導(dǎo)入querystring模塊
const querystring = require("querystring");
 
// 注意基地址
// let base_url = "https://ceshi.com"
 
// 基地址-去掉https://前綴 - 不去會報錯
let base_url = "ceshi.com"
 
 
 
 
// post-請求 - 分頁查詢
// 使用promise - 方便維護和管理
const requestpost = () => {
  return new Promise((resolve, reject) => {
 
    // 請求參數(shù)
    let postData = querystring.stringify({
      // 頁碼
      // 頁數(shù)
      // 總數(shù)
      // 參數(shù)
    });
 
    // 配置項
    const options = {
      // 基地址
      hostname: base_url,
      // 默認端口-不要改
      port: 80,
      // 接口路徑
      path: "/api/ceshi/list",
      // 請求方式
      method: "post",
      // 請求頭信息
      headers: {
        // 請求參數(shù)格式
        "Content-Type": "application/json; charset=utf-8",
        // token
        Authorization: "",
      },
    };
 
    // 發(fā)送請求
    const getpost = http.request(options, (res) => {
      // 會包裝一層data-看打印
      // console.log('res',res)
      // 使用JSONStream解析數(shù)據(jù)
      // 真正數(shù)據(jù)data-不然jsonStream.on會執(zhí)行多次
      const jsonStream = JSONStream.parse(res.data);
 
      // 處理解析到的每個對象
      jsonStream.on("data", (data) => {
        // console.log("打印數(shù)據(jù)", data);
        // 全部數(shù)據(jù)-最外層
        resolve(data);
      });
      
      // 解析錯誤
      jsonStream.on("error", (err) => {
        console.error(err.message);
      });
 
      // 將響應(yīng)流 - 放到JSONStream
      res.pipe(jsonStream);
 
    });
 
    // 錯誤處理
    getpost.on("error", (err) => {
      // 返回失敗結(jié)果
      reject(err.message);
    });
 
    // 請求參數(shù)-寫入
    getpost.write(postData);
 
    // 結(jié)束請求-不寫請求發(fā)送不出去
    getpost.end();
 
  });
};