我的代码类似于下面的精简示例
const req = request('http://www.my.url.here.com/file.bin') // 80 MB file
const decripher = .... // decipher from nodejs's crypto module
const output = fs.createWriteStream('result.zip');
const archive = archiver('zip', {zlib: { level: 9 } });
archive.pipe(output);
const stream = req
.pipe(decipher)
.on('error', (error) => {
console.error(`Error deciphering file`)
req.abort() // Does nothing
decipher.unpipe() // Unpiping to prevent the next step producing a [ERR_STREAM_WRITE_AFTER_END] error
stream.end() // End the stream as an error does not end it automatically
})
archive.append(stream, { name: 'file.bin' });一旦解密文件出现错误,我就不想再下载任何数据了。但我注意到,在这些场景中,req.abort()什么也不做。
最后,我在归档中有一个部分解密的文件,但它仍然是~80MB。也就是说,尽管出现了错误(我将其设置为在文件开头附近触发),整个文件还是被下载了。
为什么会发生这种情况?如何防止下载整个文件?
发布于 2019-07-23 00:56:22
您可以销毁基础套接字。您可以在socket或response事件中获取套接字。
const req = request(options);
req.on('response', function(response) {
....
res.socket.end(); // or res.socket.destroy();
....
});
req.pipe(...);也许在你的情况下,稍微修改一下,这基本上是一个理论,但你可以这样做:
const req = request(options);
let sock = null;
req.on('socket', function(socket) {
sock = socket;
}).on('error', ()=>{
sock.destroy()//or end();
});
req.pipe(...);https://stackoverflow.com/questions/57150217
复制相似问题