为什么我的Node.js服务器回显我从nc发送给它的所有内容？

Question

我是Node.js的新手，我正在尝试通过构建一个侦听Unix域套接字的服务器来学习。我正在使用“ nc”作为客户端来测试服务器。 'nc -U /var/run/ipc.sock'一切进展顺利，除了我在nc中键入的任何内容都得到了回显。

像这样（大写字母是服务器的响应。混合大小写键入到nc）：

    $ nc -U /var/run/ipc.sock
    READY
    Hello.
    Hello.
    OK
    Echo.
    Echo.
    OK

我不知道输入的所有内容是服务器代码中缺少的设置还是nc的设置。我浏览过nodejs.org上的net.createServer页面和FreeBSD服务器上的nc手册页面。没运气。

这是我服务器的代码：

'use strict';
const fs = require('fs');
const net = require('net');

const socket = '/var/run/ipc.sock';

// ISO date-time stamp and a separator for logging.
function stamp(msg) {
  var d = new Date();
  return d.toISOString() + ' ' + msg;
}

// Create a Unix-domain IPC server to receive and execute commands.
const server = net.createServer((c) => {
  console.log(stamp('Client connect.'));
  c.write('READY\n');
  c.pipe(c);

  c.on('data', (d) => {
    if (d.slice(-1) == '\n') d = d.slice(0, -1);  // like Perl chomp()
    console.log(stamp('Data received: ' + d.toString()));
    c.write('OK\n');
  });

  c.on('end', () => {
    console.log(stamp('Client disconnect.'));
  });
});

// Start listening on a socket restricted to user:group.
server.listen(socket, () => {
  fs.chmod(socket, 0o660, (e) => {
    if (e) throw e;
  });
  console.log(stamp('Server listening.'));
});

// Error handler (specifically for stale socket due to unclean shutdown.)
server.on('error', (e) => {
  if (e.code == 'EADDRINUSE')
    console.error('Stale socket detected. Remove ' + e.address + ' and try again.'
);
  else throw e;
});

// Catch SIGINT and SIGTERM in order to exit cleanly.
function sigHandler(s) {
  if (s == 'SIGINT' || s == 'SIGTERM') {
    console.log(stamp('Caught signal: ' + s + '.'));
    process.exit(0);
  }
}
process.on('SIGINT', sigHandler);
process.on('SIGTERM', sigHandler);

// Clean up socket on exit.
process.on('exit', (c) => {
  console.log(stamp('Shutdown.'));
  fs.unlink(socket, (e) => {
    console.error(stamp('Unable to remove socket ' + socket));
  });
});

任何帮助将不胜感激。我正在使用FreeBSD 12.1，这很重要。

Answer 1

代码行：

c.pipe(c)

告诉流c将它收到的所有内容立即发送回同一流（回送它发送的所有内容）。删除该行，它不会回显所有内容。