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!');});...