Node.js 本身没有像 Java 那样严格区分字符流和字节流,区别主要靠编码(encoding)来控制数据是以 Buffer(二进制字节)形式还是字符串(字符)形式处理。


详细解释:

方面JavaNode.js
字节流InputStream / OutputStream默认情况下的 Readable / Writable 流,数据是 Buffer(二进制)
字符流Reader / Writer流上设置 encoding,数据自动转换成字符串(UTF-8、ASCII 等)
编码处理字节流和字符流类分开,编码需自己控制Buffer 是二进制字节,设置 encoding 自动转换成字符
示例FileInputStream vs FileReaderfs.createReadStream + encoding 参数
API差异不同基类,区别明显同一套流 API,参数控制返回类型


举个 Node.js 代码例子说明:

const fs = require('fs');// 字节流(默认,读取到 Buffer)
const stream1 = fs.createReadStream('file.txt');
stream1.on('data', chunk => {console.log(Buffer.isBuffer(chunk)); // true,收到的是 Buffer(二进制)
});// 字符流(设置编码,读取到字符串)
const stream2 = fs.createReadStream('file.txt', { encoding: 'utf8' });
stream2.on('data', chunk => {console.log(typeof chunk); // string,收到的是字符串
});

总结

  • Node.js 流是统一的“字节流”,数据默认是 Buffer 类型的二进制。

  • 通过给流设置 encoding,Node.js 会自动将字节流转换成字符串,达到类似 Java 字符流的效果。

  • Java 是在类结构上区分字符流和字节流;Node.js 是靠参数和 Buffer 来决定处理方式。

如果你做文件操作,想“像用字符流一样”处理文本,就用带编码的流;如果要处理二进制数据,就用默认的 Buffer 流。

你想了解 Node.js 里跟文件读取(以及文件操作)相关的常见函数,尤其是跟“读取(read)”、“读文件(readFile)”、“创建(create)”、“流(stream)”有关的。顺便帮你补充一些常用但你没说的相关函数。

我帮你把 Node.js 文件系统(fs模块)相关常用方法做个全面的梳理和举例。


Node.js 文件读写相关函数大全

1. fs.readFile()fs.readFileSync()

  • 作用:一次性读取整个文件内容(异步和同步版本)

  • 示例:

const fs = require('fs');// 异步读文件
fs.readFile('example.txt', 'utf8', (err, data) => {if (err) throw err;console.log('异步读文件内容:', data);
});// 同步读文件
const content = fs.readFileSync('example.txt', 'utf8');
console.log('同步读文件内容:', content);

2. fs.read()

  • 作用:读取文件的部分内容(基于文件描述符,低级 API)

  • 需要先打开文件,得到文件描述符(fd)

  • 示例:

const fs = require('fs');fs.open('example.txt', 'r', (err, fd) => {if (err) throw err;const buffer = Buffer.alloc(10); // 读取10字节fs.read(fd, buffer, 0, 10, 0, (err, bytesRead, buf) => {if (err) throw err;console.log('读取字节数:', bytesRead);console.log('读取内容:', buf.toString('utf8', 0, bytesRead));fs.close(fd, (err) => {if (err) throw err;});});
});

3. fs.createReadStream()

  • 作用:创建一个可读流,适合大文件或流式处理

  • 示例:

const fs = require('fs');const readStream = fs.createReadStream('example.txt', { encoding: 'utf8', highWaterMark: 16 * 1024 });readStream.on('data', (chunk) => {console.log('读取到数据块:', chunk);
});readStream.on('end', () => {console.log('读取完毕');
});readStream.on('error', (err) => {console.error('读取错误:', err);
});

4. fs.open() / fs.close()

  • 作用:打开文件,返回文件描述符(fd),用于更底层操作;操作结束后关闭文件

  • 示例:

fs.open('example.txt', 'r', (err, fd) => {if (err) throw err;console.log('文件描述符:', fd);fs.close(fd, (err) => {if (err) throw err;console.log('文件已关闭');});
});

5. fs.readSync()

  • 同步版本的 fs.read(),基于 fd 读文件部分内容

  • 示例:

const fd = fs.openSync('example.txt', 'r');
const buffer = Buffer.alloc(10);
const bytesRead = fs.readSync(fd, buffer, 0, 10, 0);
console.log(buffer.toString('utf8', 0, bytesRead));
fs.closeSync(fd);

6. fs.readv() / fs.readvSync()(Node.js 12+)

  • 作用:一次读取多个 buffer(分散读)

  • 相对较少用,进阶用法


7. 其它相关的文件读取与创建函数

