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は、「chunked」というエンコードタイプを使用できるようです。ですから、ヘッダーフィールドをチャンクに設定して、res.write（）のエンコーディングパラメータに "chunked"を指定してみてください。これが失敗した場合 https://nodejs.org/api/http.html#http_response_write_chunk_encoding_callback

、あなただけのres.writeの順序を保証するためにres.writeのコールバックパラメータを使用して巨大なコールバック/約束のチェーンを作ることができます（）。