Node.js:来自一个函数的多个回调

Node.js : multiple callbacks from one function

本文关键字：一个 函数 回调 js Node      更新时间：2023-09-26

我在应用程序的代码中遇到了一个问题，我想知道处理它的最佳方法：我有一个函数在回调时应用了5个值，我想了解使用它的最佳方式。

这是我的功能代码：

var someFunc = function(callback) {
var http = require('http');
var id;
var url = 'http://somesite.com/json';

// First request to get an array of 5 elements
http.get(url, function(res) {
    var body = '';
    res.on('data', function(chunk) {
        body += chunk;
    });
    res.on('end', function() {
        var jsonResult = JSON.parse(body);
// 5 requests with a value from each of the 5 elements
        for (var i=0;i<5;i++)
        {
            (function(idx) {
                gameId = jsonResult.gameList[idx].id;
                url = 'http://somesite.com' + id + '/token';
                http.get(url, function(res) {
                    var body = '';
                    res.on('data', function(chunk) {
                        body += chunk;
                    });
                    res.on('end', function() {
                        jsonRes = JSON.parse(body);
                        callback.apply(null, [idx, jsonRes.interestScore]);
                    });
                }).on('error', function(e) {
                    console.log("Got error: ", e);
                });
            })(i);
        }
    });
}).on('error', function(e) {
    console.log("Got error: ", e);
});
};
exports.someFunc = someFunc;

当我调用函数来检索5个值时，我会这样做：

exports.featured = function(req, res){
    getSome.someFunc(function callback(result) {
        var variables = {};
        var variableName = result;
        variables[variableName] = jsonRes.interestScore;
        res.render('featured', { score0: variables[0], score1: variables[1], score2: variables[2], score3: variables[3], score4: variables[4] });
    });
};

不幸的是，"res.render"是在函数只检索到1个值后调用的，所以我想知道如何正确地执行它，或者进行适当的回调。

谢谢。

您调用的函数是异步的，响应end事件可以随时发生。您的代码导致res.render执行5次，但您只需要它执行1次，其中包含5个值。您应该使用像async这样的模块，它将帮助您激发多个任务，并在所有任务完成时进行回调。

示例：

var jsonResult = JSON.parse(body);
var arr = [];
for(var i = 0; i < 5; i++){
   arr.push(jsonResult[0].interestScore);
}
async.map(arr, myAsyncFunction, function(err, results){
   // results[0] => response of first index
   // results[4] => response of last index
});

我看到的第一个问题是，您为end事件分配了五次监听器。你应该只做一次。您可以收集五次结果，然后调用回调。下面是一个使用请求模块的示例：

var request = require('request');
var makeRequests = function(callback) {
    var result = [],
        done = 0;
    request('http://www.google.com', function (error, response, body) {
        if (!error && response.statusCode == 200) {
            // read the body here
            var searchFor = [
                'nodejs',       // 1
                'http request', // 2
                'npm',          // 3
                'express',      // 4
                'javascript'    // 5
            ];
            for(var i=0; keyword = searchFor[i]; i++) {
                request('https://www.google.bg/search?q=' + keyword, function (error, response, body) {
                    if (!error && response.statusCode == 200) {
                        result.push(body);
                        ++done;
                        if(done == searchFor.length) {
                            callback(result);
                        }
                    }
                });
            }
        }
    });
}
makeRequests(function(result) {
    console.log("result=" + result.length);
})
相关文章：