javascript - 我如何在 node.js 中使用 promises 来清理回调链？

Question

我正在尝试弄清楚如何使用 promises，尤其是 Q 实现来清理 node.js 程序中一些困惑的嵌套回调。不幸的是，似乎很少有简单的例子可以说明我想做什么。

这是我现在拥有的嵌套回调的简化版本:

    var parent = this;
    this.receiveMessage(params, function(err, request) {
    if (err) console.log(err, err.stack);
    else {
       parent.handleMessage(request, function(response) {
           parent.sendMessage(JSON.stringify(response), function() {
               console.log("response sent");
               var params = { ReceiptHandle:request.Messages[0].ReceiptHandle };
               parent.deleteMessage(params, function() {
                   parent.waitForMessage();
               });
           });
       });
    }
});

如您所见，这非常困惑并且有 4 层嵌套回调。

使用 Q，我发现您可以从以下内容开始:

Q.nfcall(this.connection.receiveMessage, params)
    .then(function(err, request) {
        return(Q.nfcall(this.handleMessage(request));
    })
    .then(function(response)) { 
        return(Q.nfcall(this.sendMessage(JSON.stringify(response))));
    } ...

等等...但这似乎不太正确。首先，我是否需要对链中的每个函数调用 Q.nfcall？另外，我是否避免了使用回调时遇到的“this”的范围问题？我是否以正确的方式使用 promises？

Answer 1

我有过类似的问题，后来我意识到这是因为 Q。在我看来，Q 的 API 很乱，使用起来很麻烦，而且只有很少的简单示例。我建议尝试任何其他库，但我确实推荐 Bluebird。使用 Bluebird，您可以执行以下操作:

var Promise = require('bluebird');
var parent = this;
Promise.promisifyAll(parent, { suffix: "P" });
parent.receiveMessageP(params)
  .then(function (request) {
    return [request, parent.handleMessageP(request)];
  })
  .spread(function (request, response) {
    return [request, parent.sendMessageP(JSON.stringify(response))];
  })
  .spread(function (request) {
    console.log("response sent");
    var params = { ReceiptHandle: request.Messages[0].ReceiptHandle };
    return parent.deleteMessageP(params);
  })
  .then(function () {
    parent.waitForMessage();
  })
  .catch(function (err) {
    console.log(err, err.stack);
  });

如果您不喜欢返回数组和使用 .spread 的样式，您可以在外部作用域中使用映射对象。

var Promise = require('bluebird');
var parent  = this;
Promise.promisifyAll(parent, { suffix: "P" });
var cache = {};
parent.receiveMessageP(params)
  .then(function (request) {
    cache.request = request;
    return parent.handleMessageP(request);
  })
  .then(function (response) {
    return parent.sendMessageP(JSON.stringify(response));
  })
  .then(function () {
    console.log("response sent");
    var params = { ReceiptHandle: cache.request.Messages[0].ReceiptHandle };
    return parent.deleteMessageP(params);
  })
  .then(function () {
    parent.waitForMessage();
  })
  .catch(function (err) {
    console.log(err, err.stack);
  });

如果您需要访问链中较晚的变量，而这些变量在链的较早阶段已解析，您可以简单地将它们添加到 cache 对象中以便于访问。有时，如果你有很多这样的方法，这种方法会更清晰、更容易阅读。在大多数情况下，我通常更喜欢第一个示例，只是为了避免污染父范围并可能保留本应处理掉的引用。

并不是说您不能在 Q 中执行类似于 promisifyAll 的操作，而是 Bluebird 性能更高、更直观。

如果您的回调不符合 function (err, successValue) 的典型 Node 样式签名(您的一些回调似乎不符合，这意味着 promisifyAll 不会对它们起作用)那么你可以在 Bluebird 中定义一个自定义的“promisier”。或者修改您的回调 API 以符合 node-style callbacks .

https://github.com/petkaantonov/bluebird/blob/master/API.md#option-promisifier