我在尝试解决NodeJS中的一个问题时偶然发现了这个页面:重新组装文件块。基本上: 我有一个文件名数组。 我需要以正确的顺序追加所有这些文件，以创建一个大文件。 我必须异步地做到这一点。

节点的'fs'模块确实提供了appendFileSync，但我不想在此操作期间阻塞服务器。我想用fs。承诺模块，并找到一种方法将这些东西链接在一起。本页上的示例并不适合我，因为我实际上需要两个操作:fsPromises.read()用于读取文件块，fsPromises.appendFile()用于连接到目标文件。也许如果我是更好的JavaScript，我可以使以前的答案为我工作。: -)

我偶然发现了这个，然后我拼凑出了一个可行的解决方案:

/**
 * sequentially append a list of files into a specified destination file
 */
exports.append_files = function (destinationFile, arrayOfFilenames) {
    return arrayOfFilenames.reduce((previousPromise, currentFile) => {
        return previousPromise.then(() => {
            return fsPromises.readFile(currentFile).then(fileContents => {
                return fsPromises.appendFile(destinationFile, fileContents);
            });
        });
    }, Promise.resolve());
};

这里有一个jasmine单元测试:

const fsPromises = require('fs').promises;
const fsUtils = require( ... );
const TEMPDIR = 'temp';

describe("test append_files", function() {
    it('append_files should work', async function(done) {
        try {
            // setup: create some files
            await fsPromises.mkdir(TEMPDIR);
            await fsPromises.writeFile(path.join(TEMPDIR, '1'), 'one');
            await fsPromises.writeFile(path.join(TEMPDIR, '2'), 'two');
            await fsPromises.writeFile(path.join(TEMPDIR, '3'), 'three');
            await fsPromises.writeFile(path.join(TEMPDIR, '4'), 'four');
            await fsPromises.writeFile(path.join(TEMPDIR, '5'), 'five');

            const filenameArray = [];
            for (var i=1; i < 6; i++) {
                filenameArray.push(path.join(TEMPDIR, i.toString()));
            }

            const DESTFILE = path.join(TEMPDIR, 'final');
            await fsUtils.append_files(DESTFILE, filenameArray);

            // confirm "final" file exists    
            const fsStat = await fsPromises.stat(DESTFILE);
            expect(fsStat.isFile()).toBeTruthy();

            // confirm content of the "final" file
            const expectedContent = new Buffer('onetwothreefourfive', 'utf8');
            var fileContents = await fsPromises.readFile(DESTFILE);
            expect(fileContents).toEqual(expectedContent);

            done();
        }
        catch (err) {
            fail(err);
        }
        finally {
        }
    });
});

Bergi的回答让我使用Array.reduce走上了正确的轨道。

然而，为了让函数一个接一个地返回我的承诺，我必须添加更多的嵌套。

我真正的用例是一个文件数组，由于下游的限制，我需要按顺序一个接一个地传输…

这是我最后得出的结论:

getAllFiles().then( (files) => {
    return files.reduce((p, theFile) => {
        return p.then(() => {
            return transferFile(theFile); //function returns a promise
        });
    }, Promise.resolve()).then(()=>{
        console.log("All files transferred");
    });
}).catch((error)=>{
    console.log(error);
});

如前面的回答所示，使用:

getAllFiles().then( (files) => {
    return files.reduce((p, theFile) => {
        return p.then(transferFile(theFile));
    }, Promise.resolve()).then(()=>{
        console.log("All files transferred");
    });
}).catch((error)=>{
    console.log(error);
});

没有等到传输完成才开始另一个，而且“所有文件传输”的文本甚至在第一个文件传输开始之前就出现了。

不知道我做错了什么，但想分享对我有用的东西。

编辑:自从我写了这篇文章，我现在明白为什么第一个版本不起作用了。Then()期望函数返回一个promise。因此，您应该传入不带括号的函数名!现在，我的函数需要一个参数，所以我需要封装在一个匿名函数中，不带参数!

并行

await Promise.all(items.map(async (item) => { 
  await fetchItem(item) 
}))

优点:速度更快。所有的迭代都将启动，即使其中一个在以后失败。然而，它会“快速失败”。使用的承诺。allsettle，即使某些迭代失败，也要并行地完成所有迭代。从技术上讲，这些是并发调用，而不是并行调用。

按顺序

for (const item of items) {
  await fetchItem(item)
}

优点:循环中的变量可以在每次迭代中共享。行为类似于普通的命令式同步代码。

使用async await可以很容易地按顺序执行promise数组:

let a = [promise1, promise2, promise3];

async function func() {
  for(let i=0; i<a.length; i++){
    await a[i]();
  }  
}

func();

注意:在上述实现中，如果一个承诺被拒绝，其余的承诺将不会被执行。如果你想要所有的承诺都被执行，那么将await a[i]();内部尝试捕获

Bergi的回答帮助我使电话同步。我在下面添加了一个例子，我们在前面的函数被调用之后调用每个函数:

function func1 (param1) {
    console.log("function1 : " + param1);
}
function func2 () {
    console.log("function2");
}
function func3 (param2, param3) {
    console.log("function3 : " + param2 + ", " + param3);
}

function func4 (param4) {
    console.log("function4 : " + param4);
}
param4 = "Kate";

//adding 3 functions to array

a=[
    ()=>func1("Hi"),
    ()=>func2(),
    ()=>func3("Lindsay",param4)
  ];

//adding 4th function

a.push(()=>func4("dad"));

//below does func1().then(func2).then(func3).then(func4)

a.reduce((p, fn) => p.then(fn), Promise.resolve());

平行

请看这个例子

const resolveAfterTimeout = async i => {
  return new Promise(resolve => {
    console.log("CALLED");
    setTimeout(() => {
      resolve("RESOLVED", i);
    }, 5000);
  });
};

const call = async () => {
  const res = await Promise.all([
    resolveAfterTimeout(1),
    resolveAfterTimeout(2),
    resolveAfterTimeout(3),
    resolveAfterTimeout(4),
    resolveAfterTimeout(5),
    resolveAfterTimeout(6)
  ]);
  console.log({ res });
};

call();

通过运行代码，它将控制台“CALLED”为所有六个承诺，当他们被解决，它将控制台每6个响应超时后，在同一时间