Nodejs streaming

Question

Chcę zrealizować proste połączenie klient-serwer za pomocą Nodejs. Ale napotkałem następujący problem.

Rozważmy kod

server.js:

var net = require('net'), 
    sys = require('sys'); 

    net.createServer(onConnection).listen(8124); 

    function onConnection(socket) { 
    socket.setNoDelay(true); 

    socket.addListener("connect", function() { 
     sys.puts('client connected: ' + this.remoteAddress); 
    }); 

    socket.addListener("data", function (data) { 
     sys.puts("message: \n" + data + "\n - end of msg."); 
    }); 

    socket.addListener("end", function() { 
     sys.puts('end of connection'); 
     this.end(); 
    }); 
    } 

    sys.puts('Server running at 127.0.0.1:8124'); 

client.js:

var net = require('net'), 
sys = require('sys'); 

var stream = net.createConnection(8124); 
stream.addListener("connect", function(){ 
sys.puts('connected'); 

stream.write('a'); 
    stream.flush(); 
stream.write('b'); 
    stream.flush(); 

}); 

stream.addListener("data", function(data){ 
sys.puts("Message: \n" + data + "\n - end of msg."); 
}); 

Kiedy biegnę client.js I czasami tylko jeden komunikat 'ab' zamiast dwie wiadomości "a" i "b".

Czy istnieje "właściwa metoda", aby sobie z tym poradzić?

Answer 1

Protokół TCP to protokół . Pojedynczy write na jednym końcu rury może spowodować wiele "odczytów" na drugim końcu i na odwrót. Musisz jednoznacznie powiedzieć drugiej stronie, ile wysyłanych bajtów zawiera długość wiadomości; lub zapewniają łatwo rozpoznawalne ograniczniki wiadomości. W każdym razie musisz przeczytać w pętli.