readline模块详解!!【Node.js】

devtools/2025/3/1 15:08:17/

‌“书到用时方恨少,事非经过不知难。”‌ —— 陆游

目录

  • ‌readline 是什么?
  • ‌基本用法:
    • ‌创建 Interface 类:
    • 核心流程‌:
  • ‌Interface 类的关键事件:
    • line:
    • close:
    • pause:
    • resume:
    • prompt:
  • 关键事件表格展示:

‌readline 是什么?

readline 是 Node.js 内置的核心模块,用于‌逐行处理输入/输出流‌(如文件、命令行输入),通过事件驱动机制实现非阻塞式行级数据处理‌。它适用于需要交互式逐行读取的场景(如命令行工具、日志解析等)。

‌基本用法:

‌创建 Interface 类:

通过 readline.createInterface() 方法创建接口实例,每个实例都关联一个input可读流和一个outpu可写流,绑定输入/输出流‌。

const readline = require('readline');
const rl = readline.createInterface({input: process.stdin, // 输入流(如文件流、标准输入)output: process.stdout // 输出流(如标准输出)
});

核心流程‌:

  • 绑定输入流‌:如 fs.createReadStream(‘file.txt’) 读取文件‌;‌
  • 逐行处理‌:通过事件监听逐行获取数据;
  • 关闭接口‌:完成操作后调用 rl.close() 释放资源‌

‌Interface 类的关键事件:

line:

此事件在输入流(例如文件流或标准输入)检测到换行符(\n,\r\r\n时触发line事件,即用户按下<Enter> 键或 )时即刻触发,意味着我们可以借此机会对每一行输入数据进行实时处理。

设想有一个名为 example.txt 的文本文件,内容如下:

第一行内容
第二行内容
第三行内容

我们的目标是逐行读取这个文件,并将每行的内容打印到控制台。

实现步骤:

  • ‌引入所需模块‌:首先,需要引入 Node.js 的 fs(文件系统)模块和 readline 模块。
  • 创建文件读取流‌:利用 fs.createReadStream 方法,我们可以创建一个指向 example.txt 文件的读取流。‌
  • 构建 Interface 实例‌:接着,需要用这个读取流作为输入,来创建一个 readline.Interface 实例。
  • 监听 line 事件‌:为 Interface 实例绑定一个 line 事件监听器,这样每当读取到一行新数据时,该监听器就会被触发,并接收到这行数据作为参数。
  • 处理数据‌:在 line 事件的回调函数中,可以对接收到的行数据进行处理,本例中即将其打印到控制台。
  • 关闭接口‌(可选):虽然对于文件读取来说不是必需的,但在处理完所有行后关闭 Interface 实例是一个好习惯。

示例代码:

const fs = require('fs');
const readline = require('readline');// 创建一个指向 example.txt 文件的读取流
const fileStream = fs.createReadStream('example.txt');// 利用文件读取流构建一个 readline.Interface 实例
const rl = readline.createInterface({input: fileStream,crlfDelay: Infinity // 确保兼容不同系统的换行符
});// 监听 line 事件,逐行处理文件内容
rl.on('line', (line) => {console.log(line); // 将读取到的行内容打印到控制台
});// 监听 close 事件,以便在所有行处理完毕后执行清理操作(本例中无需特别处理)
rl.on('close', () => {console.log('文件读取完成。');
});

close:

close事件在 Interface 实例被关闭时触发。这通常发生在所有输入数据都已经被处理完毕,且不再需要该接口时。 它可以释放与接口相关联的资源,并确保不会有未处理的事件或回调函数残留。

close 事件的触发时机:

  • 当显式调用 rl.close() 方法时,close 事件会被触发。
  • 如果输入流(如文件流)自然结束(例如,文件被完全读取),并且没有更多的数据可以读取,那么 Interface 会自动关闭,并触发 close 事件。
  • 在某些情况下,如遇到错误或异常导致接口无法继续工作时,Interface 也可能会自动关闭,并触发 close 事件。

close 事件的处理:
在 close 事件的回调函数中,可以执行任何需要在接口关闭时进行的清理操作。这可能包括关闭文件描述符、释放内存、结束数据库连接、发送通知等。

示例代码:
以下是一个包含 close 事件处理的示例代码,它读取一个文件并在处理完所有行后自动关闭接口。

