javascript - 在 Node.js 网络中使用 pipe()

Question

我无法理解 net 的几个 Node.js 示例中显示的 pipe 函数。模块。

var net = require('net');

var server = net.createServer(function (socket) {
  socket.write('Echo server\r\n');
  socket.pipe(socket);
});

谁能解释一下它是如何工作的以及为什么需要它？

Answer 1

pipe() 函数在可读流可用时读取数据并将其写入目标可写流。

文档中的示例是一个回显服务器，它是一个发送它接收到的东西的服务器。 socket 对象实现了可读和可写的流接口(interface)，因此它会将接收到的任何数据写回套接字。

这相当于使用事件监听器使用 pipe() 方法:

var net = require('net');
net.createServer(function (socket) {
  socket.write('Echo server\r\n');
  socket.on('data', function(chunk) {
    socket.write(chunk);
  });
  socket.on('end', socket.end);
});