关于Stream和Buffer的相互转换详解
前言
最近在工作的时候突然就有了这样一个需求,这一次正好也对本来不太熟的Stream有了一点更加深刻的理解……(好吧本来是根本没搞清楚状况)。本文将给大家详细介绍关于Stream和Buffer相互转换的相关资料,下面话不多说,来一起看看详细的介绍吧。
方法如下:
Stream,中文叫做流,和我们平时充值信仰的那个Steam还是差了那么一点的。所谓流,是一种消费的模型,被消费完就木有了,所以如果我们需要重复使用,就得存下来,也就是把Stream转成别的东西——JustLikeArrayorBuffer。
上代码表演一下:
functionstreamToBuffer(stream){ returnnewPromise((resolve,reject)=>{ letbuffers=[]; stream.on('error',reject); stream.on('data',(data)=>buffers.push(data)) stream.on('end',()=>resolve(Buffer.concat(buffers)) }); }
Buffer.concat(buffers)之后就转换为了Buffer,可以重复使用了。
逆向转换也很简单:
letDuplex=require('stream').Duplex; functionbufferToStream(buffer){ letstream=newDuplex(); stream.push(buffer); stream.push(null); returnstream; }
参考:
http://derpturkey.com/buffer-to-stream-in-node/
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对毛票票的支持。