首页 > 代码库 > node.js Stream Buffer FsPromise

node.js Stream Buffer FsPromise

2024-08-31 00:34:34   216人阅读

Stream:

　　类似这样：a.pipe(b).pipe(c); 我想写一个b。所以：

var rs=new (require(‘stream‘).Readable)();
var ws=new (require(‘stream‘).Writable)();

rs._read=function(){
  this.push(‘send a msn for the first time‘);
  this.push(‘send a msn for the second time‘);
  this.push(null);    
}

ws._wirte=function(chunk,encoding,next){
  console.log(chunk.toString());
  next()
}

var Duplex=function(){
  let duplex= new (require(‘stream‘).Duplex)();
  duplex._read=function(){
     this.push(null);
  }
  duplex._write=function(chunk,e,callback){
     this.push(chunk.toString()+‘...by ztw‘);
     next()
   }
   return duplex;
}
var myDuplex=Duplex();

rs.pipe(myDuplex).pipe(ws);

　　最后正常显示：

技术分享

Buffer:

　先说概念：

　　Unicode定义码点，utf8配置字节如何对应码点。

　　Buffer，你能看到是Unicode 16进制码的形式储存。

　　Buffer[0]，这种返回的是10进制的Unicode码，这和‘string‘.charCodeAt(0)是一样的。

　　JS对4字节的Unicode码支持不好，‘string‘.length不对。使用：[...‘string‘].length。

var buffer=new Buffer(‘Buffer Test‘,‘utf8‘);

buffer.toString(‘utf8‘,0,4);   // ‘Buff‘   位置按buffer内的位置算，非String的位置。

buffer.copy(buffer2, targetStart, sourceStart, sourceEnd) ;
      // 说形象点，按照[sourceStart,sourceEnd]对buffer进行裁剪，并从buffer2的targetStart位置，开始替换。

buffer.fill(‘shit‘ ,  sourceStart, sourceEnd );
  //使用shit在buffer的裁剪区域进行填充，填充方式为：repeat;
    
       buffer.fill(‘shit‘) //全部填充

buffer.write(‘strawberry‘, start,end);   //替换某个位置。

Buffer.concat([buf1,buf2]); //合并两个Buffer;

　　详见官方API；

JS中有原生的buffer支持，ArrayBuffer，举个例子:

var arryBuffer=new ArrayBuffer(10);   //Buffer,拥有10个字节的容量。
var arr1=new Int8Array(arryBuffer);
    //每个Int8Array(Unit8Array...)都带有一个ArrayBuffer。这里显示申明了而已。我们可以这样获得它：

var buf=arr1.buffer;   //buf指向arryBuffer，两者是一样的。

var arr2=new Int8Array(buf) ; //arr2与arr1使用同一空间，二者关联，值也相同。
var arr2=new Int8Array(buf.slice(5)); //只将5以后的空间分配给arr2，而arr1仍然全部占有。
new Buffer(buf) //可以得到这个Buffer。只能在nodeJs端使用。

buf.typeLength  // 返回buf的字节容量大小。

　　

 

FsPromise:

　　nodeJS没有提供FS的promise模块，需要自己包装：

function fsPromise(method){
  return function(...args){
    return new Promise((resolve,reject)=>{
         method.apply(method,args.concat([(err,data)=>{resolve(data)}]))
     })
  }  
}

　　写一个最简单直接的，其他功能可以在这基础上变通。

　　最后使用：

　　fsPromise(fs.readFile)(‘fileName‘,‘utf8‘).then(val=>console.log(val));

 

FsPromise为了跳出callBack的嵌套。还可以这样：

function thunkify(method){
    return function(){
      return function(...args){
             return function(fn){
                 method.call(method,...args,fn);  //相同于 method.apply(method, args.concat[fn]);
              };
          }  
    }
}

　　先想定义一个thunkify;再接着写：

var readFile=thunkify(fs.readFile);
var FsGen=function* (){
     yield readFile(‘fileOne‘,‘utf8‘);
     yield readFile(‘fileTwo‘,‘utf8‘);
}

var fg=FsGen();
nextFile();              //调用nextFile,按顺序异步读取文件。

function nextFile(err,data){
    let result=fg.next();
    data?console.log(data):0;
    if(!result.done) result.value(nextFile);
}

　　同样跳出callback嵌套。而generators 配合thunkify函数，可以异步处理更多的文件。

node.js Stream Buffer FsPromise


联系
我们