函数说明同步/异步
fs.writeFile() / fs.writeFileSync()写文件(覆盖写)异步/同步
fs.appendFile() / fs.appendFileSync()追加写文件异步/同步
fs.createWriteStream()创建写流适合大文件或流式写入
fs.exists() / fs.existsSync()判断文件是否存在(不推荐,建议用 fs.stat异步/同步
fs.stat() / fs.statSync()获取文件信息(大小、时间等)异步/同步
fs.readdir() / fs.readdirSync()读取目录下文件列表异步/同步


8. 结合 stream 读取文件示例

const fs = require('fs');
const { pipeline } = require('stream');const readStream = fs.createReadStream('example.txt', { encoding: 'utf8' });
readStream.on('data', (chunk) => {console.log('读取块:', chunk);
});
readStream.on('end', () => {console.log('读完了');
});

9. readline 模块按行读取大文件

const fs = require('fs');
const readline = require('readline');const rl = readline.createInterface({input: fs.createReadStream('example.txt'),crlfDelay: Infinity
});rl.on('line', (line) => {console.log(`一行: ${line}`);
});rl.on('close', () => {console.log('文件读取结束');
});

总结

  • 简单快速读小文件fs.readFile() 或同步版本

  • **读文件片段(低级)**用 fs.read() + fs.open()

  • 大文件流式读fs.createReadStream()

  • 按行读可以结合 readline 模块

  • 底层操作使用 fs.open()fs.read()fs.close()


如果你想,我还可以帮你整理写文件相关的函数用法,或者把流式读写结合的完整例子也给你,告诉我哈!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/pingmian/85252.shtml
繁体地址,请注明出处:http://hk.pswp.cn/pingmian/85252.shtml
英文地址,请注明出处:http://en.pswp.cn/pingmian/85252.shtml

如若内容造成侵权/违法违规/事实不符,请联系英文站点网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

基于二进制XOR运算的机器人运动轨迹与对称图像自动生成算法

原创:项道德(daode3056,daode1212) 新的算法出现,往往能给某些行业与产业带来革命与突破。为探索机器人运动轨迹与对称图像自动生成算法,本人已经通过18种算法的测试,最终,以二进制的XOR运算为…

Spring AI 项目实战(七):Spring Boot + Spring AI Tools + DeepSeek 智能工具平台(附完整源码)

系列文章 序号文章名称1Spring AI 项目实战(一):Spring AI 核心模块入门2Spring AI 项目实战(二):Spring Boot + AI + DeepSeek 深度实战(附完整源码)3Spring AI 项目实战(三):Spring Boot + AI + DeepSeek 打造智能客服系统(附完整源码)4Spring AI 项目实战(四…

spring-webmvc @RequestHeader 典型用法

典型用法 基础用法:获取指定请求头值 GetMapping("/info") public String getInfo(RequestHeader("User-Agent") String userAgent) {return "User-Agent: " userAgent; }如果请求中包含 User-Agent 请求头,则其值将被…

Ubuntu:20.04中安装docker

是的,您列出的命令是完整的安装步骤,但为了确保100%可靠性和处理可能的问题,我建议进行以下优化和补充: 完整优化的安装脚本(包含错误处理和验证) #!/bin/bash# 1. 彻底清理旧版本和配置 sudo apt remove…

大数据实时风控引擎:Spark Streaming、Kafka、Flink与Doris的融合实践

大数据实时风控引擎:Spark Streaming、Kafka、Flink与Doris的融合实践 在数字金融、电商交易与在线服务的核心战场,风险控制能力已成为业务的生命线。传统批量风控模式在应对瞬息万变的欺诈攻击、信用风险时捉襟见肘。本文将深入探讨如何利用**Spark St…

【创龙瑞芯微 RK3576 全国产 ARM 八核 2.2GHz 工业开发板-硬件说明书】

前 言 本文主要介绍TL3576-EVM评估板硬件接口资源以及设计注意事项等内容。 RK3576J/RK3576处理器的IO电平标准一般为1.8V、3.3V,上拉电源一般不超过3.3V或1.8V,当外接信号电平与IO电平不匹配时,中间需增加电平转换芯片或信号隔离芯片。按键或接口需考虑ESD设计,ESD器件…

一文吃透ADB,从入门到精通

目录 一、ADB 简介1.1 什么是 ADB1.2 ADB 的工作原理1.3 ADB 的安装与环境配置 二、ADB 基础命令2.1 设备连接相关命令2.2 应用管理命令2.3 文件传输命令 三、ADB 高级命令3.1 ADB Shell 深入探究3.2 日志查看与分析3.3 设备信息获取3.4 屏幕操作与录制 四、ADB 常见问题与解决…

PostgreSQL高可用架构设计与实践指南

# PostgreSQL高可用架构设计与实践指南 ## 一、高可用性核心诉求 PostgreSQL作为企业级关系型数据库,高可用设计需要满足以下关键指标: - 故障恢复时间(RTO):秒级到分钟级自动切换能力 - 数据损失容忍度&#xff0…

今天我想清楚了

首先说一声抱歉,很多天没有更新了,因为在我这里,我的内心感到迷茫,从来没有这样过,不知道为什么自己一直要做的事,进度太慢了,因为我的人生是空虚的,我感觉我做的不够好,…

代码随想录day3链表1

new关键字 1.new是一个关键字,用于开辟空间,开辟的空间在堆上,而一般声明的变量存放在栈上; 2.new得到的是一段空间的首地址。所以一般需要用指针来存放这段地址 new int(10);//返回new出来这块内存的地址int *pnew int(10);//…

taro小程序如何实现新用户引导功能?

一、需求背景 1、需要实现小程序新功能引导 2、不使用第三方库(第三方组件试了几个,都是各种兼容性问题,放弃) 二、实现步骤 1、写一个公共的guide组件,代码如下 components/Guide/index.tsx文件 import React, { …

键盘动作可视化技术浅析:如何做到低延迟显示

在做屏幕录制或者操作演示的时候,你是否遇到过这样的问题:观众看不清你按了哪个键、点了哪里?这是能完美解决这个问题的小工具Keyviz。它可以把你的键盘输入和鼠标点击实时显示在屏幕上,清晰直观,特别适合教学、录屏、…

Prufer序列 学习笔记

文章目录 P r u f e r Prufer Prufer 序列对树建立 P r u f e r Prufer Prufer 序列对 P r u f e r Prufer Prufer 序列重建树 应用Cayley 公式[HNOI2004] 树的计数「雅礼集训 2017 Day8」共[THUPC 2018] 城市地铁规划CF156D Clues[ARC106F] Figures P r u f e r Prufer Pruf…

高性能场景使用Protocol Buffers/Apache Avro进行序列化怎么实现呢

我们以Protocol Buffers(Protobuf)和Apache Avro为例,分别展示高性能序列化的实现方式。 由于两者都需要定义Schema,然后生成代码,因此步骤包括: 1. 定义Schema文件 2. 使用工具生成Java类 3. 在代码中…

iOS端网页调试 debug proxy策略:项目中的工具协同实践

移动开发中的调试,一直是效率瓶颈之一。特别是当前 Web 前端与 App 原生高度耦合的背景下,页面调试不仅受限于浏览器,还要面对 WebView 实现差异、系统权限控制、设备多样性等复杂情况。 但我们是否可以构建一套**“设备无关”的调试工作流*…

springboot项目启动报错:spring boot application in default package

启动类报错: 问题: springboot的启动方法不能直接在java目录下 解决: 1.使用CompentScan 和EnableAutoConfiguration注解 2.启动类放在java目录下的package目录下

机器学习实验报告5-K-means 算法

4.1 k-means算法简介 聚类分析,作为机器学习领域中的一种无监督学习方法,在数据探索与知识发现过程中扮演着举足轻重的角色。它能够在没有先验知识或标签信息的情况下,通过挖掘数据中的内在结构和规律,将数据对象自动划分为多个类…

【已解决】yoloOnnx git工程部署

首先 yoloonnx一个VS工程下来整个工程大概1-2个g的大小因此在git的过程中总是会因为文件超过100M而触发报错,上传不上去,因此现在需要做一个过滤才能把工程重新上传上去,那么这个时候别人需要下载下来的时候确实不完整的工程,因此…

如何轻松地将照片从电脑传输到安卓手机

一些安卓用户正在寻找有效可靠的方法,将照片从电脑传输到安卓设备。如果您也想将有趣或难忘的照片导入安卓手机或平板电脑,可以参考这篇文章,它提供了 6 种可靠的方法,让您轻松传输照片。 第 1 部分:如何通过 Android …

准备纯血鸿蒙理论高级认证的一些心得

最近在准备纯血鸿蒙理论高级认证,一些心得记录下来,希望早日考过高级! 一、考试目标: HarmonyOS核心技术理念HarmonyOS应用架构设计ArkTS原理和实践ArkUI开发HarmonyOS关键技术能力开发工程管理、代码编辑、调试与定位应用上架运…