NodeJS/ExpressJS senden Antwort von großen Datenmengen in 1 Stream

Question

Ich bin Prototyping eine App mit der nativen Mongo Rest API, wo Knoten etwa 400K von JSON zurückgibt. Ich benutze den folgenden er einen Antrag auf Mongo nativen api maket und das Ergebnis zurück:

http.request(options, function(req) 
    { 
    req.on('data', function(data) 
     { 
console.log(data,data.rows); 
     response.send(200, data); 
     } 
    ); 
    } 
) 
.on('error', function(error) 
    { 
console.log('error\t',error); 
    response.send(500, error); 
    } 
) 
.end(); 

Wenn ich http://localhost:8001/api/testdata über curl getroffen, die Antwort richtig ist (beide, was zu Knoten der Konsole aus den console.log ausgegeben wird und was empfangen werden durch Locken). Aber wenn ich es über Ajax in meiner App traf, ist der Stream ... unterbrochen, sogar data ausgegeben an Nodes Konsole (Terminal) ist ungerade: Es hat mehrere EOFs, und die Netzwerk> Antwort für den Aufruf in Chrome Dev Tools endet am ersten EOF.

Eine andere seltsame Sache: data wie folgt aussieht:

{ 
    "offset": 0, 
    "rows": [ … ] 
} 

aber in keinem der beiden Knoten noch clientseitige (Winkel-) kann ich Referenz data.rows (es gibt nicht definiert). typeof data gibt [object Object] zurück.

EDIT Die Anforderungs-Header für beide curl und eckig (wie durch Knoten gemeldet) sind:

req.headers: { 
    'x-action': '', 
    'x-ns': 'test.headends', 
    'content-type': 'text/plain;charset=utf-8', 
    connection: 'close', 
    'content-length': '419585' 
} 

EDIT geprüft I-Antwort-Header in beiden Winkel und kräuseln direkt (anstatt von Node), annnd es gibt eine Nichtübereinstimmung (die gleiche Ausgabe von sowohl curl und Winkel direkt anstelle von node):

access-control-allow-headers: "Origin, X-Requested-With, Content-Type, Accept" 
access-control-allow-methods: "OPTIONS,GET,POST,PUT,DELETE" 
access-control-allow-origin: "*" 
connection: "keep-alive" 
content-length: "65401" // <---------------- too small! 
content-type: "application/octet-stream" 
//    ^-- if i force "application/json" 
// with response.json() instead of response.send() in Node, 
// the client displays octets (and it takes 8s instead of 0s) 
date: "Mon, 15 Jul 2013 18:36:50 GMT" 
etag: ""-207110537"" 
x-powered-by: "Express" 

Answer 1

Knotens http.request() gibt Daten in chunks zum Streamen (wäre schön, wenn sie dies explizit angeben). Daher ist es notwendig, jeden Block in den Hauptteil der Antwort von Express zu schreiben, listen for the end of the http request (was nicht wirklich dokumentiert ist), und dann response.end() aufzurufen, um die Antwort tatsächlich zu beenden.

var req = http.request(options, function(res) 
    { 
    res.on('data', function(chunk) { response.write(chunk); }); 
    res.on('end', function() { response.end(); }); 
    } 
); 
req.on('error', function(error) { … }); 
req.end(); 

Wo response ist Express Antwort die die ursprünglichen Client-Anforderung (curl oder Ajax-Aufruf des Winkels).