Q 承诺链接以正确的顺序做事

Question

我有一个异步函数需要以正确的顺序调用多次。这是关于将图像上传到服务器，但就像我说的那样，图像应该以正确的顺序上传。

我的函数如下所示：

  function uploadImage(sku,fileName) {
    console.log("Uploading image for sku="+sku+", imageName="+fileName);

    var deferred = Q.defer();

    var readStream = fs.createReadStream(rootPath+'/data/'+sku+"/"+fileName);
    var req = request.post('http://localhost:3000/'+sku+'/upload/'+fileName);

    readStream.pipe(req);

    req.on('end', function() {
      console.log("Image imageName="+fileName+" uploaded successfully.");
      db.updateLastUploadedImage(sku,fileName).then(function (res) {
        if(res) {
          console.log("Table watches for sku="+sku+" updated.");
          deferred.resolve(sku);
        }
      });
    });

    req.on('error',function(err) {
      deferred.reject(err);
    });

    return deferred.promise;
  }

我试图通过链接 https://github.com/kriskowal/q 中记录的承诺来实现它，但效果不佳。不知何故，我没有来到 "then" 街区。

所以我尝试创建一个递归函数，但它也没有进入函数调用的 "then" 块。

只有此方法有效，但运行以正确的顺序无效。

function uploadImages(sku) {
    var promises = [];

    for(var x=0; x<10; x++) {
      promises.push(uploadImage(sku,(x+1)+".jpg")));
    }

    return Q.all(promises).then(function (res) {
      return sku;
    });
}

我的递归解决方案如下所示：

function uploadImages(sku,current,max) {
    var deferred = Q.defer();

    if(current<=max) {
      uploadImage(sku,current+'.jpg').then(function (res) {
        if(res) {
          uploadImages(sku,current+1,max);
        }
      }, function (err) {
        deferred.reject();
      });
    } else {
      deferred.resolve(sku);
    }

    return deferred.promise;
 }

我正在寻找的是这样的东西（但这不是实现的方式）：

 return uploadImage(sku,"1.jpg").then(function(res) {
      return uploadImage(sku,"2.jpg").then(function(res) {
        return uploadImage(sku,"3.jpg").then(function(res) {
          return uploadImage(sku,"4.jpg").then(function(res) {
            return uploadImage(sku,"5.jpg").then(function(res) {
              return uploadImage(sku,"6.jpg").then(function(res) {
                return uploadImage(sku,"7.jpg").then(function(res) {
                  return uploadImage(sku,"8.jpg").then(function(res) {
                    return uploadImage(sku,"9.jpg").then(function(res) {
                      return uploadImage(sku,"10.jpg").then(function(res) {
                        return sku;
                      });
                    });
                  });
                });
              });
            });
          });
        });
      });
    });

那么对我来说最好的做法是什么？

Answer 1

异步调用没有 "correct order" 的概念，因为它们就是异步调用，它们可以在任何时候结束。

在您 Q.all(promises).then(...) 的回调中，您应该按照您做出响应的顺序获得响应，但控制台日志的顺序 可能不会 由于异步性质，顺序相同。

在你的情况下，你可以递归地做：

function uploadFiles(sku, current, max) {
     return uploadImage(sku, current + '.jpg').then(function (sku) {
          if (current > max) { return sku; }

          return uploadFiles(sku, current + 1, max);
     });
}

// use it
uploadFiles('SOME_SKU', 1, 10).then(function (sku) {
    // ALL DONE!
});

Answer 2

尝试捕获 promise 中的异常。

return Q.all(promises).then(function (res) {
  return sku;
})
.catch(function (error) {
    // Handle any error from all above steps
});

Q 承诺链接以正确的顺序做事

Q promises chaining to do things in correct order

javascript

node.js

promise

q