使用fs和bluebird的Promises

Question

我目前正在学习如何在Node.js中使用Promise。

因此，我的第一个挑战是列出目录中的文件，然后使用异步函数获取每个文件的内容。我想出了以下解决方案，但我强烈感觉这不是最优雅的方式，特别是第一部分，即我将异步方法“转换”为Promise的部分。

// purpose is to get the contents of all files in a directory
// using the asynchronous methods fs.readdir() and fs.readFile()
// and chaining them via Promises using the bluebird promise library [1]
// [1] https://github.com/petkaantonov/bluebird 

var Promise = require("bluebird");
var fs = require("fs");
var directory = "templates"

// turn fs.readdir() into a Promise
var getFiles = function(name) {
    var promise = Promise.pending();

    fs.readdir(directory, function(err, list) {
        promise.fulfill(list)
    })

    return promise.promise;
}

// turn fs.readFile() into a Promise
var getContents = function(filename) {
    var promise = Promise.pending();

    fs.readFile(directory + "/" + filename, "utf8", function(err, content) {
        promise.fulfill(content)
    })

    return promise.promise
}

现在将两个Promise链接起来：

getFiles()    // returns Promise for directory listing 
.then(function(list) {
    console.log("We got " + list)
    console.log("Now reading those files\n")

    // took me a while until i figured this out:
    var listOfPromises = list.map(getContents)
    return Promise.all(listOfPromises)

})
.then(function(content) {
    console.log("so this is what we got: ", content)
})

就像我之前写的那样，它可以返回期望的结果，但我相信一定有更加优雅的方法。

- Henrik

Answer 1

代码可以通过使用通用Promise化和.map方法来缩短:

var Promise = require("bluebird");
var fs = Promise.promisifyAll(require("fs")); //This is most convenient way if it works for you
var directory = "templates";

var getFiles = function () {
    return fs.readdirAsync(directory);
};
var getContent = function (filename) {
    return fs.readFileAsync(directory + "/" + filename, "utf8");
};

getFiles().map(function (filename) {
    return getContent(filename);
}).then(function (content) {
    console.log("so this is what we got: ", content)
});

事实上，由于这些函数已经没有发挥作用了，你甚至可以将其进一步简化：

var Promise = require("bluebird");
var fs = Promise.promisifyAll(require("fs")); //This is most convenient way if it works for you
var directory = "templates";

fs.readdirAsync(directory).map(function (filename) {
    return fs.readFileAsync(directory + "/" + filename, "utf8");
}).then(function (content) {
    console.log("so this is what we got: ", content)
});

.map应该是处理集合时的必备方法 - 它非常强大，因为它可以处理任何东西，从一个映射到进一步的承诺数组的承诺，到在其中混合了直接值的任何组合。

- Esailija

---

很好，还要指出给未来的读者使用Async函数：readdirAsync，readFileAsync。 - Wtower