如何使请求等待先前的请求完成？

Question

我正在尝试将 API 调用发送到 NodeJS 服务器。不幸的是，服务器（不是我制作的）不允许我进行异步调用。

我正在尝试找出一种方法，让每个请求都等待前一个请求完成后再发送。

这是我的代码：

var http = require('http');
var fs = require('fs');

// An object of options to indicate where to post to
var post_options = {
    host: 'localhost',
    port: '8080',
    path: '/api/scan',
    method: 'POST',
    headers: {
        'Content-Type': 'application/json'
    }
};
var array = ["ssl.com", "google.com", "hamzakhan.org"];
for (var i=0; i<array.length;i++) {
    //console.log(array[i]);
    var post_req = http.request(post_options, function(res) {
        res.setEncoding('utf8');
        var body = '';
        res.on('data', function(chunk) {
            body += chunk;
        });
        res.on('end', function() {
            body = JSON.parse(body);
            // Make sure it's working
            console.log(body.response.subject);
        });
    });

    var url = array[i];
    var catURL = { "url": url, "path": "/", "port": "443", "live_scan": "false", "advanced": "true" };
    post_req.write(JSON.stringify(catURL), function(err) {
        //console.log(err);
        post_req.end();
    });

}

我在想我可以在 for 循环中嵌套一个 while 循环，而 while 循环会有一个标志来指示 for 循环何时可以继续进行。

现在，当我将 url 的值硬编码为单个 url 时，此代码有效，因此我知道我成功发送和接收。

感谢所有/任何帮助！

Answer 1

/**
 * Disclaimer: I did not test your code. I simply added a few
 * lines to illustrate my suggestion.
 */

var http = require('http');
var fs = require('fs');
var EventEmitter = require('events').EventEmitter;

// An object of options to indicate where to post to

var post_options = {
    host: 'localhost',
    port: '8080',
    path: '/api/scan',
    method: 'POST',
    headers: {
        'Content-Type': 'application/json'
    }
};

var array = ["ssl.com", "google.com", "hamzakhan.org"];
var emitter = new EventEmitter();
var counter = 0, n = array.length;

function PostRequest() {
    var post_req = http.request(post_options, function(res) {
        res.setEncoding('utf8');
        var body = '';
        res.on('data', function(chunk) {
            body += chunk;
        });
        res.on('end', function() {
            body = JSON.parse(body);
            // Make sure it's working
            console.log(body.response.subject);

            // ADD THE CALLBACK 
            // OR 
            // TRIGGER EVENT
            return emitter.emit('ResponseEnded');

        });
    });

    var url = array[counter];
    var catURL = { "url": url, "path": "/", "port": "443", "live_scan": "false", "advanced": "true" };
    post_req.write(JSON.stringify(catURL), function(err) {
        //console.log(err);
        post_req.end();
    });
}

emitter.on('ResponseEnded',function() {
    ++counter;
    if (counter < n) {
        PostRequest();
    }
    else {
        console.log('Nothing more request');
    }
});

// Start with the first request
PostRequest();

更新：这是做同样事情的另一种方式。

/**
 * Disclaimer: I did not test your code. I simply added a few
 * lines to illustrate my suggestion.
 */

var http = require('http');
var fs = require('fs');


// An object of options to indicate where to post to

var post_options = {
    host: 'localhost',
    port: '8080',
    path: '/api/scan',
    method: 'POST',
    headers: {
        'Content-Type': 'application/json'
    }
};

var array = ["ssl.com", "google.com", "hamzakhan.org"];
var counter = 0, n = array.length;

function PostRequest() {
    var post_req = http.request(post_options, function(res) {
        res.setEncoding('utf8');
        var body = '';
        res.on('data', function(chunk) {
            body += chunk;
        });
        res.on('end', function() {
            body = JSON.parse(body);
            // Make sure it's working
            console.log(body.response.subject);

            // THIS IS ANOTHER WAY OF DOING IT
            ++counter;
            if (counter < n) {
                /**
                 * This is were your start new 
                 * requests
                 */
                PostRequest();
            }
            else {
                console.log('Nothing more request');
            }            

        });
    });

    var url = array[counter];
    var catURL = { "url": url, "path": "/", "port": "443", "live_scan": "false", "advanced": "true" };
    post_req.write(JSON.stringify(catURL), function(err) {
        //console.log(err);
        post_req.end();
    });
}

// Start with the first request
PostRequest();