来自文件读取流的Nodejs不定式流

Question

我在尝试完成相当平庸的任务时遇到了麻烦。我需要从输入 txt 文件创建 nodejs 可读流。我需要对此流执行一些转换（为每一行创建 JSON 对象）。

问题是我希望这个流是不定式的：在读取最后一行之后，流应该从头开始。我的解决方案有效，但收到警告消息：

(node) 警告：检测到可能的 EventEmitter 内存泄漏。添加了 11 个排水监听器。使用emitter.setMaxListeners() 增加限制。

我希望找到简单的解决方案，而不是直接读取和缓冲文件。

//Transform stream object
var TransformStream = function () {
    Transform.call(this, {objectMode: true});
};
util.inherits(TransformStream, Transform);

TransformStream.prototype._transform = onTransform;
TransformStream.prototype._flush = onEnd;

var ts = new TransformStream();

var infinStream = function () {
    var r = fs.createReadStream(filePath);
    r.pipe(split(), {end: false})
        .pipe(ts, {end: false});
    r.once('end', function () {
        //console.log('\n\n\n\nRead file stream finished. Lines counted:\n\n\n\n' + detectionCounter);
        r.removeAllListeners();
        r.destroy();
        infinStream();
    });
    return r;
};
infinStream();

return ts;

Answer 1

来自cmets：

我需要每天 24 小时运行的服务器，并且将模拟设备 一直输出。

为此，递归函数是个好主意。你做的方法没问题。当您不需要对数据进行不同的转换任务时，实际上不需要流。简单事件可以完全按照您的意愿进行，并且更容易理解。

您的代码中的错误是您放置监听器的地方。侦听器r.once 在您的递归函数中。您在函数内部定义 r，因此每个函数调用都会创建一个新的 r。因为 r.once 不能像您期望的那样工作。

你可以做什么：

1. 创建一个发出事件的递归函数
2. 使用您在户外活动的数据

这只是一个简单的概念，使用简单的事件，它会在整个时间内触发文件中的数据：

// Your recursive function
var simulateDeviceEvents = function(){
  fs.readFile('device.txt', function (err, data) {
    if (err) throw err;
    // Just emit the event here
    Emitter.emit('deviceEvent', data);
  });
  //If this happens to fast you could also call it with
  //a timeout.
  simulateDeviceEvents();
};

// Start the function
simulateDeviceEvents();
//IMPORTANT: The listener must be defined outside your function!
Emitter.on('deviceEvent', function(data){
   // Do something with your data here
});