我有一个关于缓冲区的问题。这是我的代码:
var Grid = require('gridfs-stream');
var mongodb = require('mongodb');
var gfs = Grid(db, mongodb);
var deferred = Q.defer();
var image_buf = new Buffer('buffer');
var readableStream = gfs.createReadStream(name);
readableStream.on('data',function(chunk){
console.log(chunk);
image_buf = Buffer.concat([image_buf, chunk]);
console.log(image_buf)//differ from the chunk above
});
readableStream.on('end',function(){
db.close();
deferred.resolve(image_buf);
})
return deferred.promise;
我正在做的是从 MongoDB 读取图像并将其放入 gridfs-stream 中。我真的想检索流中的所有块并将它们传递给另一个变量,以便我可以重用这些块在另一个 API 中绘制图像。因此我使用 image_buf 和 Buffer 来执行任务。但是,我得到了一个完全不同的缓冲区字符串。正如你在上面的代码中看到的,我安慰了我得到的 chunk 和 image_buf,但它们是完全不同的。谁能告诉我这样做的原因以及如何正确收集所有块?多谢!!!
更新:好的,所以我现在想通了:我将在下面附加我的代码,供任何遇到与我相同问题的人使用:
readableStream.on('data',function(chunk){
console.log("writing!!!");
if (!image_buf)
image_buf = chunk;
else image_buf = Buffer.concat([image_buf, chunk]);
});
问题发布者提供的更新不起作用。所以我将提供我自己的答案。而不是使用new Buffer('buffer')
最好使用一个简单的数组并将块推入其中并使用Buffer.concat(bufferArray)
最后获取流的缓冲区,如下所示:
var readableStream = gfs.createReadStream(name);
var bufferArray = [];
readableStream.on('data',function(chunk){
bufferArray.push(chunk);
});
readableStream.on('end',function(){
var buffer = Buffer.concat(bufferArray);
deferred.resolve(buffer);
})
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)