与 fs 和 bluebird 的承诺

Posted

技术标签:

【中文标题】与 fs 和 bluebird 的承诺【英文标题】:Promises with fs and bluebird 【发布时间】:2013-10-26 02:08:12 【问题描述】:

我目前正在学习如何在 nodejs 中使用 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

现在链接两个承诺:

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)
)

正如我在上面所写的,它返回所需的结果,但我很确定有一种更优雅的方法。

【问题讨论】:

【参考方案1】:

使用generic promisification 和.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 应该是您使用集合时的基本方法 - 它非常强大,因为它适用于任何事情,从对一系列承诺的承诺映射到进一步的承诺,再到中间的任何直接值组合。

【讨论】:

很好,也为以后的读者指出使用Async函数:readdirAsyncreadFileAsync

以上是关于与 fs 和 bluebird 的承诺的主要内容,如果未能解决你的问题,请参考以下文章

如何使用 Bluebird 承诺 NodeJS Express

像在 Q 中定义空的 Bluebird 承诺

Redux Thunk, Sequelize (Bluebird) - 向动作创建者“链”返回承诺

bluebird - fs.readdir().then - 无法读取未定义的属性

NPM CI 和 Bluebird 承诺警告

Express.js 和 Bluebird - 处理承诺链