节点 JS，链接可变数量的 http 请求

Question

我正在使用 request js 库向我的 API 发出 HTTP 请求。我的单个 API 调用如下所示：

var options = {
  method: "post",
  url: 'http//example.com',
  json: true,
  headers: headers,
  body: {key: value}
}
request(options, callback);

但是，我有 options 数组，需要一个接一个地调用，如果其中一个失败，我需要断开整个链。

如果最后一个链完成，我需要将结果输出到控制台。

我知道链接回调可以通过承诺实现，但我发现的所有示例都使用预定义数量的链接请求。

可能吗？

Answer 1

如果你有一个数组，你可以有一个到该数组的索引，并在前一个请求完成时让回调启动下一个请求。大致：

var index = 0;
var options = [/*...array of options objects...*/];
doRequest() {
    request(options[index], function(err, result) {
        // ...handle the result/error here. If there's no error, then:
        if (++index < options.length) {
            // Kick off the next request
            doRequest();
        }
    });
}

虽然上述可以是 Promise 化的，但由于您的 request 方法似乎不是，它只会使事情复杂化。

Answer 2

在请求回调中调用自身的递归函数应该可以工作。

options = [{...}, {...}];

function doRequests(options){

    request(options.shift(), function(){

        if(error){
            return "handle error";
        }

        if(options.length > 0){
            doRequests(options);
        }

    });

}

Answer 3

我要做的第一件事是使用返回承诺的请求库。假设你有这样的东西，那么你只需将承诺链接在一起。

首先创建一个已解决的承诺：

var promise = new Promise.resolve();

您要请求的每个新对象：

promise = promise.then(() => requestToPromise(options));

将另一个请求链接到现有的承诺上，并且仅当前一个请求完成时才会触发新请求。

Answer 4

您可以改用 request-promise

并执行以下操作

import request = require('request-promise');

var options = [/*...array of options objects...*/];
requests = [];
options.forEach(function(option){
    requests.push(request(option));
}
Promise.all(requests).then(function(reponses){
    //all requests are done.
});

节点 JS，链接可变数量的 http 请求

Node JS, chaining variable number of http requests

javascript

node.js

promise

bluebird