下载具有流的大型文件时发生的Axios事件
提问于 2019-01-21 10:44:36
我在服务器端上使用axios。
我想下载大文件..。从技术上讲，这应该与字节范围一起使用。
- axios是否处理字节范围请求，以便只有在所有响应准备就绪时才调用回调函数？
- 如果1不是真，我应该自己处理数据块吗？
在以下守则中：
axios({
url: params.url,
method: 'GET',
responseType: 'stream' // important
}).then(function (response) {
logger.debug('__download() : done!')
let contentType = response.headers['content-type']
let contentLength = response.headers['content-length']
var writer = new streams.WritableStream()
response.data.pipe(writer)
// ....
})我是否应该等待类似response.on('end')之类的东西？
我所做的工作的目的是获取缓冲区的大小(可以通过writer.getBuffer()获得)
谢谢你的暗示！
回答 1
Stack Overflow用户
回答已采纳
发布于 2019-01-21 12:07:32
我发现要下载这个流，in memory在我的例子中，我不得不等待我的作者的事件(writer.on('finished'，cb) vs response.on('end'，cb )) (不确定是否有类似response.on(‘end’)的东西).
var stream = require('stream');
var util = require('util');
var Writable = stream.Writable;
function MemoryStream(options) {
if (!(this instanceof MemoryStream)) {
return new MemoryStream(options);
}
Writable.call(this, options); // init super
}
util.inherits(MemoryStream, Writable);
MemoryStream.prototype._write = function (chunk, enc, cb) {
var buffer = (Buffer.isBuffer(chunk)) ?
chunk :
Buffer.alloc(chunk, enc);
if (Buffer.isBuffer(this.memStore)) {
this.memStore = Buffer.concat([this.memStore, buffer]);
} else {
this.memStore = buffer
}
cb();
};
MemoryStream.prototype.toBuffer = function () {
return this.memStore
};
module.exports = MemoryStream然后在我的下载功能中：
axios({
url: params.url,
method: 'GET',
responseType: 'stream' // important
}).then(function (response) {
logger.debug('__download() : done!')
let contentType = response.headers['content-type']
let contentLength = response.headers['content-length']
var writer = new MemoryStream()
response.data.pipe(writer)
writer.on('finish', function () {
var b = writer.toBuffer()
let computedContentLength = b.byteLength
if (!contentLength) { contentLength = computedContentLength }
return callback(null, { 'foo':'bar'})
});
})页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/54296085
复制
腾讯云开发者
