使用 request-promise 在 Electron 中链接 HTTP 请求

Question

更新

好的，所以我解决了。使用 highland.js 时，我需要一个 .done() 来完成流。

var requests = [];           
_(fs.createReadStream("small.txt", { encoding: 'utf8' }))
        .splitBy('-----BEGIN-----\n')
        .splitBy('\n-----END-----\n')
        .filter(chunk => chunk !== '')
        .each(function (x) {

            requests.push(function (next) {
                Helpers.Authenticate()
                    .then(function (response1) {
                        return Helpers.Retrieve();
                    })
                    .then(function (response2) {
                        return Helpers.Retrieve();
                    })
                    .then(function () {
                        next();
                    });
            });

        })}).done(function () {
        async.waterfall(requests);
    });

request 数组现在正在工作。

---

我在使用电子和链式承诺时遇到了一些问题。这是我在主进程中运行的代码。

var request = require('request-promise');
request.post(tppAuthenticate)
    .then(function (responseFromFirstPost) {
        var newoptions = tppRetrieveCertificate(responseFromFirstPost.APIKey)
        return request.post(newoptions) // The return is important
    })
    .then(function (responseFromSecondPost) {
        console.log(responseFromSecondPost)
    })

整个代码块通过遍历文件的每一行来执行数千次调用。第一个请求被连续触发，但这似乎显着阻止/限制了仅定期调用的第二个请求。

我希望按顺序调用整个块，但这似乎没有发生。

这是我的完整代码块，包括迭代：

        const _ = require('highland');
        const request = require('request-promise');

        fs.createReadStream(files[0], { encoding: 'utf8' }))
         .splitBy('-----BEGIN -----\n')
         .splitBy('\n-----END -----\n')
         .filter(chunk => chunk !== '')

         // .each(_.log);
         .each(function (x) {

             request.post(tppHelpers.Authenticate)
                 .then(function (responseFromFirstPost) {
                     const newoptions = tppHelpers.tppRetrieveCertificate(responseFromFirstPost.APIKey)
                     console.log(newoptions)
                     return request.post(newoptions) // The return is important
                 })
                 .then(function (responseFromSecondPost) {
                     console.log(responseFromSecondPost)
                     event.sender.send('selected-directory', responseFromSecondPost)
                 })

         });

Answer 1

如果您不想一次触发每个请求，这似乎是读取您创建的 cmets 的情况，那么不要并行运行所有请求：

.each(function (x) {
  // ...
});

您可以在运行 fs.createReadStream 之前创建一个空数组：

var requests = [];

并在您的 each 回调中创建函数以添加到您的数组中：

.each(function (x) {
  requests.push(function (next) {
    // ...
    next();
  });
});

然后您可以使用以下命令串联运行它：

async.series(requests);

使用async 模块。

只要确保 next() 在正确的时刻被调用，例如在给定的 Promise 链的最后一个 .then() 回调中。

另一种方法是使用async.queue:

var queue = async.queue(function(x, callback) {
  // 
  callback();
}, 1);

（这里确保在应该调用 callback() 的时候调用它。最后你可以使用其他数字代替 1 来并行完成一定数量的请求。）

然后在您的each 回调中：

.each(function (x) {
  queue.push(x);
});

有关详细信息，请参阅 async.queue 文档。 （感谢 robertklep 在 cmets 中提及 async.queue()。）

顺便说一句：您甚至在迭代中使用x 还是只是对输入的每一行提出一堆相同的请求？

示例

为了回答 cmets 的问题，这里有一种构造函数数组的方法。

如果这是您的原始代码：

yourStream.each(function (x) {
  doRequest1()
  .then(function (response1) {
    return doRequest2();
  })
  .then(function (response2) {
    return doRequest3();
  });
});

然后你可以用类似的东西来构造这个函数数组：

var requests = [];
yourStream.each(function (x) {
  requests.push(function (next) {
    doRequest1()
    .then(function (response1) {
      return doRequest2();
    })
    .then(function (response2) {
      return doRequest3();
    })
    .then(function () {   
      next();
    });
  });
});

您可以使用以下命令运行它们：

async.series(requests);

希望对你有帮助。