node.js - 无法向 TCP 客户端发送响应

Question

我有一个带有以下代码的 TCP 服务器:

// Start a TCP Server
require('net').createServer(function (socket) {

  // Handle incoming messages from clients.
  socket.on('data', function (data) {
    console.log("received:" + data);

    // Do something with the data
    //...

    // Send result to client
    socket.write('OK');          // Code added which make the server crash
  });
}).listen(10000);

每次客户端连接时，服务器都会从套接字中检索数据并进行处理。如果我不尝试向客户端发送响应，则运行良好。

如果我添加 'socket.write("ok");'代码行我收到以下错误(似乎套接字已经关闭？):

"memoryUsage":{"rss":22474752,"heapTotal":16571136,"heapUsed":7168552}},"os":{"loadavg":[1.25634765625,1.111328125,1.00341796875],"uptime":185009 },"trace":[{"column":11,"file":"net.js","function":"errnoException","line":884,"method":null,"native":false} ,{"column":19,"file":"net.js","function":"TCP.onread","line":539,"method":"onread","native":false}], “堆栈”:[“错误:读取 ECONNRESET”，“在 errnoException (net.js:884:11)”，“在 TCP.onread (net.js:539:19)”]，“级别”:“错误” "message":"uncaughtException: read ECONNRESET","timestamp":"2013-09-10T14:11:29.354Z"

知道哪里出了问题吗？

编辑

我使用以下 ruby​​ 代码来模拟客户端，我应该为我打开的每个套接字使用一个线程吗？

...
# Send test data to server
[1,2,3,4,5].each do |data|
  puts "sending #{data}"
  s = TCPSocket.open(host, port)
  s.puts data 
end

Answer 1

您的 ruby​​ 客户端在将消息发送到您的服务器后完成执行并退出。它不期望服务器有任何响应，因此它不会等待。您只需要像这样修改您的客户端:

  s = TCPSocket.open(host, port)
  s.puts data 
  puts s.read(2) //wait for response

读取是阻塞的，因此客户端不会发送下一条消息，直到它在循环中收到来自服务器的消息。要并行发送数据，您必须 a) 在 ruby​​ 中使用非阻塞 I/O(不知道如何)或 b) 将其包装在一个为每个客户端生成一个线程的包装器上。