Come mantenere Node.js da messaggi di socket dividere in porzioni più piccole

Question

ho un programma di chat che spinge i dati JSON da Apache/PHP per Node.js, tramite un socket TCP:

// Node.js (Javascript) 
phpListener = net.createServer(function(stream) 
{ 
    stream.setEncoding("utf8"); 
    stream.on("data", function(txt) 
    { 
     var json = JSON.parse(txt); 

     // do stuff with json 
    } 
} 
phpListener.listen("8887", 'localhost'); 

// Apache (PHP) 
$sock = stream_socket_client("tcp://localhost:8887"); 
$written = fwrite($sock, $json_string); 
fclose($sock); 

Il problema è, se la stringa JSON è abbastanza grande (oltre a circa 8k), il messaggio di output viene diviso in più blocchi e il parser JSON ha esito negativo. PHP restituisce il valore $ scritto come la lunghezza corretta della stringa, ma il gestore di eventi data genera due o più volte.

Devo associare la funzione a un evento diverso o esiste un modo per memorizzare il testo in cache tra gli eventi, in modo tale da non soccombere a condizioni di competizione in condizioni di carico intenso? O qualche altra soluzione a cui non avessi pensato?

Grazie!

Answer 1

Si dovrebbe provare a utilizzare un buffer per memorizzare i dati in quanto Node.js tende a suddividere i dati per migliorare le prestazioni.

http://nodejs.org/api.html#buffers-2

si può tamponare tutta la vostra richiesta, e quindi chiamare la funzione con i dati memorizzati in esso.

Answer 2

I socket TCP non gestiscono il buffering per l'utente. Come potrebbe? Non sa quale protocollo di livello applicazione stai usando e quindi non ha idea di cosa sia un "messaggio". Spetta a te progettare e implementare un altro protocollo su di esso e gestire qualsiasi buffering necessario.

Tuttavia, Node.js ha un protocollo di livello applicazione incorporato su TCP che gestisce automaticamente il buffering per voi: il modulo http. Se si usa il modulo http invece del modulo tcp per questo, non è necessario preoccuparsi della frammentazione e del buffering dei pacchetti.