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

Unable to correctly parse and reassemble binary file using read/writestreams

本文关键字：二进制文件 新组装      更新时间：2023-09-26

我正在尝试获取二进制文件的某些段，然后将它们重新组合为压缩格式。然而，在完成该任务时，二进制数据以半随机顺序进行加扰。事实上，最初大约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);
                    });
                }));

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

例如：

             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
            });
相关文章：