承诺链和错误处理

Question

我正在尝试用 Promise 来理解链接和错误处理。在这里，我有一些承诺。

return ad_fetcher.getAds(live_rail_url, ad_time, req.sessionID)
        .spread(generator.playlist_manipulate) // returns Promise.resolve([data, anotherData])
        .then(client.incrAsync(config.channel_name + ":ad_hits", "vdvd")) // FOCUS HERE
        .then(function() {
            console.log("AD FETCHED AND PLAYLIST GENERATED.");
            res.send(generator.generate_regular(config.default_bitrate));
            })
        .catch(function(err) {
            console.log('!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!');
            console.log("!!! AD FETCHER - THERE WAS AN ERROR:!!!!!!!!!!!");
            client.sadd(config.channel_name + ":ad_errors", err);
            client.incr(config.channel_name + ":ad_errors:count");
            console.log(err);
            console.log('!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!');
            res.send(generator.generate_regular(config.default_bitrate));
    });

现在在client.incrAsync(config.channel_name + ":ad_hits", "vdvd") 行，我故意编写错误的语法以查看.catch 是否捕获到错误。但是当我运行它时，我得到了这个：

未处理的拒绝错误：ERR 'incr' 的参数数量错误 命令

但是当我改变这个承诺的用法时：

.
.
    .then(function() {
        return client.incrAsync(config.channel_name + ":ad_hits", "vdvd");
    })
.
.

错误被很好地捕获。它不再是“未处理的”。

我不明白这种行为。 incrAsync 不返回一个承诺，所以它的错误应该被链末尾的.catch 捕获吗？

注意：我承诺了 redis 客户端，毫无疑问。

谢谢！

Answer 1

当你链接 Promise 时，你会使用前一个函数的结果调用链中的下一个函数。

但是，您正在调用直接返回承诺的函数。因此，除非调用该函数返回一个返回 Promise 的函数，否则您没有正确链接。

所以这两种方法都可以：

.spread(generator.playlist_manipulate) // returns Promise.resolve([data, anotherData])
.then(client.incrAsync) // this function will receive [data, anotherData]

或者，正如您在问题中使用的那样，一个匿名函数：

.spread(generator.playlist_manipulate) // returns Promise.resolve([data, anotherData])
.then(function() { // this function receives [data, anotherData] but throws it away
    // this Promise is "subsumed" by the Promise chain. The outer Promise BECOMES this Promise
    return client.incrAsync(config.channel_name + ":ad_hits", "vdvd");
})

因为否则，你写的基本上是这样的：

.then(function)
.then(Promise)
.then(function)

但是你需要将函数传递给 .then，而不是 Promises，如果你希望它们在最后由你的 .catch 块处理。