函数在异步方法完成之前返回 Node JS
Function returning before async method done Node JS
我目前有一个从我的路由器调用的函数:
router.js:
var result = Api.getUser();
console.log("Result: " + result);
api.js
exports.getUser = function(req, result) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + req.user.accessToken},
json: true
}, function(e, r, body) {
console.log("e: " + e + " body: %j", body);
if(e) {
return "{error: true}";
} else {
return body;
}
});
};
我遇到的问题是我先获取日志 "Result: undefined"。
有没有办法阻止 getUser 函数返回,直到 get 函数完成?
Promises 很棒,我建议研究一下。然而,一个简单的回调就可以解决问题
api:
exports.getUser = function(req, result, callback) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + req.user.accessToken},
json: true
}, function(e, r, body) {
if(e) {
callback({error: true});
} else {
callback(body)
}
});
};
路由器:
var result
Api.getUser(req, result, function (response) {
result = response
console.log(result)
});
你不能从异步函数中 return
,你可以使用回调:
exports.getUser = function(req, result, callback) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + req.user.accessToken},
json: true
}, function(e, r, body) {
if(e) {
callback({error: true});
} else {
callback(body);
}
});
};
Api.getUser(req, result, function(user) {
console.log(user);
});
您正在处理异步代码。有几种方法可以解决这个问题。
有一个承诺
// api.js
var Promise = require('bluebird');
var request = require('request');
var getP = Promise.promisify(request.get.bind(request));
exports.getUser = function(accessToken) {
return getP({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + accessToken},
json: true
}).spread(function(e, r, body) {
console.log("e: " + e + " body: %j", body);
if(e) {
return Promise.reject("{error: true}");
} else {
return Promise.resolve(body);
}
});
};
// main.js
api.getUser(req.user.accessToken)
.then(console.log.bind(console, "Result: "))
.catch(console.error.bind(console));
有回调
// api.js
var request = require('request');
exports.getUser = function(accessToken, callback) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + accessToken},
json: true
}, function(e, r, body) {
console.log("e: " + e + " body: %j", body);
if(e) {
callback("{error: true}");
} else {
callback(null, body);
}
});
};
// main.js
api.getUser(req.user.accessToken, function (err, result) {
if (err) return console.error(err);
console.log("Result: " + result);
});
promise API 的好处是您只需要在最终的 .catch
处理程序中检查一次错误。在回调样式中,如果您需要继续进行额外的异步调用,那么您必须继续嵌套回调并在每个回调中检查 if (err) return console.error(err)
。
我目前有一个从我的路由器调用的函数:
router.js:
var result = Api.getUser();
console.log("Result: " + result);
api.js
exports.getUser = function(req, result) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + req.user.accessToken},
json: true
}, function(e, r, body) {
console.log("e: " + e + " body: %j", body);
if(e) {
return "{error: true}";
} else {
return body;
}
});
};
我遇到的问题是我先获取日志 "Result: undefined"。
有没有办法阻止 getUser 函数返回,直到 get 函数完成?
Promises 很棒,我建议研究一下。然而,一个简单的回调就可以解决问题
api:
exports.getUser = function(req, result, callback) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + req.user.accessToken},
json: true
}, function(e, r, body) {
if(e) {
callback({error: true});
} else {
callback(body)
}
});
};
路由器:
var result
Api.getUser(req, result, function (response) {
result = response
console.log(result)
});
你不能从异步函数中 return
,你可以使用回调:
exports.getUser = function(req, result, callback) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + req.user.accessToken},
json: true
}, function(e, r, body) {
if(e) {
callback({error: true});
} else {
callback(body);
}
});
};
Api.getUser(req, result, function(user) {
console.log(user);
});
您正在处理异步代码。有几种方法可以解决这个问题。
有一个承诺
// api.js
var Promise = require('bluebird');
var request = require('request');
var getP = Promise.promisify(request.get.bind(request));
exports.getUser = function(accessToken) {
return getP({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + accessToken},
json: true
}).spread(function(e, r, body) {
console.log("e: " + e + " body: %j", body);
if(e) {
return Promise.reject("{error: true}");
} else {
return Promise.resolve(body);
}
});
};
// main.js
api.getUser(req.user.accessToken)
.then(console.log.bind(console, "Result: "))
.catch(console.error.bind(console));
有回调
// api.js
var request = require('request');
exports.getUser = function(accessToken, callback) {
request.get({
uri: URL + '/user/me/',
headers: {Authorization: 'bearer ' + accessToken},
json: true
}, function(e, r, body) {
console.log("e: " + e + " body: %j", body);
if(e) {
callback("{error: true}");
} else {
callback(null, body);
}
});
};
// main.js
api.getUser(req.user.accessToken, function (err, result) {
if (err) return console.error(err);
console.log("Result: " + result);
});
promise API 的好处是您只需要在最终的 .catch
处理程序中检查一次错误。在回调样式中,如果您需要继续进行额外的异步调用,那么您必须继续嵌套回调并在每个回调中检查 if (err) return console.error(err)
。