如何在 JavaScript 中执行同步 HTTP 请求

Question

我需要在 node.js 程序中执行未知数量的 http 请求，并且它需要同步发生。只有当一个人得到响应时，下一个请求才会被执行。如何在 JS 中实现它？

我用requset包同步试过了：

function HttpHandler(url){

  request(url, function (error, response, body) {
     ...
  })

}

HttpHandler("address-1")
HttpHandler("address-2")
...
HttpHandler("address-100")

并与 request-promise 异步：

async function HttpHandler(url){

  const res = await request(url)
  ...

}

HttpHandler("address-1")
HttpHandler("address-2")
...
HttpHandler("address-100")

它们都不起作用。正如我所说，我可以通过程序获得未知数量的 http 请求，这取决于最终用户。

有什么解决办法吗？

Answer 1

使用got() 库，而不是request() 库，因为request() 库已被弃用并且不支持承诺。然后，您可以使用async/await 和for 循环依次对您的调用进行排序。

const got = require('got');
let urls = [...];    // some array of urls

async function processUrls(list) {
    for (let url of urls) {
        await got(url);
    }
}

processUrls(urls).then(() => {
    console.log("all done");
}).catch(err => {
    console.log(err);
});

您正在声明某种 URL 的动态列表，但不会显示它是如何工作的，因此您必须自己弄清楚这部分逻辑。我很乐意展示如何解决这部分问题，但您还没有告诉我们应该如何工作。

---

如果您想要一个可以定期添加项目的队列，您可以执行以下操作：

class sequencedQueue {
    // fn is a function to call on each item in the queue
    // if its asynchronous, it should return a promise
    constructor(fn) {
        this.queue = [];
        this.processing = false;
        this.fn = fn;
    }
    add(...items) {
        this.queue.push(...items);
        return this.run();
    }
    async run() {
        // if not already processing, start processing
        // because of await, this is not a blocking while loop
        while (!this.processing && this.queue.length) {
            try {
                this.processing = true;
                await this.fn(this.queue.shift());
            } catch (e) {
                // need to decide what to do upon error
                // this is currently coded to just log the error and
                // keep processing.  To end processing, throw an error here.
                console.log(e);
            } finally {
                this.processing = false;
            }
        }
    }
}