不完整的节点 HTTP.Response

Question

我的应用程序构建了一个自定义整数数组，需要将这些整数连接起来以创建对经济数据的动态请求。

创建变量选项后，我通过 http 请求将其推送并尝试解析响应，但出现错误 -

SyntaxError: Unexpected end of JSON input
at JSON.parse (<anonymous>)

当我使用我的代码读取正文时，响应会提前中断，并且我在 console.log() 中没有得到完整的响应。

我已经测试了请求值并将结果放在我的搜索栏中并产生了积极的结果。

关于为什么响应中的正文被缩短的任何想法？我需要从此请求中读取所有数据，并且在解析时出现错误。

这里是代码-

var options = {
host: 'api.eve-central.com',
port: 80,
path: '/api/marketstat/json?typeid=18&typeid=19&typeid=20&typeid=21&typeid=22&typeid=34&typeid=35&typeid=36&typeid=37&typeid=38&typeid=39&typeid=40&typeid=41&typeid=42&typeid=43&typeid=44&typeid=45&typeid=49&typeid=50&typeid=51&typeid=52&typeid=164&typeid=165&typeid=166&typeid=178&typeid=179&typeid=180&typeid=181&typeid=182&typeid=183&typeid=184&typeid=185&typeid=186&typeid=187&typeid=188&typeid=189&typeid=190&typeid=191&typeid=192&typeid=193&typeid=194&typeid=195&typeid=196&typeid=197&typeid=198&typeid=199&typeid=200&typeid=201&typeid=202&typeid=203&typeid=204&typeid=205&typeid=206&typeid=207&typeid=208&typeid=209&typeid=210&typeid=211&typeid=212&typeid=213&typeid=215&typeid=216&typeid=217&typeid=218&typeid=219&typeid=220&typeid=221&typeid=222&typeid=223&typeid=224&typeid=225&typeid=226&typeid=227&typeid=228&typeid=229&typeid=230&typeid=231&typeid=232&typeid=233&typeid=234&typeid=235&typeid=236&typeid=237&typeid=238&typeid=239&typeid=240&typeid=241&typeid=242&typeid=243&typeid=244&typeid=245&typeid=246&typeid=247&typeid=248&typeid=249&typeid=250&typeid=251&typeid=252&typeid=253&typeid=254&usesystem=30000142',
method: 'GET'
}

function requester(options) {
http.request(options, function (res) {
    //console.log('STATUS: ' + res.statusCode);
    //console.log('HEADERS: ' + JSON.stringify(res.headers));
    res.setEncoding('utf8');
    res.on('data', function (chunk) {
        console.log('BODY: ' + chunk);
        var payload = JSON.parse(chunk);
        //console.log('After Parse: ' + payload);
        //Separating the payload into three pieces.
        buy = payload[0]["buy"];
        all = payload[0]["all"];
        sell = payload[0]["sell"];
    });
  }).end();
};

编辑：从代码中删除了会干扰测试的变量。

Answer 1

您需要在执行解析之前累积流式传输的数据，因为构成数据块的内容由 io 速率决定。

而是存储所有分块数据，然后对其进行解析

var options = {
  host: 'api.eve-central.com',
  port: 80,
  path: '/api/marketstat/json?typeid=18&typeid=19&typeid=20&typeid=21&typeid=22&typeid=34&typeid=35&typeid=36&typeid=37&typeid=38&typeid=39&typeid=40&typeid=41&typeid=42&typeid=43&typeid=44&typeid=45&typeid=49&typeid=50&typeid=51&typeid=52&typeid=164&typeid=165&typeid=166&typeid=178&typeid=179&typeid=180&typeid=181&typeid=182&typeid=183&typeid=184&typeid=185&typeid=186&typeid=187&typeid=188&typeid=189&typeid=190&typeid=191&typeid=192&typeid=193&typeid=194&typeid=195&typeid=196&typeid=197&typeid=198&typeid=199&typeid=200&typeid=201&typeid=202&typeid=203&typeid=204&typeid=205&typeid=206&typeid=207&typeid=208&typeid=209&typeid=210&typeid=211&typeid=212&typeid=213&typeid=215&typeid=216&typeid=217&typeid=218&typeid=219&typeid=220&typeid=221&typeid=222&typeid=223&typeid=224&typeid=225&typeid=226&typeid=227&typeid=228&typeid=229&typeid=230&typeid=231&typeid=232&typeid=233&typeid=234&typeid=235&typeid=236&typeid=237&typeid=238&typeid=239&typeid=240&typeid=241&typeid=242&typeid=243&typeid=244&typeid=245&typeid=246&typeid=247&typeid=248&typeid=249&typeid=250&typeid=251&typeid=252&typeid=253&typeid=254&usesystem=30000142',
  method: 'GET'
}

function requester(options) {
    http.request(options, function (res) {
        res.setEncoding('utf8');

        // Build response body in a string
        var resBody = '';

        // Listen for data and add
        res.on('data', function (chunk) {
            resBody += chunk
        });

        res.on('end', function () {   
            // Now that the response is done streaming, parse resBody           
            var payload = JSON.parse(resBody);

            //Separating the payload into three pieces.
            buy = payload[0]["buy"];
            all = payload[0]["all"];
            sell = payload[0]["sell"];

            itemStats.hiBuy = buy["max"];
            itemStats.loSel = sell["min"];
            itemStats.iskSpread = itemStats.loSel - itemStats.hiBuy; //Adjusted the spread calculation for station trading.
            itemStats.perSpread = itemStats.iskSpread / itemStats.loSel;
            itemStats.buyVol = buy["volume"];
            itemStats.selVol = sell["volume"];
            itemStats.allVol = all["volume"];
            itemStats.buyPerHR = itemStats.buyVol / 24;
            itemStats.selPerHR = itemStats.selVol / 24;

            console.log("Transferred Values" + JSON.stringify(itemStats));
        });
    });
};

Answer 2

你正在解析单个块，你需要在解析数据之前读取所有块：

let data = '';
res.on('data', function (chunk) {
  data += chunk;
});
res.on('end', function() {
  let payload = JSON.parse(data);
});