如何使用 nodejs 使用 Promise？

Question

这是我第一次使用 Promise，所以我使用 bluebird 库来完成我的任务，在下面的代码中，我有来自客户端的字符串输入，我必须在文件系统中搜索。所以我必须遍历 dir 并检查该字符串是否与任何文件匹配将该行推送到results 所以一旦forEach 完成我想将results 发送给客户端。我如何使用 Promise 完成该任务？以下代码错误

Error: Unhandled rejection TypeError: expecting an array or an iterable object but got [object Null]

app.js

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

promises.js

function readFile(str,logFiles,callback){
   searchStr = str;
    return Promise.map(logFiles, function(logfile) {

        return new Promise(function(resolve, reject) {
             fs.readFile('logs/dit/' + logfile.filename, 'utf8', function(err, data) {
                               if (err) {
                                   callback(null,err);
                                   return; // **** Make sure not to run the code below!
                               }
                               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);
                                   }
                               });
                            });
        })
    });
//}
}
Promise
    .all(readFile())
    .then(function() {
        console.log('done');
        callback(results);
    });

Answer 1

更新

我发布了一些一般性建议，然后发布了一些答案以及非常复杂的代码示例，因此我想补充一点，使用正确的模块您的 readFiles() 函数可以非常紧凑：

function readFiles(str, files) {
  return Promise.all(files.map(
    file => rsp(fs.readFile(`logs/dit/${file}`, 'utf-8'))
       .split('\n').filter(l => l.includes(str))))
       .then(a => [].concat(...a));
}

正确的模块在这里是mz 和rsp（免责声明，我是rsp 模块的作者，所以我在这里显然有偏见）。 mz 模块允许您使用承诺版本的fs 方法，rsp 模块允许您在未来调用承诺结果的方法。

您需要将这些模块用作：

let fs = require('mz/fs');
let rsp = require('rsp');

上面的readFiles()函数可以用作：

readFiles('line 3', ['file1.txt', 'file2.txt', 'file3.txt'])
  .then(lines => console.log(lines.join('\n')))
  .catch(err => console.log('Error:', err));

它确实有效 - 我用logs/dit 目录中的一堆文件对其进行了测试。

完整示例

let fs = require('mz/fs');
let rsp = require('rsp');

function readFiles(str, files) {
  return Promise.all(files.map(
    file => rsp(fs.readFile(`logs/dit/${file}`, 'utf-8'))
       .split('\n').filter(l => l.includes(str))))
       .then(a => [].concat(...a));
}

readFiles('line 3', ['file1.txt', 'file2.txt', 'file3.txt'])
  .then(lines => console.log(lines.join('\n')))
  .catch(err => console.log('Error:', err));

总结

如您所见，不需要循环、不需要显式回调、不需要new Promise() 构造等。

原答案

如果您想在 Node 中使用带有文件系统访问权限的 Promises，请使用这些模块中的一个：

• https://www.npmjs.com/package/mz
• https://www.npmjs.com/package/fs-promise
• https://www.npmjs.com/package/fs-promised

或者使用 Bluebird 的 promisyfyAll：

• http://bluebirdjs.com/docs/api/promise.promisifyall.html

在 Node 中承诺 fs 模块。

例如使用mz，您将能够执行以下操作：

return Promise.map(logFiles, file => fs.readFile('logs/dit/' + file, 'utf-8'));

在一行代码中返回所有这些文件内容的数组的承诺。

您可以进一步链接：

return Promise.map(...).then(files => ...);

获取所有文件并使用它们，或者您可以使用类似的东西：

return Promise.map(logFiles, file => fs.readFile('logs/dit/' + file, 'utf-8').then(content => {...});

并承诺转换后的文件内容数组。

Answer 2

你忘了调用“resolve”，也忘了传参数，而且好像把“results”当做全局变量，很糟糕。

这是我对代码的更正：

function readFile(str,logFiles){
   searchStr = str;
    return Promise.map(logFiles, function(logfile) {

        return new Promise(function(resolve, reject) {
             fs.readFile('logs/dit/' + logfile.filename, 'utf8', function(err, data) {
                               if (err) {
                                   reject(err);
                                   return; // **** Make sure not to run the code below!
                               }
                               var results = [];
                               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);
                                   }
                               });
                               resolve(results);
                            });
        })
    });
}

Promise
    .all(readFile(searchTxt, logFiles))
    .then(function(results) {
        console.log('done');
        callback(results);
    });

Answer 3

错误 TypeError: expecting an array or an iterable object but got [object Null] 来自于没有将 logFiles 传递给您的 readFile() 调用，Promise.map 会抱怨它的第一个参数是 undefined。

此外，您不能使用Promise.all(readFile(…))，因为Promise.all 确实接受了一组承诺而不是承诺（readFile 函数中的Promise.map 已经返回）。

但事实上，即使您修复了这些问题，您的代码仍然无法正常工作，因为您永远不会解决您创建的承诺。您实际上需要调用reject 和resolve，而不是一些callback：

function readFile(filename) {
    return new Promise(function(resolve, reject) {
        fs.readFile(filename, 'utf8', function(err, data) {
            if (err) reject(err); // <--
            else resolve(data); // <--
        });
    });
}

现在您可以在循环中使用该函数：

function findFileLines(searchStr, logFiles) {
    return Promise.map(logFiles, function(logfile) {
        return readFile('logs/dit/' + logfile.filename).then(function(data) {
            var lines = data.split('\n'); // get the lines
            var result = lines.filter(function(line) {
                return line.indexOf(searchStr) != -1
            });
            return result;
        });
    })
}

findFileLines("…", [{filename:"…"}, …]).then(function(results) {
    console.log('done');
    callback(results);
});