已经使用异步调用了回调？

Question

一旦fs.readFile 循环遍历所有文件并获取匹配数据并将其推送到结果中，我想调用callback(results) 以便向客户端发送响应。我收到以下代码Error: Callback is already called 的错误我如何使用async 方法解决此问题。

app.js

searchFileService.readFile(searchTxt, logFiles, function(lines, err) {
    console.log('Logs', lines);
    if (err)
        return res.send();
    res.json(lines);
})

readFile.js

var searchStr;
var results = [];

function readFile(str,logFiles,callback){
   searchStr = str;
    async.map(logFiles, function(logfile, callback) {
           fs.readFile('logs/dit/' + logfile.filename, 'utf8', function(err, data) {
               if (err) {
                   callback(null,err);
               }
               var lines = data.split('\n'); // get the lines
               lines.forEach(function(line) { // for each line in lines
                   if (line.indexOf(searchStr) != -1) { // if the line contain the searchSt
                       results.push(line);
                       callback(results,null);
                   }
               });
            });
    }), function(error, result) {
         results.map(result,function (result){
             console.log(result);
         });
    };
}

Answer 1

注意：此答案是trincot's answer 的扩展。因此，如果这回答了您的问题，请将其标记为答案！

您说：一旦 fs.readFile 循环遍历所有文件并获取匹配的数据并将其推送到结果中，老实说，我认为 .map 不适合此功能.这是为了将数组中的每个元素转换为另一个不是你正在做的事情。

更好的方法是.eachSeries 一次读取一个文件。

最好将您的第二个 callback 重命名为其他名称，例如done 不要让自己（和其他人）感到困惑。调用done() 是为了告诉我们对文件的操作已经完成，就像我们“完成”读取文件一样。

最后，请注意您的拼写错误。第一个可能会阻止您进入最后一部分。

var results = [];
var searchStr;

function readFile(str, logFiles, callback) {
    searchStr = str;
    // loop through each file
    async.eachSeries(logFiles, function (logfile, done) {
        // read file
        fs.readFile('logs/dit/' + logfile.filename, 'utf8', function (err, data) {
            if (err) {
                return done(err);
            }
            var lines = data.split('\n'); // get the lines
            lines.forEach(function(line) { // for each line in lines
                if (line.indexOf(searchStr) != -1) { // if the line contain the searchSt
                    results.push(line);  
                }
            });
            // when you are done reading the file
            done();
        });

    // wrong: }), function (err) {
    }, function (err) {
        if (err) {
            console.log('error', err);
        }
        console.log('all done: ', results);

        // wrong: results.map(result, function (result){
        results.map(function (result){
            console.log(result);
        });

        // send back results
        callback(results);
    });
}