使用节点从"命名管道"/ fifo读取.js

Question

>我有这个：

const p = path.resolve(projectRoot + '/NAMEDPIPEIN');
const fd = fs.openSync(p, 'r+');
fs.createReadStream(null, {fd}).on('data', function (d) {
if (String(d).trim() === '[stdin end]') {
return process.nextTick(cb);
}
process.argv.push(String(d).trim());
});

我启动 Node.js 进程，然后写入命名管道。由于某种原因，似乎没有数据到达 on 数据回调。

我像这样写给命名管道：

mkfifo NAMEDPIPEIN
echo "foo bar baz" > NAMEDPIPEIN

Answer 1

另一个解决方案，从@richardpringle应该可以工作，但功能有限。

如果您尝试以这种方式打开多个 FIFO(超过线程池中的线程数(，则您打开的第一个 FIFO 将不再是流式传输数据。这是因为fs模块不是为在非阻塞模式下使用文件描述符而设计的。请改用net模块！

从 https://stackoverflow.com/a/52622722/1843507 从FIFO实现流式传输的当前方法是使用套接字：

const fs = require('fs');
const net = require('net');
fs.open('path/to/fifo/', fs.constants.O_RDONLY | fs.constants.O_NONBLOCK, (err, fd) => {
// Handle err
const pipe = new net.Socket({ fd });
// Now `pipe` is a stream that can be used for reading from the FIFO.
pipe.on('data', (data) => {
// process data ...
});
});

总之，如果您正在运行脚本并且不介意捆绑线程池中的一个线程，则可以使用 @richardpringle 的解决方案。否则，您绝对应该使用此解决方案。

Answer 2

这应该可以做到：

const fs = require('fs');
const path = require('path');
const fifoPath = path.resolve(projectRoot, '/NAMEDPIPEIN')
const fifo = fs.createReadStream(fifoPath);
fifo.on('data', data => {
// process data...
});

使用fifo.on('data', console.log)进行测试。