node.jsはストリームを利用して読み書きの同期、読み書きを同時に行う機能を実現します。

次の記事では、node.js がストリームを使用して読み取りと書き込みの同期を実現する方法、および読み取りと書き込みを同時に行う方法について説明します。内容がとても良かったので、参考としてシェアさせていただきます。

は次のとおりです:

//10个数 10个字节，每次读4b,写1b
let fs=require("fs");
function pipe(source,target) {
  //先创建可读流，再创建可写流
  //先读一次，rs.on(data)
  //将读到的类容写入目标中 ，返回布尔值，如果是ture,继续写，默认情况应该是false,暂停读取
  //ws.on('drain'),抽干后，回复读取
  //监听读取文件完毕后，关闭读取rs.on('end')

  let rs=fs.createReadStream(source,{highWaterMark:4});
  let ws=fs.createWriteStream(target,{highWaterMark:1});

  rs.on('data',function (chunk) { //chunk是buffer类型

    if(ws.write(chunk)===false){
      //写不下，停止读取
      rs.pause()
    }

  });
  ws.on('drain',function () {
    //每次写的内存干了就恢复读取
    console.log("111");
    rs.resume() //恢复读取
  });
  rs.on('end',function (chunk) {
    ws.end();
  })

}
pipe('./1.txt','./3.txt')

上記の書き方は面倒ですが、みんなが読んだら忘れてください

node.jsは組み込みメソッドpipeを提供します

。

//10个数 10个字节，每次读4b,写1b
let fs=require("fs");
function pipe(source,target) {

  let rs=fs.createReadStream(source,{highWaterMark:4});
  let ws=fs.createWriteStream(target,{highWaterMark:1});
  //可读流到可写流,异步操作，可以保证内存不会被淹没，读一点，写一点
  // 如果想看文件类容，使用readFile

  rs.pipe(ws);
}
pipe('./1.txt','./4.txt')

直接 読み取りストリームを書き込みストリームに操作する必要がありますか、それとも非同期に操作する必要がありますか? 以上がこの記事の全内容です。その他の関連コンテンツについては、お支払いください。 PHP 中国語 Web サイトに注意してください。

関連する推奨事項:

nodejsソケットサーバーとクライアント間の簡易通信機能について

angular2とnodejsは画像アップロード機能を実現

以上がnode.jsはストリームを利用して読み書きの同期、読み書きを同時に行う機能を実現します。の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。