我不知道循环何时结束，

app.post('/api/books', upload.array('images'), function(req, res) {
    let book = req.body.book;
    let arr = [];

    // GridFS get connection with DB   
    var gfs = gridfsstream(conn.db);
    var writestream;

    for (i = 0; i < req.files.length; i++) {
        writestream = gfs.createWriteStream({
            filename: req.files[i].originalname
        });
        fs.createReadStream('uploads/' + req.files[i].filename).pipe(writestream);
        writestream.on("close", function(file) {
            console.log(file.filename + "stored successfully into mongodb using gridfs");
        });
        writestream.on("error", function(file) {
            console.log(file.filename + "not stored into mongodb using gridfs");
        });

        base64(writestream.name, function(response) {
            arr.push(response);
        });
    }

    book.images = arr;
    Book.addBook(book, function(err, book) {
        if (err) {
            throw err;
        }
        res.json(book);
    });
});

问题是:我做的时候数组arr是空的

book.images = arr 

我需要等待 for 循环结束，但我该怎么做呢？

我知道这是可行的，因为我已经放置了一个 console.log() 并且可以正常工作

base64(writestream.name, function(response) {
    arr.push(response);
});

最佳答案

可能最好使用 Promise.all在这里，但是您需要将每个"file"包装在一个 Promise 中，并根据每个文件中的 writeStream 完成或出错的时间返回解析:

app.post('/api/books', upload.array('images'), function(req,res) {
  let book = req.body.book;
  var gfs = gridfsstream(conn.db);

  Promise.all(
    req.files.map(function(file) => {
      return new Promise(function(resolve,reject) {
        var writestream = gfs.createWriteStream({
          filename: file.originalname
        });

        fs.createReadStream('uploads/'+file.filename).pipe(writestream);

        writestream.on("error",reject);
        writestream.on("close",function() {
           base64(writestream.name, function(response) {
             resolve(response);
           });
        });

      })
    })
  )
  .then(function(images) {
    book.images = images;
    Book.addBook(book,function(err,book) {
      if (err) throw err; // or whatever
      res.json(book)
    });
  })
  .catch(function(err) => {
    // Deal with errors
  });
});

这不涉及额外的依赖项，但是您可以交替使用 async.map作为附加依赖项:

app.post('/api/books', upload.array('images'), function(req,res) {
  let book = req.body.book;
  var gfs = gridfsstream(conn.db);

   async.map(
     req.files,
     function(file,callback) {
        var writestream = gfs.createWriteStream({
          filename: file.originalname
        });

        fs.createReadStream('uploads/'+file.filename).pipe(writestream);

        writestream.on("error",callback);
        writestream.on("close",function() {
           base64(writestream.name, function(response) {
             callback(null,response);
           });
        });                      
     },
     function(err,images) {
       if (err) throw err;

       book.images = images;
       Book.addBook(book,function(err,book) {
         if (err) throw err; // or whatever
         res.json(book)
       });
     }
   );
});

所以他们看起来很相似，基本上他们在做同样的事情。在每种情况下，“循环”现在都是 .map()它将当前文件名作为参数传递并返回转换后的响应数组，在本例中是 base64 函数的输出。它们的关键是 resolve 或 callback 基本上控制事情何时发生。

在使用 Promise.all 的情况下, .map()是基本的 JavaScript .map()数组上的函数，它实际上返回一个“Promise 数组”，它们都实现了 reject 和 resolve 函数，然后由流中的相应处理程序调用.

这里的“ promise ”全部执行并在 Promise.all 内返回结果并使用 .then() 将输出数组传递给 block ，其中包含内容，然后可以传递给您的方法以根据情况进行更新/创建。

在async.map例如，这反而使用了一个 callback 参数，它再次提供给流上的事件处理程序。以完全相同的方式，最后一个 block 接收输出或错误，并可以再次传递给您的方法以保留数据。

调用的实际执行略有不同，但两者本质上都应用了相同的原则，即我们向提供“循环”的机制“发出”输出已完成的“信号”，以便我们知道“所有”何时完成。

关于javascript - 如何在保存之前等待创建流的循环完成？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44856929/