Node.js中readline读取行存入数组为空问题求助

你碰到的这个问题其实是Node.js异步编程里的典型陷阱——readline的行读取操作是异步的，你现在的代码逻辑里，绑定完line事件就立刻打印myArray，这时候文件还没开始读取（或者只读取了极少部分，但主线程已经走到打印步骤了），所以数组肯定是空的。

为什么会这样？ #

Node.js的I/O操作（包括文件读取）都是非阻塞的：当你创建lineReader并绑定事件后，Node.js不会等着文件读完再执行后续代码，而是直接跳到console.log(myArray)这一行执行，而文件行的读取和myArray.push()的操作，要等系统把文件数据加载到内存后才会触发line事件回调。

解决方案：等待异步操作完成后再处理数组 #

这里有两种常用的处理方式，你可以根据自己的代码风格选择：

方式一：监听close事件，所有行读取完成后再操作

当readline读完所有行后，会触发close事件，我们可以把打印数组、存入数据库的逻辑放在这个事件的回调里：

var chokidar = require('chokidar');
var readline = require('readline');
var fs = require('fs');

var watcher = chokidar.watch("MyFolder", {ignored: /^\./, persistent: true});
watcher
.on('add', function(path) {
 var myArray = [];
 console.log('File', path, 'has been added');
 var lineReader = readline.createInterface({
 input: fs.createReadStream(path)
 });
 
 lineReader.on('line', function (l) {
 // l本身就是字符串，不需要额外调用toString()
 myArray.push({
 "date" : l.substring(25,35),
 "time" : l.substring(35,46)
 });
 });
 
 // 所有行读取完成后触发close事件
 lineReader.on('close', function() {
 console.log(myArray); // 现在能看到完整的数组内容了
 // 在这里执行存入数据库的操作
 });
})
.on('change', function(path) {console.log('File', path, 'has been changed');})
.on('unlink', function(path) {console.log('File', path, 'has been removed');})
.on('error', function(error) {console.log('Error happened', error);});

方式二：用Promise封装读取逻辑，结合async/await让代码更清晰

如果你的Node.js版本支持ES6+的async/await，可以把文件读取逻辑封装成Promise，这样代码的同步可读性更强：

var chokidar = require('chokidar');
var readline = require('readline');
var fs = require('fs');

// 封装读取文件行并转化为对象数组的函数
function parseLogFile(path) {
 return new Promise((resolve, reject) => {
 const resultArray = [];
 const lineReader = readline.createInterface({
 input: fs.createReadStream(path)
 });
 
 lineReader.on('line', (line) => {
 resultArray.push({
 "date" : line.substring(25,35),
 "time" : line.substring(35,46)
 });
 });
 
 lineReader.on('close', () => {
 resolve(resultArray);
 });
 
 lineReader.on('error', (err) => {
 reject(err);
 });
 });
}

var watcher = chokidar.watch("MyFolder", {ignored: /^\./, persistent: true});
watcher
.on('add', async function(path) {
 console.log('File', path, 'has been added');
 try {
 const logData = await parseLogFile(path);
 console.log(logData);
 // 在这里执行存入数据库的操作
 } catch (err) {
 console.error('处理日志文件出错:', err);
 }
})
.on('change', function(path) {console.log('File', path, 'has been changed');})
.on('unlink', function(path) {console.log('File', path, 'has been removed');})
.on('error', function(error) {console.log('Error happened', error);});

额外的优化建议 #

• 把模块引用（require）放在文件顶部，不要在事件回调里重复引用，提升代码性能和整洁度。
• 去掉多余的l.toString()，因为line事件的回调参数本身就是字符串类型。
• 如果日志文件非常大，不建议把所有数据都存在数组里再批量存入数据库——可以在line事件回调里直接处理单行数据并存库，避免内存占用过高。

内容的提问来源于stack exchange，提问作者Jonathan