使用q promise和map来获取文件内容

Using q promises with map to get file contents

本文关键字：获取 文件 map promise 使用      更新时间：2023-09-26

我正在尝试使用q promise库来获取目录中.json文件的名称并返回这些文件的内容。我可以获得文件名，但在将arr.map与promise结合使用以读取文件的内容时遇到了问题。我希望getContents()返回一个包含指定文件名内容的映射数组。

function readDir() {
    var deferred = q.defer();
    fs.readdir('users', function(err, data) {
        if (err) console.log(err);
        deferred.resolve(data);
    })
    return deferred.promise;
}
function getContents(filenames) {
    return filenames.map(function(filename) {
        fs.readFile('users/' + filename, 'utf8', function(err, result) {
            return result;
        });
    });
}
readDir()
    .then(getContents)
    .then(function(fileContents) {
        // currently returns undefined
        console.log(fileContents);
    });

如何在promise中正确地包装getConents()，使数组的内容不等于undefined？

首先，您需要获得一个promise数组，即return result在异步回调中是无用的。为每一个readFile呼叫做出承诺：

filenames.map(function(filename) {
    return Q.nfcall(fs.readFile, 'users/' + filename, 'utf8');
//  ^^^^^^ here's where the return is needed
})

Q.nfcall函数基本上执行与您在readDir函数中编写的内容相同的内容。

现在您已经有了一个promise数组，您可以使用Q.all:轻松地将其转换为一个数组的promise（等待所有的promise）

function getContents(filenames) {
    return Q.all(filenames.map(function(filename) {
        return Q.nfcall(fs.readFile, 'users/' + filename, 'utf8');
    }));
}

首先，您可以使用promise定义fs.readFile的适当异步版本：

function readFileAsync(/* ...args */) {
    return Q.nfapply(fs.readFile, arguments);
}

之后，你有两个选择。这将并行读取文件：

function getContents(filenames) {
    return Q.all(
        filenames.map(function(filename) {
            return readFileAsync('users/' + filename, 'utf8');
        })
    );
}

这将逐一阅读：

function qMap(array, selector) {
    var i = 0;
    var result = [];

    function store(x) {
        result.push(x);
        return next();
    }
    function next() {
        if (i < array.length) {
            var index = i++;
            var item = array[index];
            return Q.fcall(selector, item, index).then(store);
        } else {
            return result;
        }
    }
    return Q.fcall(next);
}
function getContents(filenames) {
    return qMap(filenames, function(filename) {
        return readFileAsync('users/' + filename, 'utf-8');
    });
}
相关文章：