为什么我的 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 将它收到的所有内容发送回同一流（回显它发送的所有内容）。删除该行，它不会回显所有内容。

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

Why does my Node.js server echo back everything I send to it from nc?

netcat

unix-socket

node.js