模块的地址在这里https://github.com/request/request 问题是这样的,我写了一个zol壁纸下载器,使用async来控制并发,然后通过监听request的error response 和end的事件来控制下载的过程 我通过在end事件里调用callback()来通知async图片已经下载好了,并使用pipe()方法来把图片存到本地 通过在error事件里调用callback()来通知async下载过程已经结束 问题在与,在出现网络错误的时候,会依次触发error事件和end事件,导致callback()会被重复调用,这个问题该怎么办呢

部分代码在这里

function downloadImgs(callback, result) {
    if (!fs.existsSync('download_pictures/')) {
        fs.mkdirSync('download_pictures');
    }
    var img_urls = result['get_img_urls'];
    var index = 0;
    console.log('正在下载壁纸....');
    async.eachLimit(img_urls, 5, function (item, callback) {
        var request_stream = request({
            url: item,
            timeout: 5000,
            headers: {
                'User-Agent': 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:39.0) Gecko/20100101 Firefox/39.0'
            }
        });
        request_stream.on('error', function (error) {
            console.log('downloadImgs| 下载 ' + item  + '失败| Error: ' + error);
            callback();
        });
        request_stream.on('response', function (response) {
            // 我也不知道有时候response为啥会为空,所以为了避免出现response为空的情况
            // 我使用了事件监听的方式来处理数据
            if (response.statusCode === 404) {
                console.log('downloadImgs| 无效的下载地址 ' + item);
                callback();
            } else {
                request_stream.pipe(fs.createWriteStream('download_pictures/number.jpg'.replace(/number/, index +'')));
                index++;
                // 通过设置end事件监听器,通知async已经完成了pipe方法
            }
        });
        request_stream.on('end', function () {
            callback();
        });
    }, function (error) {
        console.log('所有壁纸下载完毕,请查看download_pictures文件夹');
    })
}