用 NodeJS 编写的简单 TCP 服务器中的 socket.emit？

Question

[正如你将看到的，我不太了解 TCP 服务器和客户端的基本概念，可能 socket.emit 甚至不可能，但我想知道最好的替代方案或类似的东西......]

Socket.io 有一个漂亮的东西可以发出事件并在另一端捕获它们，它位于它的首页（http://socket.io）。我可以做类似的事情，但使用 NodeJS 的常规“net”模块吗？如果不是那么相当于什么？

我尝试过：

server.js

var server = net.createServer(function(socket) {
    socket.on("connect",function() {
        socket.emit('test',{msg : 'did you get it ?'});
    });
}).listen(8000);

client.js

var client = net.createConnection(8000, localhost);
client.on('connect',function(){
    client.on('test',function(data) {
        console.log(data.toString());
    });
});

但正如你可以想象的，它不起作用。我怎样才能做到这一点？

提前致谢。

Answer 1

嗯，net 只是 TCP 的一个接口。要发送和接收消息，您需要在 TCP 之上设计和实现您自己的协议。 TCP是面向流的协议，而不是面向消息的协议。这意味着您必须发明一种让读者分隔消息的方法。分隔消息的最简单方法是在消息之间插入 \n 字符。将消息编码为字节流的最简单方法是使用 JSON.stringify。所以：

client.js

var Lazy = require('lazy'), net = require('net')

var client = net.createConnection(8000)

new Lazy(client).lines.forEach(function (msg)
{
    console.log(JSON.parse(msg))    
})

server.js

var net = require('net')

var server = net.createServer(function(socket) {
    socket.on("connect",function() {
    var str = JSON.stringify({foo : 'test', msg : 'did you get it ?'}) + "\n"
        socket.write(str)
    });
}).listen(8000);

可以从这里开始，详细阐述。例如，您可以在接收方使用 EventEmitter 库类，并在收到不同消息时发出不同的事件。

NPM 上提供了“惰性”模块，用于将接收字节流拆分为单独的行。拆分可以手动完成，但需要 20 多行代码。请参阅“脏”NPM 模块的来源，了解拆分的示例实现 - 它很麻烦，因此在这种情况下具有外部依赖项是有根据的。

Answer 2

Socket.io 使用 socket.io-parser 的编码/解码方法在服务器和客户端之间传输消息，这意味着它实际上在幕后使用流。

Answer 3

只是想提一下，在 Nodejs 版本 5.0.0 中，已经有一个客户端，以防您想跳过使用 lazy：

var client = net.connect({port: 8000},
    function() { //'connect' listener
       console.log('connected to server!');
});

client.on('data', function(data) {
  console.log(data.toString());
  client.end();
});

client.on('end', function() {
  console.log('disconnected from server');
});