javascript - 客户端和服务器在同一个nodejs进程中

Question

尝试在同一 Node 进程中使用客户端和服务器创建回显服务器测试。如果我将其拆分为 2 个文件(服务器和客户端)，此代码可以工作，但如果合并为 1 个文件，则该代码不起作用。我怎样才能让它在 1 个文件中工作？

var HOST, createServer, g, net;

net = require("net");

HOST = "127.0.0.1";

createServer = function(port) {
  net.createServer(function(sock) {
    sock.write("welcome!  on port " + port + "\r\n");
    console.log("CONNECTED: " + sock.remoteAddress + ":" + sock.remotePort);
    while (true) {
      sock.write("hello\r\n");
    }
  }).listen(port, HOST);
  console.log("server listening on " + port);
};

createServer(7001);

g = net.createConnection(7001, HOST);

g.on("data", function(data) {
  console.log("got " + data);
});

在 CoffeeScript 中也是如此:

net = require "net"
HOST = "127.0.0.1"

createServer = (port) ->
  net.createServer((sock) ->
    sock.write("welcome!  on port #{port}\r\n")
    console.log("CONNECTED: #{sock.remoteAddress}:#{sock.remotePort}")
    while true # this is the work queue, what ports to send to...                
      sock.write "hello\r\n"
    return
  ).listen port, HOST
  console.log "server listening on #{port}"
  return

createServer(7001)

# XXX why does g.on "data" never fire?                                           
# this works fine if I move it into                                              
# it's own file, how to co-exist                                                 
# this client with server above                                                  
# in same file?                                                                  
g = net.createConnection(7001, HOST)
g.on "data", (data) ->
  console.log "got #{data}"
  return

Answer 1

while (true) {
  sock.write("hello\r\n");
}

这是你的问题。您无限期地写入流；如果它永远不会结束，它就不会触发你的“数据”事件。为了更清楚地说明，请尝试以下操作(代替上面的代码):

while (true) {
  console.log("hello!");
  sock.write("hello\r\n");
}

或者:

var i = 0;
while (i < 5) {
  i++;
  sock.write("hello\r\n");
}

编辑:要无限期地继续回显，也许可以尝试这样的事情:

net.createServer(function(sock) { 
  sock.write("welcome!  on port " + port + "\r\n");
  console.log("CONNECTED: " + sock.remoteAddress + ":" + sock.remotePort);
  setInterval(function() {
    sock.write("hello\r\n");
  }, 2000);
}).listen(port, HOST);