JavaScript异步回调地狱

安托

我有一个应用程序,我使用了异步操作来避免“意大利面条回调”并正常工作,但是在某些并行调用中,我必须进行一些更改,因为在返回之前必须更改值,因为这些更改产生了与我认为相同的例程设置一个函数来执行此操作,从而保存代码,但无法使用该应用程序(我是javascript的新手,正在学习)。

调试(console.log),在某些情况下,错误是与从不同请求中调用的回调相同(如果它们是局部变量,则不了解这种情况是如何发生的)。我试图用forEach和async.each更改代码,但是在两种情况下我都出错,不再是继续尝试的更多更改,找不到错误。

我的原始代码(为避免冗长的文章,我对其进行了总结):

async.parallel({
    today: function(callback){

        data.get('DATA', function(err, dataGet){

            if(err){
                callback(err);
            }
            callback(null, dataGet);
        });
    },
    .... yesteday, week, month ....
    year: function(callback){

        data.get('DATA', function(err, dataGet){

            if(err){
                callback(err);
            }
            callback(null, dataGet);
        });
    }
},
function(error, results){
    --- routine ----
});

我的新代码是这样的:

功能

function getDataChange(key, valuePass, callback){

    var values = [ .... ],
        totalData = 0.00;

    /*
    async.each(values, function(value, cb){

        var keyR = key.replace(/%value%/g, value.toLowerCase() );

        data.get(keyR, function(err, dataGet){

            if(err){
                cb(err);
            }

            dataGet = ( dataGet !== null ) ? dataGet : 0 ;

            if( valuePass === value ) {

                totalData += parseFloat( dataGet );
                cb();

            } else {

                valueConverter.convert({ force: true, multi: true }, function(data){

                    totalData += parseFloat( data );
                    cb();
                });
            }
        });
    },
    function(err){

        if(err){
            callback(err);
        } else {
            callback(null, totalData );
        }
    });
    */

    var totals = values.length;

    values.forEach(function(value){ 

        var keyR = key.replace(/%value%/g, value.toLowerCase() );

        data.get(keyR, function(err, dataGet){

            if(err){
                return callback(err);
            }
            dataGet = ( dataGet !== null ) ? dataGet : 0 ;
            total--;

            if( valuePass === value ) {

                totalData += parseFloat( dataGet );

                if( totals === 0 ){     
                    callback(null, totalData);
                }
            } else {

                valueConverter.convert({ force: true, multi: true }, function(data){

                    totalData += parseFloat( data );

                    if( totals === 0 ){
                       callback(null, totalData);
                    }
                });
            }
        });
    });
    //callback(null, totalData);
}

并更改主要例程:

var keyBase = '......',
    value = '.....';

async.parallel({

    today: function(callback){
        /*
        data.get('DATA', function(err, dataGet){

            if(err){
                callback(err);
            }
            callback(null, dataGet);
        });
        */
        getDataChange(keyBase + 'DATAD', value, function(err, returnData){

            if(err){
                callback(err);
            }
            //console.log('## Return Data today');
            callback(null, returnData);
        });
        //callback(null, 0);
    },
    .... yesteday, week, month ....
    year: function(callback){

        getDataChange(keyBase + 'DATAY', value, function(err, returnData){

            if(err){
                callback(err);
            }
            console.log('## Return Data year');
            callback(null, returnData);
        });
    }
},
function(error, results){
    --- routine ----
});

我认为我将不得不重复并行异步调用中引入的代码,因为我无法操作。

我的错误多种多样。在各种测试中,我对函数的调用进行了注释,并在多个并行调用中将回调的返回值建立为0,并且我发现未运行最终的async.parallel回调函数(例如,如果注释了所有调用,今天,昨天和一周)。在其他情况下(将所有呼叫都建立为注释并将值重新设置为0(昨天和星期除外)),则每周运行两次回调。如果对该函数的所有调用都进行了注释(星期和今天除外),则会导致异常,显示消息“错误:已经调用了回调”。

我被困了几天,找不到错误或如何解决这个问题:-S

谢谢。

安托

固定的 !

使用功能的模块之一被称为对Web api的请求,这大大延迟了响应。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章