tcp客户端服务器通信

Question

我正在尝试构建 TCP 服务器/客户端聊天 到目前为止我的代码是

server.js

var net=require("net");
var sockets=[];
var server=net.createServer(function(socket){
    console.log("new socket connected");
    sockets.push(socket);
    var sh="";
    socket.on("data",function(data){
        sh=sh+data;
    });
    socket.on("end",function(){
        sockets.forEach(function(x){
            if(x!==socket){
                x.write("Dakto poveda :"+ sh);
                sh="";
            }
        });
    })
    socket.on("close",function(){
        console.log("Connection closed")
    })
}).listen(8888)

和client.js

var net=require("net");
var client= new net.Socket();
client.connect(8888,function(){
    console.log("Conncted");
    client.write("Hello from client")
});
client.on("data",function(data){
    console.log("data "+data)
});
client.on("close",function(){
    console.log("Client closed");
    client.write("client closed")
})

我启动 server.js 然后我打开新的 cmds 并在其中启动 client.js。在服务器 cmd 中写入客户端已连接，在客户端 cmd 中写入“已连接”，但未写入“来自客户端的您好”+问题是，我如何在这些客户端/服务器之间进行通信？当我启动这些文件时，我无法再写入 cmd

Answer 1

目前，您的服务器代码会等待客户端断开连接，然后再将缓冲的数据显示到标准输出。如果要立即显示它，则需要使用某种框架协议，以便知道“消息”何时开始和结束。一种流行的方法是使用换行符分隔的 JSON 消息。例如：

server.js:

var net = require('net');
var sockets = [];
function broadcast(from, msg) {
  msg = JSON.stringify('Dakto poveda: ' + msg) + '\n';
  sockets.forEach(function(x) {
    if (x !== from)
      x.write(msg);
  });
}
var server = net.createServer(function(socket){
  sockets.push(socket);

  var buffer = '';
  socket.on('data',function(data) {
    buffer += data;
    var idx;
    while ((idx = buffer.indexOf('\n')) > -1) {
      broadcast(socket, JSON.parse(buffer.slice(0, idx)));
      buffer = buffer.slice(idx + 1);
    }
  });

  socket.on('close',function() {
    // Remove dead socket from list
    sockets.splice(sockets.indexOf(socket), 1);

    console.log('Connection closed')
  });
}).listen(8888);

client.js:

var net = require('net');
var client = new net.Socket();
function send(msg) {
  client.write(JSON.stringify(msg) + '\n');
}
client.connect(8888, function() {
  console.log('Conncted');
  send('Hello from client');
});
var buffer = '';
client.on('data', function(data) {
  buffer += data;
  var idx;
  while ((idx = buffer.indexOf('\n')) > -1) {
    console.log('message received: ' + JSON.parse(buffer.slice(0, idx)));
    buffer = buffer.slice(idx + 1);
  }
});
client.on('close',function(){
  console.log('Client closed');
});

如果您想在消息中嵌入换行符等，JSON 转换会很有用，否则会弄乱您的消息框架。另一个好处是您可以发送 JavaScript 对象、数组等，而不仅仅是纯字符串。这将使您能够更轻松地传递不同类型的数据。