promise按顺序运行嵌套promise，并在第一次拒绝时解决

Question

我正在努力在以下任务中发送多个AJAX调用。API返回有两个参数：userId和offsetValue，并返回指定用户的最后10条消息，从指定的偏移量开始。如果偏移量大于用户的消息总数，API将返回空字符串。

我编写了一个函数，返回一个单独的promise，为指定的userId和offsetValue获取10条消息。

function getMessages(userId, offsetValue) {
    return new Promise(function (resolve, reject) {
        $.ajax(
        {
            url: 'https://example.com/api.php',
            type: 'POST',
            data: {
                action: 'get_messages',
                offset: offsetValue,
                user: userId
            },
            success: function (response) {
                if (response != '') {
                    resolve(response);
                } else {
                    reject(response);
                }
            },
            error: function (response) {
                reject(response);
            }
        });
    });
}

我需要使用.all（）为多个用户ID运行并行任务，但是我无法为每个用户ID运行并行子任务（每次将偏移值增加10），因为我事先不知道每个用户有多少条消息，因此，当第一个单独的promise被拒绝时（即offsetValue大于消息总数），执行应该停止。大概是这样的：

var messages = '';

getMessages('Alex', 0)
    .then(function(result) {
        messages += result;

        getMessages('Alex', 10);
            .then(function(result) {
                messages += result;

                getMessages('Alex', 20)
                ....
            });
    });

那么，有没有办法一个接一个地运行带有迭代参数的顺序promise，并在第一次拒绝时解决整体级联结果？




Answer 1

首先，您希望避免promise反模式，即当$.ajax（）已经返回一个您可以直接使用的promise时，不必要地将代码包装在新的promise中。要解决此问题，请更改为：

// retrieves block of messages starting with offsetValue
// resolved response will be empty if there are no more messages
function getMessages(userId, offsetValue) {
    return $.ajax({
        url: 'https://example.com/api.php',
        type: 'POST',
        data: {
            action: 'get_messages',
            offset: offsetValue,
            user: userId
        }
    });
}

现在，回答你的主要问题。如果您希望在收到拒绝或空响应时停止请求新项目，并且您不知道将提前有多少个请求，那么您几乎必须连续请求，并在收到空响应或错误时停止请求下一个项目。这样做的关键是通过从.then（）处理程序返回一个新的promise，将顺序promise链接在一起。

您可以这样做：

function getAllMessagesForUser(userId) {
    var offsetValue = 0;
    var results = [];

    function next() {
        return getMessages(userId, offsetValue).then(function(response) {
            // if response not empty, continue getting more messages
            if (response !== '') {
                // assumes API is returning 10 results at a time
                offsetValue += 10;
                results.push(response);
                // chain next request promise onto prior promise
                return next();
            } else {
                // empty response means we're done retrieving messages
                // so just return results accumulated so far
                return results.join("");
            }
        });
    }
    return next();
}

这将创建一个内部函数，该函数返回一个promise，并且每次它收到一些消息时，它都会将一个新promise链接到原始promise上。因此，getAllMessagesForUser（）返回一个单独的promise，该promise使用它检索到的所有消息进行解析，或使用错误拒绝所有消息。

您可以这样使用它：

getAllMessagesForUser('Bob').then(function(messages) {
    // got all messages here
}, function(err) {
    // error here
});

您可以将多个用户并行化（只要您确定没有使服务器过载或遇到速率限制问题），如下所示：

$.when.apply($, ['Bob', 'Alice', 'Ted'].map(function(item) {
    return getAllMessagesForUser(item);
})).then(function() {
    // get results into a normal array
    var results = Array.prototype.slice.call(arguments);
});

另外，Promise.all（）使用起来比$好得多。when（）（因为它需要一个数组并解析为一个数组），但是因为这里已经涉及到jQuerypromise，而且我不知道您的浏览器兼容性要求，所以我坚持使用jQuerypromise管理，而不是ES6标准promise。