Node JS/Gzip：图像文件下载提前结束且没有错误

Question

我正在 Node.js 中创建一个应用程序来下载图像文件。但是，我遇到了一个问题，如果我的下载速度很慢或失去连接，我正在下载的图像将被截断。如果我的程序抛出一个错误警告我图像没有完成下载，这不会那么糟糕，但是，它并没有像图像下载成功一样解析。我在下载后检查响应代码或探测图像时没有收到错误消息。这是我用来下载图像的当前代码。const fs = require('fs-extra');const request = require('request');var probe = require('probe-image-size');var progress = require('request-progress');var filename = 'C:/Users/User/Desktop/myimage.jpg';var req = request(createRequestHeaders('www.linktomyimage.com/image.jpg'));downloadImage(req, filename)function createRequestHeaders(url) {    var cookie = `userid=${userid}; phash=${phash};`;    return {        'url': url,        'method': 'GET',        'gzip': true,        'headers': {            'Referer': `https://${website}/`,            'Cookie': cookie        }    };}function downloadImage(req, filename) {    return new Promise((resolve, reject) => {        var response = null;        var bytes;        var dirname = path.dirname(filename);        if (!fs.existsSync(dirname)) fs.ensureDirSync(dirname);        progress(req, { delay: 0 }).on('progress', function (state) {            updateDownloadSpeed(state.speed);        }).on('end', function () {            if (response.statusCode == 200) {                var input = require('fs').createReadStream(filename);                probe(input).then(result => {                    input.destroy();                    if (result != null) {                        resolve({bytes: bytes, width: result.width,                                height: result.height,});                    } else {                        // The image size probe does not detect if the download was truncated                        reject({ 'name': 'ImageMissingOrCorrupt');                    }                }).catch((error) => {                    reject(error);                });            } 我在这里问了这个问题的早期版本，但在实施了答案中的建议后，我的下载器仍然存在相同的问题。从那时起，我的下载器的代码也发生了变化。如何检测图像何时被截断，以便指示下载器重新尝试下载？

Answer 1

使用数据事件，我可以跟踪收到的字节数，并检查它是否等于触发结束事件时标头中的字节数。

var bytesRecieved = 0;

var bytes = -1;

...

bytes = response.headers['content-length'];

.on('response', function (resp) {

    bytes = response.headers['content-length']

}).on('data', function (chunk) {

    bytesRecieved += chunk.length;

}).on('end', function () {

    if (bytes !== bytesRecieved) reject('Error!');

});

...