我正在尝试使用 Kraken 框架创建在 NodeJS 中使用 HTTP 请求的 promise 函数链。

我的代码可以在 90% 的情况下工作,但如果远程请求的服务器需要时间来响应,代码将返回一个带有未定义值的错误。所以我认为 Q 是一个很好的解决方案来防止这种情况。

这是情况:

我们使用“代码”参数访问 URL -> 路由 Controller 使用此参数在 HTTP POST 请求中使用它 -> 响应( token )存储在变量中并用于其他 HTTP GET 请求 ->响应(多个 JSON 对象)也存储在变量中 -> 所有变量都存储在 MongoDB 中。
如果函数没有按照这个顺序使用,当然会失败。

var Q = require('q');

module.exports = function (router) {
  router.get('/', function (req, res) {
    var codein = req.param('code');
    if(codein){
        console.log('Provided code: ' + codein+'\n');
        getAccessToken(codein).then(function(token){
            console.log('Provided AccessToken: ' + token + '\n');
            getUsername(token).then(function(userdata){
                console.log('Provided Username: ' + JSON.parse(userdata).username + '\n');
                storeData(userdata).then(function(msg){
                    console.log(msg);
                    res.redirect('/dashboard/' + JSON.parse(userdata).username);
                });
            });
        });

    }
    else{
        console.log('Access Denied, redirecting...');
        res.redirect('/');
    }
  });
};

这种方法有效,但实际上并没有解决问题,因为有时变量再次未定义。我认为这是我的请求功能做得不好......

这是带有 POST 请求的第一个函数的示例:
var getAccessToken = function(cod){
    var def = Q.defer();
    var data = querystring.stringify({
            client_id:"1234567890",
            client_secret:"******",
            grant_type:"authorization_code",
            redirect_uri:"http://localhost:8000/r/callback",
            code:cod
    });

    var options = {
        host: 'domain.server.com',
        port: 443,
        path: '/api/oauth2/token',
        method: 'POST',
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded',
            'Content-Length': Buffer.byteLength(data)
        }
    };

    var response = "";

    var req = https.request(options, function(res) {
        res.setEncoding('utf8');
        res.on('data', function (chunk) {
            response += chunk;
        });

        res.on('end', function(){
            var json = JSON.parse(response);
            var acto = json.access_token;
            def.resolve(acto);

        });
    });

    req.write(data);
    req.end();
    return def.promise;

};

在这种情况下,acto 变量可能是未定义的......那么我是否以错误的方式使用 Q ?

编辑

为了理解我的问题,让我向您展示我的输出控制台中可以有什么(非常罕见但会发生):
Provided code: 12345678910

Provided Username: user543210

代替 :
Provided code: 12345678910

Provided AccessToken: 9876543210

Provided Username: user

最佳答案

我认为您需要考虑两种情况

  • Twitch API 需要时间来响应的地方。
  • 无法解析 Twitch 响应

  • 编码
        res.on('end', function(){
            var json = JSON.parse(response);
            var acto = json.access_token;
            def.resolve(acto);
        });
    

    应修改为:
        try {
           var json = JSON.parse(response);
           var acto = json.access_token;
           //check if acto is undefined
           if (acto === undefined) {
             def.reject('Some error message');
           } else {
             def.resolve(acto);
           }
        } catch (error) {
          //since the JSON could not be parse
          def.reject(error);
        }
    

    关于node.js - 在 NodeJs 的 HTTP 请求中使用 Q promise ,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/25132205/

    10-12 12:25
    查看更多