const fs = require('fs');
const readline = require('readline');// 创建一个指向文件的读取流
const fileStream = fs.createReadStream('example.txt');// 构建 readline.Interface 实例
const rl = readline.createInterface({input: fileStream,crlfDelay: Infinity // 兼容不同系统的换行符
});// 监听 line 事件,逐行处理文件内容
rl.on('line', (line) => {console.log(line); // 打印读取到的行内容
});// 监听 close 事件,执行清理操作
rl.on('close', () => {console.log('文件已完全读取,接口已关闭。');// 在这里执行任何需要的清理操作
});// 注意:对于文件流,通常不需要显式调用 rl.close(),
// 因为当文件读取完毕时,流会自动结束,从而触发 close 事件。

pause:

pause 事件是 readline 模块中的一个事件,它在用户按下 Ctrl+S 组合键时被触发,用于暂停终端的输出‌。不过,需要注意的是,readline 默认情况下并不会直接处理这个 pause 事件来暂停输入流,而是会暂停终端的输出显示。 这意味着,尽管 pause 事件被触发了,但输入流本身可能仍然会继续接收数据,只是这些数据暂时不会在终端上显示出来。

为了正确处理 pause 事件并暂停输入流,我们可以采取以下步骤:

  • 使用 readline.createInterface 方法创建一个 readline.Interface 实例。
  • 监听 pause 事件,并在事件处理程序中调用 rl.pause() 方法来手动暂停输入流(尽管这通常不是必需的,因为 pause 事件本身并不会自动暂停输入流,但我们可以在这里执行其他与暂停相关的逻辑)。

‌手动暂停和恢复输入流的示例‌:

const readline = require('readline');
const rl = readline.createInterface({input: process.stdin,output: process.stdout
});// 监听 pause 事件(尽管它通常不会直接暂停输入流)
rl.on('pause', () => {console.log('pause 事件被触发,但输入流不会自动暂停。');// 你可以在这里执行其他逻辑,比如显示一个提示信息
});// 手动暂停输入流(如果需要)
// rl.pause(); // 这行代码会在调用时暂停输入流,直到你调用 rl.resume()// 监听其他事件,如 line 事件来处理输入数据
rl.on('line', (line) => {console.log(`接收到输入: ${line}`);// 根据需要处理输入数据
});// 在适当的时候关闭接口
// rl.close(); // 这行代码会在你准备好关闭接口时调用

resume:

在 readline 模块中,resume 事件是一个与 pause 事件相对应的事件,它用于指示输入流已经被恢复。 当输入流处于暂停状态时,如果用户执行了某些操作(比如按下 Ctrl+Q 组合键,这取决于终端和操作系统的具体行为),或者在代码中显式调用了 rl.resume() 方法,resume 事件就会被触发。

resume 事件的触发时机:

  • 当之前被暂停的输入流被恢复时,resume 事件会被触发。
  • 这通常发生在用户按下 Ctrl+Q 组合键(在大多数终端和操作系统中,Ctrl+S 用于暂停输出,Ctrl+Q 用于恢复输出,但请注意这可能会因环境而异)或者在代码中调用了 rl.resume() 方法之后。

resume 事件的处理:
在 resume 事件的回调函数中,我们可以执行任何需要在输入流恢复时进行的操作。这可能包括更新用户界面、恢复数据处理逻辑等。

const readline = require('readline');
const rl = readline.createInterface({input: process.stdin,output: process.stdout
});// 监听 resume 事件
rl.on('resume', () => {console.log('输入流已恢复。');// 在这里执行任何需要在输入流恢复时进行的操作
});// 监听 pause 事件(尽管它通常不会直接暂停输入流,但可以作为用户操作的指示)
rl.on('pause', () => {console.log('输入流已暂停(注意:这通常是由 Ctrl+S 触发的,但 readline 默认不会直接暂停输入流)。');// 你可以在这里执行其他逻辑,比如显示一个提示信息// 如果需要,你也可以显式调用 rl.pause() 来暂停输入流,但通常这不是必需的
});// 监听 line 事件来处理输入数据
rl.on('line', (line) => {console.log(`接收到输入: ${line}`);// 根据需要处理输入数据
});// 在适当的时候关闭接口
// rl.close(); // 这行代码会在你准备好关闭接口时调用// 注意:在这个示例中,我们没有显式调用 rl.pause() 来暂停输入流,
// 因为 readline 默认不会将 Ctrl+S 解释为暂停输入流的命令。
// 如果你想测试 resume 事件,你可能需要在其他上下文中暂停输入流,
// 或者使用其他方法来模拟输入流的暂停和恢复。

需要注意的是,readline 模块默认不会将 Ctrl+S 和 Ctrl+Q 组合键解释为暂停和恢复输入流的命令。这些组合键通常用于控制终端输出的暂停和恢复。如果你希望在代码中显式控制输入流的暂停和恢复,你应该使用 rl.pause() 和 rl.resume() 方法。

prompt:

