我知道这里有一些重复的问题。但是,我不知道如何解决这个问题。我的代码是这样的:
/**
* DEFINE
* @connection_kill
*/
apiRoutes.post('/balancer_connection_drop', function(req, res) {
/* BALANCER - connection kill */
async.auto({
decrypt_kill: function(callback, drop, user, stream) {
/* DROP - decrypt */
try {
/* DEFINE - drop */
var drop = JSON.parse(decrypt(Object.keys(req.body)[0], encryption));
/* DROP - user & stream */
callback(null, drop['drop'], drop['user'], drop['stream']);
} catch(s) {
/* CLOSE - connection */
res.end();
}
},
remove_connection: ['decrypt_kill', function(results, callback) {
/* DROP - balancer || user & stream */
if ((results[Object.keys(results)[0]])[0] !== 'null') {
/* DROP - balancer users */
if (results[Object.keys(results)[0]][0] == 'balancer') {
console.log('callback users...');
/* DROP - balancer users */
pool.query('UPDATE live SET remove=?',[1], function(err, results) {
/* DROP - failed */
if (err) return callback('Could NOT Drop Users From Live Table!');
})
} else {
console.log('callback user...');
/* DROP - balancer user */
pool.query('UPDATE live SET remove=? WHERE user=? AND stream=?',[1, results[Object.keys(results)[0]][1], results[Object.keys(results)[0]][2]], function(err, results) {
/* DROP - failed */
if (err) return callback('Could NOT Drop Users From Live Table!');
})
}
} else {
console.log('failed to kill data empty...');
return callback('Balancer Connection Kill Data Empty!');
}
console.log('callback...');
callback();
}]
}, function(err, results) {
/* CHECK - error */
if (err) return res.send(encrypt(JSON.stringify({'status': 'false'}), encryption));
/* DROP - success */
res.send(encrypt(JSON.stringify({'status': 'true'}), encryption));
/* END - connection */
res.end();
})
})
现在,当我调用此api C时,从节点获取此错误:
已经调用了回调
所以我放入代码console.log来查看两次调用的内容,我从console.log中获取此内容,然后抛出两次调用的错误:
callback user...
callback...
所以我看到我错了,我称之为两次,但我不知道如何重写上面的代码,因为它应该是这样,当调用回调用户...时。我需要去
function(err, results) {
函数和函数返回json到我的服务器api,但我不知道如何重写它。我尝试使用上面的代码在函数外部移动回调,但从不调用回调。
/* DROP - user & stream */
callback(null, drop['drop'], drop['user'], drop['stream']);
} catch(s) {
/* CLOSE - connection */
res.end();
}
},
remove_connection: ['decrypt_kill', function(results, callback) {
/* DROP - balancer || user & stream */
if ((results[Object.keys(results)[0]])[0] !== 'null') {
/* DROP - balancer users */
if (results[Object.keys(results)[0]][0] == 'balancer') {
console.log('callback users...');
/* DROP - balancer users */
pool.query('UPDATE live SET remove=?',[1], function(err, results) {
/* DROP - failed */
if (err){ return callback('Could NOT Drop Users From Live Table!');}
return callback();
})
} else {
console.log('callback user...');
/* DROP - balancer user */
pool.query('UPDATE live SET remove=? WHERE user=? AND stream=?',[1, results[Object.keys(results)[0]][1], results[Object.keys(results)[0]][2]], function(err, results) {
/* DROP - failed */
if (err){ return callback('Could NOT Drop Users From Live Table!');}
return callback();
})
}
} else {
console.log('failed to kill data empty...');
return callback('Balancer Connection Kill Data Empty!');
}
}]
},function(err,results){/ * CHECK - error / if(err)return res.send(encrypt(JSON.stringify({'status':'false'}),encryption)); / DROP - success / res.send(encrypt(JSON.stringify({'status':'true'}),encryption)); / END - 连接* / res.end(); })})把return
放在pool.query
电话前面。您的代码执行正在通过if statement
降低,
...
console.log('callback...');
callback();
仅供参考,
你已经有一个if-else
捕捉所有路径,所以为什么你有这个?
...
console.log('callback...');
callback();
remove_connection: ['decrypt_kill', function(results, callback) {
/* DROP - balancer || user & stream */
if ((results[Object.keys(results)[0]])[0] !== 'null') {
/* DROP - balancer users */
if (results[Object.keys(results)[0]][0] == 'balancer') {
console.log('callback users...');
/* DROP - balancer users */
pool.query('UPDATE live SET remove=?',[1], function(err, results) {
/* DROP - failed */
if (err) return callback('Could NOT Drop Users From Live Table!');
})
} else {
console.log('callback user...');
/* DROP - balancer user */
pool.query('UPDATE live SET remove=? WHERE user=? AND stream=?',[1, results[Object.keys(results)[0]][1], results[Object.keys(results)[0]][2]], function(err, results) {
/* DROP - failed */
if (err) return callback('Could NOT Drop Users From Live Table!');
})
}
} else {
console.log('failed to kill data empty...');
return callback('Balancer Connection Kill Data Empty!');
}
console.log('callback...');
callback();
}]
因为pool.query
是一个异步操作,所以callback()
fter console.log('callback...');
将在它们完成之前被调用。如果他们失败了,他们会再次打电话给他们。
我将删除最后一个callback()
call并在每次异步调用运行后调用它,如下所示:
remove_connection: ['decrypt_kill', function(results, callback) {
/* DROP - balancer || user & stream */
if ((results[Object.keys(results)[0]])[0] !== 'null') {
/* DROP - balancer users */
if (results[Object.keys(results)[0]][0] == 'balancer') {
console.log('callback users...');
/* DROP - balancer users */
pool.query('UPDATE live SET remove=?',[1], function(err, results) {
/* DROP - failed */
if (err) return callback('Could NOT Drop Users From Live Table!');
callback();
})
} else {
console.log('callback user...');
/* DROP - balancer user */
pool.query('UPDATE live SET remove=? WHERE user=? AND stream=?',[1, results[Object.keys(results)[0]][1], results[Object.keys(results)[0]][2]], function(err, results) {
/* DROP - failed */
if (err) return callback('Could NOT Drop Users From Live Table!');
callback();
})
}
} else {
console.log('failed to kill data empty...');
return callback('Balancer Connection Kill Data Empty!');
}
}]