如何使用来自 http 端点的 json 块流？

Question

我有一个将 json 对象流式传输到端点的服务器。这是一个简化的例子：

app.get('/getJsonObjects', function (req, res) {
    res.write(JSON.stringify(json1));
    res.write(JSON.stringify(json2));
    res.write(JSON.stringify(json3));
    res.write(JSON.stringify(json4));
    res.write(JSON.stringify(json5));
    res.end();
});

然后客户端使用浏览器请求，我正在尝试这样做：

var r = request(url);
r.on('data', function(data) {
    console.log(JSON.parse(data));
});

问题是尽管流式传输到有效字符串化 JSON 的端点块，我从请求中返回的块只是文本块，不一定与发送的 JSON 块的开始/结束对齐服务器。这意味着 JSON.parse(data) 有时会失败。

以与写入端点相同的方式流式传输这些 json 块的最佳方式是什么？

Answer 1

这是一个异步问题。您提供的服务器代码不能保证按该顺序发送数据。

您要么必须在客户端累积块并确定客户端上块的显示顺序，要么您必须在服务器端执行某种累加器方法，然后按顺序输出 JSON随着它们的处理。

编辑： 看来 res.write 可以采用“分块”编码类型。所以尝试将 header 字段设置为 chunked，然后在 res.write() 的编码参数中指定“chunked”。 https://nodejs.org/api/http.html#http_response_write_chunk_encoding_callback

如果这失败了，你可以使用 res.write 的回调参数做一个巨大的回调/承诺链来保证 res.write() 的顺序。