节点应用程序中的请求超时

Question

我对节点 api 发出的请求需要 4 多分钟才能响应。而收到响应的时间。角度应用程序不接受响应。在萤火虫上，网址变成红色。

我该如何克服这个问题。

api.route('/allsearch')
    .post(function(req,res){
        var filters=req.body.everything;
        var filterid=req.body.filterId;
        var searchid=req.body.searchid;
        var zipgroup=req.body.zipgroup;
        var myObject = new Array();


        function getData(docs,  filters, filterid, callback) {
            function loop(i) {
                searchingalgo(docs[i], filters, filterid,  function(pers){
                        myObject[i] = pers;
                        if (i < docs.length) {
                        loop(i + 1);
                        } else {
                            callback();
                        }
                    });
            };
            loop(0);
        };//closing get data() 

        Searchradius.findOne({"searchid" : searchid, user: req.decoded.id}).exec(function(err, docs) {


            // Array to hold async tasks
            var asyncTasks = [];

            // Loop through some items
            zipgroup.forEach(function(item){
              // We don't actually execute the async action here
              // We add a function containing it to an array of "tasks"
              asyncTasks.push(function(callback){
                // Call an async function, often a save() to DB
                console.log(item);
                searchingalgo(item, filters, filterid,  function(pers){
                        myObject[item] = pers;
                      // Async call is done, alert via callback
                  callback();
                });
              });
            });


            Async.parallel(asyncTasks, function(){
                //console.log(myObject);
                Searchradius.update({ _id: searchid }, { $set: { ucounteds: myObject , uzips: zipgroup }}, function(err, result){
                    if(err) {
                        res.send(err);
                        return;
                    }
                    var fields = ['city', 'state', 'zip','distance', 'count'];
                    var myresults = [];
                    var tc=0;
                    var newMyobj= new Array();
                    co=0;
                    zipgroup.forEach(function(item){
                        tc+=myObject[item];
                        //myresults.push(jobj);
                    });

                    for(i=0;i<zipgroup.length;i++){
                        newMyobj[i]=myObject[zipgroup[i]];
                    }
                    console.log(tc);

                    Searchfilter.update({ _id: filterid }, { $set: { counted_results: tc }}, function(err, resultupdate){
                        //console.log(resultupdate);
                        //console.log(tc);
                    });




                //  console.log(myObject);
                //  console.log(newMyobj);
                    res.json({ 
                    success: true,
                    zips: zipgroup,
                    states: docs.states,
                    cities: docs.cities,
                    distances: docs.distances,
                    counted_results : newMyobj,
                    });

                });     //update searchradius
            });         //getdata function 
        });             //searchradius findone
    });

根据要求，这是我的节点 API。 zipgroup 是一个 zip 数组，例如

[37663, 37664, 37669, 37671, 37660, 37669, 37667, 37668, 37666, 37665, 37662, 37661]

为了清楚起见，Consumer1s 集合有超过 2900009876 个文档。它已正确编入索引，并且查询花费的时间尽可能少。但我仍然面临这个问题。 任何建议都会有所帮助。

这是我来自 Angular 控制器的发布请求。

$http.post('/api/allsearch',
        {
            "everything":$scope.filterSearch ,
            "searchid":$routeParams.id, 
            "filterId": $scope.filterId, 
            "zipgroup" : $scope.zipgroup
        })
        .success(function(data){

            for(var i=0; i<data.zips.length;i++){
                oneset={
                    "zip": data.zips[i],
                    "state": data.states[i],
                    "city": data.cities[i],
                    "distance": data.distances[i],
                    "count": data.counted_results[i]
                };
                $scope.totalCount+=data.counted_results[i];
                $scope.results.push(oneset);
            }
            angular.forEach($scope.results, function (result) {
                    result.distance = parseFloat(result.distance);
                });
            $rootScope.processing=false;
            $scope.filterlinkdisplay=true;
    }); 

Answer 1

至少有几个选项：

1. 设置AngularJS $http timeout 10分钟左右，让AngularJS请求不超时，等待4分钟获取数据
2. 轮询：1) AngularJS 应用程序执行初始请求 2) Node.js 服务器为此请求向 AngularJS 应用程序发出唯一令牌并开始收集数据 3) AngularJS 应用程序等待几分钟并发出请求使用之前收到的令牌来获取数据 4) 如果结果准备好，你就完成了。如果没有，请再次等待并从 AngularJS 发出另一个请求
3. use WebSocket。在客户端，许多浏览器都支持它，在服务器端使用ws。这是一个双向协议，因此服务器可以在数据准备好时通知客户端。