Node.js_流Stream

Node.js 中的流(Streams)是一种处理读取和写入数据的抽象接口,它允许你以非阻塞的方式处理数据,这对于处理大文件或网络请求等 I/O 密集型任务非常有用。流主要分为四种类型:可读流(Readable)、可写流(Writable)、双工流(Duplex)和转换流(Transform)。

1. 可读流(Readable Streams)

可读流用于从源读取数据。数据源可以是文件、网络连接等。

常用函数:
  • read([size]):从流中读取数据。不推荐直接使用,因为流的设计初衷是自动处理数据的流动。
  • pipe(destination[, options]):将可读流的数据流重定向到一个可写流。这是处理流数据最常见的方法之一。
  • pause():暂停流中的数据读取。
  • resume():恢复流的数据读取。
  • on('data', callback):当流中有数据可读时,触发回调函数。
  • on('end', callback):当没有更多数据可读时触发。
  • on('error', callback):处理流中的错误。

2. 可写流(Writable Streams)

可写流用于将数据写入目标。目标可以是文件、网络连接等。

常用函数:
  • write(chunk[, encoding][, callback]):向流中写入数据。chunk 是要写入的数据,encoding 是数据的编码(如果 chunk 是字符串),callback 是写入完成后的回调函数。
  • end([chunk][, encoding][, callback]):结束写入过程。可选的 chunk 和 encoding 允许在结束前再写入一些数据。
  • on('drain', callback):当可以继续写入数据时被调用(即流内部的缓冲区为空时)。
  • on('finish', callback):当所有数据都被写入底层系统时触发。
  • on('error', callback):处理流中的错误。

3. 双工流(Duplex Streams)

双工流既是可读流也是可写流。例如,TCP 套接字连接。

继承自可读流和可写流的属性和方法。

4. 转换流(Transform Streams)

转换流是特殊的双工流,其输出数据是基于输入数据的某种转换。例如,zlib.createGzip() 用于创建 gzip 压缩流。

常用函数(继承自双工流):
  • _transform(chunk, encoding, callback):这是转换流的核心方法,需要被重写以实现自定义的转换逻辑。chunk 是要转换的数据块,encoding 是数据的编码(如果 chunk 是字符串),callback 是转换完成后的回调函数。
const fs = require('fs');  
const readableStream = fs.createReadStream('input.txt');  
const writableStream = fs.createWriteStream('output.txt');  readableStream.pipe(writableStream);  readableStream.on('end', () => {  console.log('文件读取完毕');  
});  writableStream.on('finish', () => {  console.log('文件写入完毕');  
});

在这个例子中,我们使用 fs.createReadStream 创建一个可读流来读取 input.txt 文件,然后使用 fs.createWriteStream 创建一个可写流来写入 output.txt 文件。通过 pipe 方法,我们实现了从可读流到可写流的数据流重定向。当可读流结束(end 事件)时,表示文件已读取完毕;当可写流完成写入(finish 事件)时,表示数据已完全写入目标文件。

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

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

相关文章

项目2:API Hunter 细节回顾 -1

一. 接口调用 对于开发者来说,接口的调用应当是方便快捷的,而且出于安全考虑,通常会选择在后端调用第三方 API,避免在前端暴露诸如密码的敏感信息。 若采用 HTTP 调用方式: HttpClientRestTemplate第三方库&#xf…

cglib

ASM是一个非常高效的Java字节码操控和分析框架,它允许开发者在运行时或者编译时期动态地生成、改变或者分析类。ASM提供的功能强大且灵活,适用于诸如框架开发、代码优化、代码生成等多种场景 需求:用 asm 编写一个类并运行输出hello word 依…

Spring国际化多语言实现-MessageSource

1 简介 Spring MessageSource 是 Spring 框架中用于国际化(i18n)和本地化(l10n)功能的一个关键组件 MessageSource 提供了一种灵活的方式来管理多语言环境下的消息。它支持从不同的资源文件中加载消息,如 .propertie…

视图库对接系列(GA-T 1400)四、视图库对接系列(本级)注册

视图库对接系列(本级)注册 在之前的步骤中,我们已经把项目大体的架构已经写出来了。那我们就来实现注册接口。 GA-T 1400中的步骤如下: 这里的话,我们实现的简单点, 我们不进去鉴权,也就是设备或平台找我们注册的话&…

Python高速下载及安装的十大必备事项与C++联调

