nodejs 异步到同步

Question

我是 nodejs 的新手，javascript 我目前正在做一个开源项目，因为昨晚我试图将这个函数从异步转换为同步，但我做不到，我使用了 async / await 但我认为我不太了解这个概念，这个函数使用 aes256 算法加密和压缩文件，我异步工作得很好但我想添加这个允许你加密目录内容的新功能递归地。

function encrypt({ file, password }, error_callback, succ_callback) {
    const initVect = crypto.randomBytes(16);

    // Generate a cipher key from the password.
    const CIPHER_KEY = crypto.createHash('sha256').update(password).digest();;
    const readStream = fs.createReadStream(file);
    const gzip = zlib.createGzip();
    const cipher = crypto.createCipheriv('aes-256-cbc', CIPHER_KEY, initVect);
    const appendInitVect = new AppendInitVect(initVect);
    // Create a write stream with a different file extension.
    const writeStream = fs.createWriteStream(path.join(file + ".dnc"));

    readStream
      .pipe(gzip)
      .pipe(cipher)
      .pipe(appendInitVect)
      .pipe(writeStream);

    readStream.on('error', error_callback);
    readStream.on('end', succ_callback);
}

Answer 1

您不必同步加密文件，您也可以异步加密。要遍历目录并获取其文件，请递归使用 fs.readdir 直到找不到更多文件，然后您可以运行 encrypt 在每个找到的文件上。

Answer 2

尝试使用承诺。通过稍微更改代码，您可以承诺该功能，然后等待所有承诺解决或拒绝，然后再采取行动。

function encrypt({ file, password }) {
  const initVect = crypto.randomBytes(16);

// Generate a cipher key from the password.
  const CIPHER_KEY = crypto.createHash('sha256').update(password).digest();;
  const readStream = fs.createReadStream(file);
  const gzip = zlib.createGzip();
  const cipher = crypto.createCipheriv('aes-256-cbc', CIPHER_KEY, initVect);
  const appendInitVect = new AppendInitVect(initVect);
// Create a write stream with a different file extension.
  const writeStream = fs.createWriteStream(path.join(file + ".dnc"));

  readStream
    .pipe(gzip)
    .pipe(cipher)
    .pipe(appendInitVect)
    .pipe(writeStream);


  const promise = new Promise();
  writeStream.on('error', err => promise.reject(err));
  writeStream.on('end', data => promise.resolve(data));
  return promise;
}

const promise1 = encrypt({file1, password1});
const promise2 = encrypt({file2, password2});

Promise.all([promise1, promise2])
  .then(succ_callback)
  .catch(error_callback);

我没有运行此代码，因此可能需要进行一些调整才能使其正常工作，但这是一般要点。

nodejs 异步到同步

nodejs asynchronous to synchronous

javascript

node.js

asynchronous

synchronous