用于在终端中显示提示符,并准备接收用户输入。
rl.prompt([preserveCursorPosition]) 方法会向用户显示一个可配置的提示符(通常是一个字符串,如 > ),并将输入光标移动到提示符之后,等待用户输入。这个方法不会触发一个事件,而是直接作为一个命令来执行。

const readline = require('readline');const rl = readline.createInterface({input: process.stdin,output: process.stdout,prompt: 'MyPrompt> ' // 设置自定义提示符
});// 监听 line 事件来处理用户输入
rl.on('line', (input) => {console.log(`你输入了: ${input}`);// 再次显示提示符以等待下一次输入rl.prompt();
});// 显示提示符以开始接收输入
rl.prompt();

关键事件表格展示:

‌事件名称触发条件用途
line输入流接收到换行符(如回车键)时触发处理单行数据(如解析内容、执行逻辑)‌
close接口关闭时触发(调用 rl.close() 后)执行清理操作(如释放资源、结束进程)
pause输入流暂停时触发处理暂停状态(如缓冲控制)
resume输入流恢复时触发处理恢复后的逻辑
prompt在终端中显示提示符接收用户输入
SIGINT用户按下 Ctrl+C 时触发自定义中断行为(如安全退出)

http://www.ppmy.cn/devtools/163658.html

相关文章

第三方应用程序接入DeepSeek服务的安全策略与实践

摘要 本文探讨了如何安全地通过第三方应用程序接入DeepSeek服务。对于追求企业级安全和无缝IDE体验的开发者及团队&#xff0c;QodoGen是理想选择&#xff1b;而对于希望快速访问DeepSeek-R1解决方案的用户&#xff0c;Perplexity AI提供的基于Web的应用无需安装即可使用&#…

Island架构与部分水合技术解析:下一代Web应用的性能突围

引言&#xff1a;突破传统SSR的性能瓶颈 Netflix采用Island架构重构文档中心后&#xff0c;LCP速度从2.4s提升至380ms&#xff0c;JS负载减少94%。The Guardian通过Astro实现内容站点现代化改造&#xff0c;首次输入延迟降低76%&#xff0c;SEO流量增长210%。Vercel官方数据显…

实验环境搭建集锦(docker linux ros2+强化学习环境+linux上单片机串口调试)

为了记住一些实验环境配置开的文章&#xff0c;边配置边记&#xff0c;免得之后忘了。 Docker环境搭建 yay -S docker //下载docker docker info //查看docker配置 sudo systemctl start docker //系统配置打开docker sudo systemctl enable docker //系统配置后台开启d…

如何获取mac os 安装盘

发现虚拟机VirtualBox支持Mac虚拟&#xff0c;就想尝试一下。但是发现Mac的安装盘特别难拿到&#xff0c;因此留档。 第一种方法 在mac环境下&#xff0c;使用softwareupdate命令来获取mac安装&#xff0c;能获得当前设备支持的系统。 使用这个命令&#xff1a;/usr/sbin/soft…

2025考研国家线首次全面下降,涵盖与24年对比分析!

2025年研考国家线发布&#xff0c;“调剂意向采集系统”将于3月28日开通&#xff1b;“调剂服务系统”将于4月8日开通。 “中国研究生招生信息网”中“调剂意向采集系统”将于3月28日开通&#xff0c;已完成一志愿录取的招生单位可发布调剂信息&#xff0c;有调剂意愿的考生可查…

某住宅小区地下车库安科瑞的新能源汽车充电桩的配电设计与应用方案

摘要&#xff1a; 文中以某住宅小区建设工程为例,重点研究了住宅小区地下车库新能源汽车充电桩配电设计,从位置设置、安装方式选择、配电箱设置、配电箱回路设置、供配电系统设计等方面展开分析,提出了民用建筑充电桩设计的科学建议,为新能源充电桩的推广应用提供参考。 关键…

包子凑数——蓝桥杯真题Python

包子凑数 输入输出样例 示例 1 输入 2 4 5输出 6样例说明 凑不出的数目包括&#xff1a;1, 2, 3, 6, 7, 11。 示例 2 输入 2 4 6输出 INF样例说明 所有奇数都凑不出来&#xff0c;所以有无限多个 运行限制 最大运行时间&#xff1a;1s最大运行内存: 256M 最大公约数 最大公…

RustDesk搭建公网中继服务器远控内网机器(完整版)

前情提要&#xff1a;最近要在学校实验室的服务器&#xff08;ubuntu&#xff09;上做实验&#xff0c;但是服务器在校园网里面&#xff0c;在外面的时候没法远控&#xff0c;todesk有时候有点卡顿&#xff0c;所以想试着用rustdesk进行远程控制。 参考博客&#xff1a; 官方…