选择正确的版本: 访问Python官网(https://www.python.org/)下载最新稳定版本,目前最新稳定版本为3.12.4 避免下载并安装Python 2.x版本,因为它已经停止维护。 选择适合操作系统的安装包: 根据你的操作系…

【笔记】太久不用redis忘记怎么后台登陆了

!首先启动虚拟机linux的centos7 2.启动finalshell 我的redis启动在根目录用 redis-server redis.conf --启动 systemctl status redis --查看redis状态 是否active redis-cli -h centos的ip地址 -p 你要用的redis端口号(默认为6379) -a 你…

uboo对内存操作读写命令的基本使用

内存操作命令 直接对DRAM进行读写的操作,uboot常用的内存操作命令有md,nm,mm,mw,cp和cmp. md命令: 显示内存值 # md md - memory display Usage: md [.b, .w, .l, .q] address [# of objects] b:1个字节 byte w:2个字节 world l:4个字节 long of objects 以word 为单位的1…

MySQL:保护数据库

保护数据库 1. 用户1.1 创建用户1.2 查看用户1.3 删除用户1.4 修改密码 2. 权限2.1 授予权限2.2 查看权限2.3 撤销权限 之前都是介绍本地数据库而你自己就是数据库的唯一用户,所以不必考虑安全问题。但实际业务中数据库大多放在服务器里,你必须妥善处理好…

C语言实现 人生重生模拟器游戏

目录 实现一个简化版的人生重开模拟器 1.菜单函数 2.game函数 3.幼年时期(even函数) 4.壮年时期(Juvenile函数) 课余时间实现的小游戏 实现一个简化版的人生重开模拟器 1.菜单函数 void menu() {printf("---------------…

版本控制系统:Git 纯应用(持续更新);

基本操作 ctrl上行键:上次代码 本地仓库:Git init 新建文件:touch xxxx.xxx 查看状态:Git status 文件从工作区——暂存区:Git add ./文件名(.是通配符代表所有) 暂存区——仓库:Git commit -m &…

Eureka与Docker的完美融合:容器化部署全攻略

Eureka与Docker的完美融合:容器化部署全攻略 在微服务架构中,服务发现是实现服务间通信的关键。Eureka作为Netflix开源的服务发现框架,与Docker容器化技术的结合,为构建灵活、可扩展的微服务应用提供了强大支持。然而&#xff0c…

代码随想录第四十六天 | 322. 零钱兑换,279.完全平方数,139.单词拆分

322. 零钱兑换 看完想法:此处是求最小值,所以递推公式中含Min,即dp[j] min(d[[j], dp[j - coins[i]] 1),初始化都为INT_MAX,且dp[0] 0。由于不是求组合数,所以物品和背包重量的遍历先后顺序都是可以的…

论文阅读之旋转目标检测ARC:《Adaptive Rotated Convolution for Rotated Object Detection》

论文link:link code:code ARC是一个改进的backbone,相比于ResNet,最后的几层有一些改变。 Introduction ARC自适应地旋转以调整每个输入的条件参数,其中旋转角度由路由函数以数据相关的方式预测。此外,还采…

使用 Ollama 时遇到的问题

题意: ImportError: cannot import name Ollama from llama_index.llms (unknown location) - installing dependencies does not solve the problem Python 无法从 llama_index.llms 模块中导入名为 Ollama 的类或函数 问题背景: I want to learn LL…

【postgreessql 】统计库中的所有表数量

在PostgreSQL中,你可以使用SQL查询来统计数据库中的所有表数量。这通常涉及到查询系统目录表,特别是 pg_catalog.pg_tables 表,它存储了关于数据库中所有表的信息。 SELECT COUNT(*) FROM information_schema.tables WHERE table_schema IN …

第二十五章 迭代器(Iterator)(Python)

文章目录 前言一、什么是迭代器?二、如何生成迭代器? 前言 迭代器是为了给迭代对象进行迭代使用的,是访问集合元素的一种方式。从集合的第一个元素开始访问,直到所有的元素被访问完结束。迭代器只能往前不会后退。 列表、集合、元…

mysql逗号分割字符串“1,2,3”实现in查询

数据示例 前台单值参数实现in查询 主要函数FIND_IN_SET 该函数的作用是查询字段(strlist) 中是否包含(str)的结果,返回结果为 null或记录 select id,recommend_position_id from t_stk_task where FIND_IN_SET(359919,recommend_position_id)查询效果 前台集…

小麦TaHRC信息汇总

文献中关于TaHRC的信息总结 主要发现: TaHRC基因的功能和定位: TaHRC基因编码一个富含组氨酸的钙结合蛋白,定位于核内。TaHRC-S(敏感等位基因)的高表达与小麦穗腐病(FHB)的敏感性相关 。通过RNA干扰和CRISPR-Cas9基因…

【软件测试】性能测试 | 概念 | 常见术语 | 性能指标 | 分类 | 流程

性能测试 文章目录 性能测试一、什么是性能测试1.生活中遇到的软件的性能问题2.性能测试定义3.性能测试和功能测试有什么区别4.什么样的表现属于软件性能好、什么样的表现不好5.影响一个软件性能因素有哪些 二、为什么进行性能测试三、性能测试的常见术语以及性能测试的衡量指标…

C++部分复习笔记下

7. C11 范围for 使用格式 vector<int> v { 1,2,3,4,5 }; for (auto e : v) {cout << e << " "; } cout << endl;底层原理&#xff0c;使用迭代器 vector<int> v { 1,2,3,4,5 }; auto it v.begin(); while (it ! v.end()) {cout…