Nodejs fs.createReadStream 事件错误

Question

我正在尝试非常快速地从文件中读取数据（来自 ADC 的数据）。转换在打开文件时开始，并在关闭时完成。我需要等待再次打开文件，等待当前转换完成。

我的问题是，当我很快打开文件时，nodejs 不会捕捉到预期的事件。任何线索如何解决这个问题？

 node.on('input', function(){

            readStream = fs.createReadStream(path.location,{encoding: 'utf8'});

            if (readyFlag == 1) {
                readStream.on('data',(data) => {
                    data = {payload: data/1000};
                    node.send(data);
                    console.log(`data: ${data}`);

                })
            }

            readStream.on('open', () => {
                console.log("file opened");
                readyFlag = 0;
            })   



            readStream.on('close', () => {
                console.log("file closed");
                readyFlag = 1;
            })

            readStream.on('error', (err) => {
                console.log(err);
            })




    })

我最终发现文件一直在打开。

Answer 1

所以在我看来，这里的问题是 readStream 的上下文 - 它不是 input 回调的本地内容，这意味着每条消息都会覆盖对前一个流的引用。

当你增加消息的频率时这开始失败的事实对我来说似乎是合乎逻辑的，因为流还没有机会完成，所以readyFlag 永远不会重置。

这个问题的修复应该是一个单行，使流成为本地变量

const readStream = ...

Answer 2

我想我已经解决了。 readyFlag 对于输入范围必须是全局的，否则它将不起作用。我在 if 语句中移动了“open”事件，该语句正在检查 readyFlag。这似乎解决了问题。现在系统不会挂起，文件只是在完成读取并关闭之前打开的部分后才被打开。

代码如下：

    var readyFlag = 1;
    node.on('input', function(msg){

            const readStream = fs.createReadStream(path.location,{encoding: 'utf8'});


            if (readyFlag == 1) {
                readStream.on('data',(data) => {
                    data = {payload: data/1000};
                    node.send(data);
                    console.log('data read');
                    readyFlag = 0;

                })

                readStream.on('open', () => {
                    console.log("file opened");

                })   
            }

            readStream.on('close', () => {
                console.log("file closed");
                readyFlag = 1;
            })

            readStream.on('error', (err) => {
                console.log(err);
            })
    })