事件与流

Node.js 教程 · 第 5 章 · 6 次浏览

Node 基于事件驱动,EventEmitter 是事件机制的核心。流(Stream)是处理大数据的方案:不用一次性读进内存,像水管一样分段处理。

EventEmitter

Node 很多对象继承自 EventEmitter,用 .on() 监听、.emit() 触发。

流 Stream

  • Readable:可读流(读文件、请求体)
  • Writable:可写流
  • Transform:转换流(读写之间处理)

经典用法:readStream.pipe(writeStream) 管道复制大文件,内存占用极小。

代码示例

// EventEmitter
const EventEmitter = require("events");

class MyEmitter extends EventEmitter {}
const emitter = new MyEmitter();

emitter.on("save", (data) => console.log("保存:", data));
emitter.emit("save", { id: 1 });

// 流:复制大文件
const fs = require("fs");
const readStream = fs.createReadStream("big.mp4");
const writeStream = fs.createWriteStream("copy.mp4");

readStream.pipe(writeStream);
writeStream.on("finish", () => console.log("复制完成"));
📚 JavaScript 语法速查
常用条目速查,完整版见对应教程章节。可复制代码到在线运行中测试。
写法 / 语法作用
let x = 1;声明变量(可重新赋值)
const y = 2;声明常量(不可重新赋值)
var 已过时旧式变量声明,建议用 let/const
if (条件) { } else { }条件判断
for (let i = 0; i < n; i++) { }循环
while (条件) { }条件循环
function fn(a, b) { return a + b; }函数声明
const fn = (a) => a + 1;箭头函数
array.push(x) / pop()数组尾部添加 / 删除
array.map(fn) / filter(fn)数组映射 / 过滤
obj.key / obj["key"]访问对象属性
JSON.stringify(obj)对象转 JSON 字符串
JSON.parse(str)JSON 字符串转对象
document.getElementById("id")按 id 取元素
document.querySelector("选择器")按选择器取第一个元素
element.textContent读写元素文本
element.innerHTML读写元素 HTML(慎用,防 XSS)
element.addEventListener("click", fn)绑定事件
console.log(x)控制台输出(调试)
setTimeout(fn, 1000)延迟执行(毫秒)
window.location.href当前页面地址(可赋值跳转)
localStorage.setItem("k", v)本地存储写入
localStorage.getItem("k")本地存储读取
new Promise((resolve, reject) => {})Promise 异步处理
async / await异步函数语法糖