如果抛出错误，如何重新启动 async.waterfall

Question

我正在node.js中构建一个Twitter机器人游戏。我有一个脚本，它有一个同步函数（streamOn打开Twitter流），然后是一个具有HTTP GET请求函数（getImage）的async.waterfall。 getImage有时会在触发脚本时返回 301 响应。streamOn继续保持打开状态，但玩家不知道错误，只是没有返回任何图像。

如果async.waterfall抛出错误，如何让从其步骤的开头"重试"，以便玩家仍然获得图像？

这是async.waterfall：

streamOn(function(tweet) {
  async.waterfall([
    getName,
    searchImage,
    getImage,
    postTweet.bind(null, tweet)
  ],
  function(error, result) {
    if (error) {
      console.error(error);
      return;
    }
    console.log(result);
  });
}

以下是getImage函数的简化版本：

function getImage() {
    var http=require('http'), imageBuffer;
    http.get(
      'http://www.kame.net/img/kame-anime-small.gif',
      function(res) {
        var body=new Buffer(0);
        if (res.statusCode!==200) {
          return console.error('HTTP '+res.statusCode);
        }
        res.on('data', function(chunk) {
          body=Buffer.concat([body, chunk]);
        });
        res.on('end', function() {
          imageBuffer=body;
        });
        res.on('error', function(err) {
          console.error(err);
        });
      }
    );
}

Answer 1

这就是

我想象的样子。我在回调中添加了调用，因为异步需要它才能继续。

请注意，您可能会进入重定向循环，我不确定.headers是否是响应的正确属性。

function getImage(url, callback) {
    var http=require('http'), imageBuffer;
    http.get(
      url,
      function(res) {
        var body=new Buffer(0);
        if (res.statusCode!==200) {
            if (res.statusCode === 301) {
                getImage(res.headers["Location"], callback) //I'm  not sure if .headers is correct
                return;
            }
            console.error('HTTP '+res.statusCode);
            callback(new Error('HTTP '+res.statusCode)) //Might want a better error
        }
        res.on('data', function(chunk) {
          body=Buffer.concat([body, chunk]);
        });
        res.on('end', function() {
          imageBuffer=body;
          callback(null, imageBuffer)
        });
        res.on('error', function(err) {
          console.error(err);
          callback(err);
        });
      }
    );
}