创建一个文件可读流

fs.createReadStream(path[, options])

常用可选配置：[, options]

image.png

返回值

Readable的子类ReadStream 通过这个子类可以注册监听事件

注册事件

注册事件需要通过Readable的子类ReadStream
rs.on(事件名， 事件处理函数)

常用事件

image.png方法

image.png

示例

  1. const path = require('path')
  2. const fs = require('fs')
  4. const fileName = path.resolve(__dirname, './1.txt');
  6. const re = fs.createReadStream(fileName, {
  7.     encoding: 'utf-8', //编码格式
  8.     autoClose: true, // 自动关闭
  9.     highWaterMark: 1, //一次写入的字节数，默认是64kb 
  10.     // 一个字符等于三个字节
  11. })
  13. re.on('open', (res) => {re
  14.     console.log('文件被打开啦');
  15. })
  16. re.on('error', () => {
  17.     console.log('读取文件出错啦')
  18. })
  19. let str= '';
  20. re.on('data', trunk => {
  21.     // 该事件注册过才会开始读取
  22.     // 参数中是读取到字节，按照配置的编码格式
  23.     // 每次读取的数据的大小取决于highWaterMark设置的值
  24.     console.log(trunk, '读到的一部分数据')
  25.     str += trunk; // 将读取的数据保存下来 如果不保存下来，就会用完就扔啦
  26.     re.pause() // 暂停
  27. })
  28. re.on('pause', () => {
  29.     console.log('暂停啦');
  30.     setTimeout(() => {
  31.         re.resume() //恢复
  32.     }, 1000);
  33. })
  34. re.on('resume', () => {
  35.     console.log('恢复了')
  36. })
  37. re.on('end', () => {
  38.     // 在close之前触发
  39.     console.log('全部数据读取完毕');
  40. })
  41. re.on('close', () => {
  42.     // 在end之后触发
  43.     console.log('文件关闭啦')
  44.     console.log(str, '读取到的文件内容')
  45. })