4

我正在使用 node.js 并通过打开 /dev/tty 文件从串行端口读取输入，我发送命令并读取命令的结果，并且我想在读取并解析所有数据后关闭流. 我知道我已经完成了数据标记的读取数据。我发现一旦我关闭了流，我的程序就不会终止。

下面是我所看到的示例，但使用 /dev/random 缓慢生成数据（假设您的系统没有做太多）。我发现一旦设备在流关闭后生成数据，该过程将终止。

var util = require('util'),
    PassThrough = require('stream').PassThrough,
    fs = require('fs');

// If the system is not doing enough to fill the entropy pool
// /dev/random will not return much data.  Feed the entropy pool with :
//  ssh <host> 'cat /dev/urandom' > /dev/urandom
var readStream = fs.createReadStream('/dev/random');
var pt = new PassThrough();

pt.on('data', function (data) {
    console.log(data)
    console.log('closing');
    readStream.close();  //expect the process to terminate immediately
});

readStream.pipe(pt);

更新：1

我又回到了这个问题上，并且有另一个示例，这个示例只使用了一个 pty，并且很容易在节点 repl 中复制。在 2 个终端上登录并使用您未在以下调用中运行节点的终端的 pty 来调用 createReadStream。

var fs = require('fs');
var rs = fs.createReadStream('/dev/pts/1'); // a pty that is allocated in another terminal by my user
//wait just a second, don't copy and paste everything at once
process.exit(0);

此时节点只会挂起而不退出。这是10.28。

4

2 回答 2

1

而不是使用

readStream.close(),

尝试使用

readStream.pause().

但是，如果您使用的是最新版本的节点，请使用 isaacs 从流模块创建的对象包装 readstream，如下所示：

var Readable = require('stream').Readable;
var myReader = new Readable().wrap(readStream);

然后使用 myReader 代替 readStream 。

祝你好运！告诉我这是否有效。

于 2013-11-18T11:56:55.987 回答
0

您正在关闭/dev/random流，但您仍然有一个用于'data'传递事件的侦听器，这将使应用程序保持运行，直到传递关闭。

我猜有一些来自读取流的缓冲数据，在刷新之前，传递不会关闭。但这只是一个猜测。

要获得所需的行为，您可以像这样删除传递中的事件侦听器：

pt.on('data', function (data) {
  console.log(data)
  console.log('closing');

  pt.removeAllListeners('data');
  readStream.close();
});
于 2013-11-14T15:39:58.863 回答