这是我的代码片段:

var processListing = function (directoryItems) {
    console.log('foreach');
    var itemsToDownload = [];
    directoryItems.forEach(function (element, index, array) {
        //Ignore directories
        if (element.type === 'd') {
            console.log('directory ' + element.name);
            return;
        }
        //Ignore non zips
        if (path.extname(element.name) !== '.zip') {
            console.log('ignoring ' + element.name);
            return;
        }
        //Download zip
        itemsToDownload.push({
            source: element.name,
            destination: element.name
        });
        //aftpSystem.downloadFile(element.name, element.name);
    });
    console.log('after foreach');
    return itemsToDownload;
};

var getFiles = function () {
    console.log('got files');
    return fs.readdirAsync(process.cwd() + "/zips/").then(function (files) {
        return files.filter(function (filename) {
            return path.extname(filename) === '.zip';
        });
    });
};

    aFtpClient. //this has been promisified
    listAsync(). //so calls methodAsync
    then(processListing).
    map(function (object) {
        return processItem(object).then(function (processResult) {
            return {
                input: object,
                result: processResult
            };
        });
    }).
    map(function (downloadItem) {
        console.log('downloading files');

        downloadItem.result.once('close', function () {
            console.log('closed');
        });

        return downloadItem.result.pipe(fs.createWriteStream(process.cwd() + "/zips/" + downloadItem.input.destination));
    }).
    then(getFiles).

我正在尝试使用 promises 通过 FTP 下载项目。目前它下载第一个文件但随后的文件失败。我是 Node 的新手，但相当有信心我的第二个映射函数需要返回一个 promise ，但是经过多次尝试后我一直无法弄清楚。我正在使用 bluebird 进行 promise ，但看不到如何使用它和流。

你能给我指出正确的方向吗？

谢谢

最佳答案

我不确定你到底被困在哪里，但指出你的大致方向就足够了:

• 你有一个与管道和事件一起工作的接口(interface)
• 您需要 promise 该接口(interface)。

所以你需要做的是:

1. 找出下载的“完成”事件是什么。
2. 创建一个 promise 并在该事件上解决它，在失败的事件上拒绝它。
3. 兑现 promise 。

可以通过多种方式实现 promise :

• 由 promise 图书馆。 Bluebird 包含一个非常聪明的 promisier，它使用依赖于 JIT 的动态代码生成 - 它非常快 - 但它是为 NodeJS“nodeback”案例构建的。 (即错误作为回调的第一个参数传递。)

• 使用 Deferred 对象。通常这种方式更容易出错。

• 在 Bluebird 中使用 Promise.method，这对于轻松 promise API 非常有用，但我们这里的情况并非如此。

• 使用 Promise 构造函数。这就是我们要做的。这也是标准投诉。

一般来说，promise构造函数的接口(interface)是:

new Promise(function(resolve,reject){

    resolve(); // this resolves the promise
    reject(); // this rejets the promise
});

请注意， promise 事件发射器只有在它们触发完成事件并触发一次时才有效。 Promise 是一次性的，一旦他们解决了他们就不能改变状态。事件可以触发多次。 promise 诸如 "load" 事件或 "finished" 事件之类的事情是完全没问题的——但不要 promise 重复多次的事情。

你的第二张 map 应该是这样的:

map(function (downloadItem) {
    console.log('downloading files');

    downloadItem.result.once('close', function () {
        console.log('closed');
    });
    var pipeAction = downloadItem.result.pipe(fs.createWriteStream(process.cwd() + "/zips/" + downloadItem.input.destination));
    return new Promise(function(resolve,reject){
        pipeAction.on("end",function(){ //waits for data to be consumed
             // pipe has ended here, so we resolve the promise
             resolve();
        });
    });
}).

您通常应该将 promise 提取到专用方法中。例如，上面的代码可以是 promisifyPipe 或类似的。

关于javascript - 使用 node.js、流和 promise 下载文件，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22475917/