首先是没有加入请求超时的情况:

var http = require(\'http\');
var url = require(\'url\');

function get(addr) {  
  return new Promise(function(resolve, reject) {
    var url_obj = url.parse(addr);
    var options = {
      hostname: url_obj.hostname,
      path: url_obj.path,
      method: \'GET\'
    };

    var req = http.request(options, function(res) {
      res.setEncoding(\'utf8\');

      var data = \'\';
      res.on(\'data\', function (chunk) {
        data += chunk;
      });
      res.on(\'end\', function () {
        data = JSON.parse(data);
        resolve(data);
      });
    });

    req.on(\'error\', function(e) {
      reject(e)
    });
    req.end();
  });
}

get(\'http://demos.so/result/homework.promise.userInfo\').then(function (args) {
  return Promise.all([get(\'http://demos.so/result/userid=\' + args[\'_id\']), get(\'http://demos.so/result/student=\' + args[\'_id\'])]);
}).then(function (args) {
  console.log(args);
}).catch(function(err){
  console.log(err);
});

 

再看一下加入超时的代码:

var http = require(\'http\');
var url = require(\'url\');

function delayPromise(ms) {
    return new Promise(function (resolve) {
        setTimeout(resolve, ms);
    });
}
function timeoutPromise(promise, ms) {
    var timeout = delayPromise(ms).then(function () {
            throw new Error(\'Operation timed out after \' + ms + \' ms\');
        });
    return Promise.race([promise, timeout]);
}

function get(addr) {  
  return new Promise(function(resolve, reject) {
    var url_obj = url.parse(addr);
    var options = {
      hostname: url_obj.hostname,
      path: url_obj.path,
      method: \'GET\'
    };

    var req = http.request(options, function(res) {
      res.setEncoding(\'utf8\');

      var data = \'\';
      res.on(\'data\', function (chunk) {
        data += chunk;
      });
      res.on(\'end\', function () {
        data = JSON.parse(data);
        resolve(data);
      });
    });

    req.on(\'error\', function(e) {
      reject(e)
    });
    req.end();
  });
}


timeoutPromise(get(\'http://demos.so/result/homework.promise.userInfo\'),1000).catch(function (err) {
  console.log(err);
}).then(function (args) {
  return Promise.all([timeoutPromise(get(\'http://demos.so/result/userid=\' + args[\'_id\']), 1000), timeoutPromise(get(\'http://demos.so/result/student=\' + args[\'_id\']), 1000)]);
}).then(function (args) {
  console.log(args);
}).catch(function (err) {
  console.log(err);
});

  原理其实很简单,就是利用Promise.race,我们先创建一个Promise,里面用setTimeout进行处理,然后将新创建的Promise与我们之前使用的Promise”比赛”一下。

版权声明:本文为shytong原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/shytong/p/5681568.html