承诺和循环集合

Question

请帮助我了解我的代码有什么问题。

所以我要做的是调用异步调用来获取计数。我已经把它变成了一个承诺。

function getCount(client) {
    var xml = "<urn:mgmtISCSIGetTargetList> </urn:mgmtISCSIGetTargetList>";
    client.MgmtServer.MgmtServer.mgmtISCSIGetTargetList(xml, function (err, result) {

        if (err) {
            logger.error(err);
            debug(err);
            return deferred.reject(err);
        }
            deferred.resolve(parseInt(result.list.targetCount));
        }
    });

    return deferred.promise;
};

一旦我使用上述承诺获得计数，我需要进行更多的异步调用，与第一个承诺的返回一样多。

假设稍后执行的代码是另一个承诺。 该代码是：

function az(client, index) {
  var xml = "<urn:mgmtISCSIGetTargetList> </urn:mgmtISCSIGetTargetList>";
    client.MgmtServer.MgmtServer.mgmtISCSIGetTargetList(xml, function (err, result) {

            if (err) {
                return deferred.reject(err);
            }

            var i;
            for (i = 0; i < index; i++) {
                if (1 === i) {
                    console.log('index 1 is bad news');
                    return deferred.reject("Blew up");
                }
            }

            console.log('after the loop');
            deferred.resolve(index);
        }
    );
    return deferred.promise;
};

仅出于测试目的，我对 1 的索引进行了硬编码，拒绝了承诺。 当我把承诺放在一起时，我没有看到我所期望的。 代码是：

getCount(client).then(
    function (count) {
        return az(client, count).then(console.log);
    }
).catch(
    function (err) {
        console.log('caught an error from outer promise');
        console.log(err);
    }
);

我得到的输出是：

3 which is from deferred.resolve(index);
index 1 is bad news which is hard coded failure.

我知道这是一篇很长的帖子，但是有人知道我将这两个承诺链接在一起做错了什么吗？

我将 az 改为：

function az(client, index) {
    var xml = "<urn:mgmtISCSIGetTargetList> </urn:mgmtISCSIGetTargetList>";
    client.MgmtServer.MgmtServer.mgmtISCSIGetTargetList(xml, function (err, result) {

            if (err) {
                return deferred.reject(err);
            }

            if (1 === index) {
                console.log('index 1 is bad news');
                return deferred.reject("Blew up");
            }

            console.log('after the loop with index ' + index);
            deferred.resolve(index + 30);
        }
    );
    return deferred.promise;
};

Answer 1

您只能解决（履行/拒绝）一个承诺一次。在循环中包含 return deferred.reject("Blew up"); 看起来很像设计气味或错误理解。

我需要进行更多的异步调用，与第一个承诺的返回一样多。假设做后者的代码是另一个承诺

每个异步任务都应该有自己的承诺。我对那个描述的期望是

getCount(client).then(function (count) {
    for (var i=0; i<count; i++)
        az(client, i).then(console.log);
})

现在每个az 调用都会返回一个promise，因此您将拥有一个并行执行的promise 数组。如果你需要等待所有的人一起继续他们的所有结果，你需要将它们组合成一个新的承诺。 Q 库确实有一个帮助函数，名为Q.all。你可以这样使用它：

getCount(client).then(function (count) {
    var promises = [];
    for (var i=0; i<count; i++)
        promises.push(az(client, i));
    return Q.all(promises);
}).then(function(results) {
    console.log("everything went right. All results:", results);
}, function(err) {
    console.log("something (either getCount, or one of the az calls) blew up", err);
});