无法使用读/写流正确解析和重组二进制文件

Question

我正在尝试获取二进制文件的某些片段，然后将它们重新组合为压缩格式。然而，完成此任务后，二进制数据将以半随机顺序进行加扰。事实上，最初的大约15k字节是正确的，然后冲突在这之后不断发生。哪里出了问题？我相信这些流是彼此相遇的(因为没有更好的比喻)，所产生的字节长度是正确的。为什么会发生这种情况？我以为我对异步采取了足够的预防措施？

                 var destinationPath = something.bin;
                 Promise.all(sources.map(function (source) {
                    return new Promise(function (resolve, reject) {
                        var output = fs.createWriteStream(destinationPath, {'flags': 'a', 'bufferSize': 64 * 4096});
                        var input = fs.createReadStream(source.filePath, {
                            start: source.parameters.start,
                            end: source.parameters.end + 3
                        });
                        input.on('end', function () {
                            output.on('finish', function () {
                                resolve();
                            });
                        });
                        input.pipe(output);
                    });
                }));

Answer 1

不确定这是否有影响，但你有按顺序尝试吗？您可以在同一文件上同时创建多个写入流。

例如：

             var destinationPath = something.bin;
             var promise = Promise.resolve();
             sources.forEach(function (source) {
               promise = promise.then(funtion() {
                 return new Promise(function (resolve, reject) {
                    var output = fs.createWriteStream(destinationPath, {'flags': 'a', 'bufferSize': 64 * 4096});
                    var input = fs.createReadStream(source.filePath, {
                        start: source.parameters.start,
                        end: source.parameters.end + 3
                    });
                    input.on('end', function () {
                        output.on('finish', function () {
                            resolve();
                        });
                    });
                    input.pipe(output);
                });
              });
            });

            promise.then(function() {
              // we're done here
            });