函数在异步方法完成之前返回 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)