这篇文章我们来了解Nodejs中的文件流，有很多新手对用户Nodejs中的文件流不是很理解的，对此下文给大家来详细的介绍一下，感兴趣的朋友不妨了解看看，对大家会有一定的帮助，那么接下来就跟随小编来一起学习一下吧！

    文件流

    由于电脑中的各种介质读存的速度不同、容量大小不同，因此可能在操作中会有一方存在长期等待的状态

    文件流主要有三种，分别为输入流（Readable）、输出流（Writeable）、双工流（Duplex）。其中还有一种流不常用那就是 转换流（Transform）

    在 node 中提供了 stream 模块，这个模块中有两个类实例：Readable 和 Writable，流中都会继承这两个类，因此会有很多共同的方法等。

    可读流（Readable）

    输入流：数据从源头流向内存，把磁盘里面的数据传输到内存里面。

    createReadStream

    fs.createReadStream(路径, 配置)

    在配置里面有：encoding（编码方式）、start（起始读取字节）、end（结束读取字节）、highWaterMark（每次读取量）

    highWaterMark：如果encoding有值，该数量表示一个字符数；如果encoding为null，该数量表示字节数

    返回一个Readable的子类ReadStream

const readable = fs.createReadStream(filename, { encoding: 'utf-8', start: 1, end: 2, // highWaterMark: });

    注册事件

    readable.on(事件名，处理函数)

readable.on('open', (err, data)=> {
    // console.log(err);
    console.log('文件打开了');
})

readable.on('error', (data, err) => {
    console.log(data, err);
    console.log('读取文件发生错误');
})

readable.on('close', (data, err) => {
    // console.log(data, err);
    console.log('文件关闭');
})

readable.close() // 手动触发通过 readable.close()或者在文件读取完毕之后自动关闭--autoClose配置项默认为 true

readable.on('data', (data) => {
    console.log(data);
    console.log('文件正在读取');
})

readable.on('end', ()=>{
    console.log('文件读取完毕');
})

    暂停读取

    readable.pause() 暂停读取，会触发 pause 事件

    恢复读取

    readable.resume() 恢复读取，会触发 resume 事件

    可写流

const ws = fs.createWriteStream(filename[, 配置])

    ws.write(data)

    写入一个数据，data 可以使字符串也可以是Buffer，返回一个布尔值。

    如果返回的是 true 表示写入通道没有被占满，接下来的数据可以直接写入，写入通道就是配置中的 highWaterMark 表示的大小。

    如果返回的是false 表示写入通道占满，其余字符开始等待，出现背压情况。

const ws = fs.createWriteStream(filename, {
    encoding: 'utf-8',
    highWaterMark: 2
})

const flag = ws.write('刘');
console.log(flag); // false 
这里虽然只会执行一次，但是在通道有空余空间的时候就会继续写入，并不在返回 值。

ws.write() 只会返回一次值。


const flag = ws.write('a');
console.log(flag);
const flag1 = ws.write('a');
console.log(flag1);
const flag2 = ws.write('a');
console.log(flag2);
const flag3 = ws.write('a');
console.log(flag3);

输出顺序：true、false、false、false

第二次写入的时候已经占了两字节，第三次写入后直接占满了，所以返回false

    使用流复制粘贴文件，并解决背压问题

const filename = path.resolve(__dirname, './file/write.txt');
const wsfilename = path.resolve(__dirname, './file/writecopy.txt');

const ws = fs.createWriteStream(wsfilename);
const rs = fs.createReadStream(filename)

rs.on('data', chumk => {
    const falg = ws.write(chumk);
    if(!falg) {
        rs.pause();
    }
})

ws.on('drain', () => {
    rs.resume();
})

rs.on('close', () => {
    ws.end();
    console.log('copy end');
})

    pipe

    使用 pipe 也可以直接将 可读流 和 写入流串联起来，也可以解决背压问题

rs.pipe(ws);

rs.on('close', () => {
    ws.end();
    console.log('copy end');
})

    现在大家对Nodejs中的文件流应该有所了解了吧，文件流在大量文件读写的时候是很方便的，并且可以做到快速高效，相比于writeFile和readFile效率要高很多，正确处理也不会有很大的阻塞出现。最后，想要了解更多大家可以关注群英网络其它相关文章。

文本转载自PHP中文网

免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：mmqy2019@163.com进行举报，并提供相关证据，查实之后，将立刻删除涉嫌侵权内容。

猜你喜欢

• 基于JS实现动态表格的代码是什么

  今天上午完成了Vue实现一个表格的动态样式，那么JavaScript代码能不能实现同样的效果呢？这样也可以学习一下JavaScript的语法，晚上试了一下，完全可以，效果一模一样。<!DOCTYPE htm

• Node中异步和事件循环的实现和执行是什么

  本文将深入 Node 异步和事件循环的底层实现和执行机制。聊聊Node 为什么要使用异步来作为核心编程模型呢？如何实现异步？以及基于事件循环的异步编程模型。

• 如何掌握vue-router基础知识及其应用

  这篇文章主要介绍了Vue路由vue-router详细讲解指南，对vue-router感兴趣的同学，可以参考下

• 怎样用js实现生成验证码并校验的功能?

  这篇文章给大家分享的是怎样用js实现生成验证码并校验的内容。小编觉得挺实用的，在很多注册登录页面都能使用到，因此分享给大家做个参考，感兴趣的朋友就继续往下看吧。

• 使用原生JavaScript来实现星星闪烁效果的代码示例

  本文实例为大家分享了js实现星星闪烁效果的具体代码，供大家参考，具体内容如下。使用JavaScript能够实现很多酷炫的效果，这篇文章就给大家分享下用原生JS实现星星闪烁的效果，用作星空背景动画一定很具个性和炫酷。感兴趣的朋友就继续往下看吧。