ForEach 异步 js 仍未解决

Question

我仍然无法掌握如何解决这个问题。我尝试了How do I add a delay in a JavaScript loop? 中给出的解决方案，据说这些解决方案可以解决我的问题，但它们对我没有用。

要么我得到我尝试过的相同的东西（一个运行一次但不能解决我的问题的等待功能）。或者在运行脚本时，脚本在 cli 和我希望将结果写入的 Result.txt 文件中都没有输出。

var path = require('path');
var fs = require('fs');
var VirusTotalApi = require("virustotal-api");
var virusTotal = new VirusTotalApi('<YOUR API KEY>');

fs.readdir('/home/username/Desktop/TEST/', function (err,files) {
  if (err) {
    return console.log('Unable to scan directory: ' +err);
  }

  files.forEach(function (file) {
    var directoryPath = path.join('/home/username/Desktop/TEST/', file);

    fs.readFile(directoryPath, (err, data) => {
      if (err) {
        console.log(`Cannot read file. ${err}`);
      } else {
        console.log(file);
        virusTotal
        .fileScan(data, `${file}`)
        .then(response => {
          let resource = response.resource;
      virusTotal.fileReport(resource).then(result => {
            fs.writeFile('Result.txt', `${file}: ` + JSON.stringify(result, ["verbose_msg","total","positives"]) + '\n', function (err) {
              if (err) throw err;
              if(!err) {
                console.log(`${file}: Saved!`);
              }
            }); 
          });
        })
        .catch(err => console.log(`Scan failed. ${err}`));
        if(!err) {
          console.log('Scan succesful');
        }
      }
    });
  });
});

再一次，我需要一个等待 20 秒的 ForEach 循环，然后运行所需的代码。在进入下一个 for 条件之前，它还需要等待。

Answer 1

插入暂停并不能解决异步问题，也不能暂停 .forEach() 循环。相反，您需要编写能够让您控制异步操作​​的顺序和完成的异步代码类型。

对所有异步操作使用 Promise 并避免诸如 .forEach() 之类的非异步感知循环结构将使这更容易。这是处理它的一种方法：

const path = require('path');
const fsp = require('fs').promises;
const VirusTotalApi = require("virustotal-api");
const virusTotal = new VirusTotalApi('<YOUR API KEY>');

const basePath = '/home/username/Desktop/TEST/';

async function scan() {
    const files = await fsp.readdir(basePath);
    let errors = [];
    for (let file of files) {
        const fullPath = path.join(basePath, file);
        try {
            const data = await fsp.readFile(fullPath);
            const response = await virusTotal.fileScan(data, file);
            const resource = response.resource;
            const result = await virusTotal.fileReport(resource);
            const resultLine = `${file}: ${JSON.stringify(result)}\n`;
            await fsp.appendFile('Result.txt', resultLine);
        } catch (e) {
            // collect the error, log the error and continue the loop
            e.fullPath = fullPath;
            errors.push(e);
            console.log(`Error processing ${fullPath}`, e);
            continue;
        }
    }
    // if there was an error, then reject with all the errors we got
    if (errors.length) {
        let e = new Error("Problems scanning files");
        e.allErrors = errors;
        throw e;
    }
}

scan().then(() => {
    console.log("all done scanning - no errors");
}).catch(err => {
    console.log(err);
});

另外，在您使用 fs.writeFile('Result.txt', ...) 的地方，我将其更改为使用 .appendFile()，因为您似乎想要累积结果日志，而不是每次都覆盖所有以前的结果。

Answer 2

基于https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Array/forEach

正如我所见，使用 forEach 函数在每次回调调用之间等待 20 秒是不可能的。 forEach 不适用于 Promises，因此无法在其中等待。

有一个解决方案，它使用 for 循环和异步容器。

var path = require('path');
var fs = require('fs');
var VirusTotalApi = require("virustotal-api");
var virusTotal = new VirusTotalApi('<YOUR API KEY>');

const wait = (time) => new Promise((resolve) => setTimeout(resolve, time))

fs.readdir('/home/username/Desktop/TEST/', async function (err,files) {
  if (err) {
    return console.log('Unable to scan directory: ' +err);
  }

  for (let file of files) {
    var directoryPath = path.join('/home/username/Desktop/TEST/', file);

    fs.readFile(directoryPath, (err, data) => {
      if (err) {
        console.log(`Cannot read file. ${err}`);
      } else {
        console.log(file);
        virusTotal
        .fileScan(data, `${file}`)
        .then(response => {
          let resource = response.resource;
      virusTotal.fileReport(resource).then(result => {
            fs.writeFile('Result.txt', `${file}: ` + JSON.stringify(result, ["verbose_msg","total","positives"]) + '\n', function (err) {
              if (err) throw err;
              if(!err) {
                console.log(`${file}: Saved!`);
              }
            }); 
          });
        })
        .catch(err => console.log(`Scan failed. ${err}`));
        if(!err) {
          console.log('Scan succesful');
        }
      }
    });

    // Wait for 20 seconds
    await wait(20 * 1000)
  }
});