Node.js 基础复习 - 速通版 02

// CommonJS（Node 默认，历史包袱）const fs = require('node:fs');module.exports = { sayHi() {} };// ESM（现代标准，浏览器 / Node 通用）import fs from 'node:fs';export function sayHi() {}

// 特点：代码执行到  require() 这一行才加载模块，同步阻塞。// 可以放在条件判断、函数内部。if (true) {  const util = require('./util') // ✅ 合法，运行到这里才加载  console.log(util.msg)}

// 特点：JS 引擎执行代码前扫描所有静态 import，提前解析依赖。// 静态 import不能放在 if / 函数里面。// if(true) { import {msg} from './util' } // ❌ 语法报错！静态import不能写if里import { msg } from './util' // ✅ 只能写顶层// 想要条件加载，用动态 import()，它返回Promiseif(true) {  const util = await import('./util') // ✅ 动态import，运行时异步加载  console.log(util.msg)}

// util.cjslet count = 1module.exports = {  count}setTimeout(()=>{  count = 100}, 100)// main.cjsconst m = require('./util')console.log(m.count) // 1setTimeout(()=>{  console.log(m.count) // 仍然是1！不会变成100（简单类型值拷贝）},200)

// util.cjslet obj = {count:1}module.exports = {  obj}setTimeout(()=> obj.count=100,100)// main.cjsconst m = require('./util')// 200ms后 m.obj.count =>100，拷贝的是对象引用，不是基础值

// util.mjsexport let count = 1setTimeout(()=>{  count = 100},100)// main.mjsimport { count } from './util'console.log(count) // 1setTimeout(()=>{  console.log(count) // ✅ 100！自动同步，live binding},200)

console.log(this === module.exports) // truethis.name = "cjs"console.log(module.exports.name) // cjs

// esm.mjsconsole.log(this) // undefined

// xxx.cjsconsole.log(__filename) // 当前文件绝对路径console.log(__dirname)  // 当前文件所在目录const fs = require("fs") // require直接可用

// xxx.mjsimport { fileURLToPath } from 'node:url'import { dirname, join } from 'node:path'const __filename = fileURLToPath(import.meta.url)const __dirname = dirname(__filename)console.log(__filename, __dirname)

// util.cjsexports.foo = ()=>{}exports.bar = ()=>{}// main.cjsconst { foo } = require('./util')// 打包时：bar 函数代码依旧被打包进去，删不掉

// util.mjsexport const foo = ()=>{}export const bar = ()=>{}// main.mjsimport { foo } from './util'// bar没有被引入，打包时直接删掉bar代码，减少包体积

// counter.jslet count = 0;module.exports.add = () => ++count;module.exports.get = () => count;// main.jsconst a = require('./counter');const b = require('./counter');  // 同一个实例！a.add(); a.add();console.log(b.get());  // 2，不是 1// 缓存对象挂在 require.cache，key 是文件绝对路径

// util.cjs 【CommonJS模块】const hello = "来自CJS的hello"function sayHi() {  console.log("hi from cjs")}module.exports = {  hello,  sayHi}// main.mjs 【ESM模块，package.json 需要 "type":"module"】// ✅ ESM import 引入 CJSimport cjsMod from './util.cjs'console.log(cjsMod.hello) // 来自CJS的hellocjsMod.sayHi() // hi from cjs

// main.mjsimport { hello, sayHi } from './util.cjs'console.log(hello)

// util.cjsmodule.exports = 123// main.mjsimport num from './util.cjs'console.log(num) // 123

// 旧版本// CJS 旧版本写法，只能异步const m = await import('./esm.mjs') // 异步，返回Promise

// 新版本（22.12+）// esm.mjs （ESM模块，package.json "type":"module"）export const msg = "我是ESM模块"// ⚠️ 重点：ESM内部**不能有顶层 await**！// 如果有 top-level await，// require 加载直接抛 ERR_REQUIRE_ASYNC_MODULE// index.cjs（CommonJS模块）const esmModule = require('./esm.mjs') // ✅ Node>=22.12 可以直接写console.log(esmModule.msg) // 我是ESM模块

import path from 'node:path';path.join('src', 'index.js');        // 拼接（相对/绝对都行）path.resolve('src', 'index.js');     // 基于 cwd 解析成绝对路径path.basename('/a/b/c.js');             // 'c.js'

path.dirname('/a/b/c.js');     // '/a/b'path.extname('/a/b/c.js');     // '.js'// { dir:'/a/b', base:'c.js', name:'c', ext:'.js' }path.parse('/a/b/c.js');  path.join('/a', 'b', '..', 'c');  // '/a/c'（自动规范化）

import { readFileSync } from 'node:fs';import * as fsp from 'node:fs/promises';// 同步：阻塞主线程，只在启动配置加载时用const config = readFileSync('./config.json', 'utf8');// 异步 Promise 版（推荐）：不阻塞事件循环const data = await fsp.readFile('./data.txt', 'utf8');

// 常用 fs 操作（Promise 版）import * as fsp from 'node:fs/promises';await fsp.mkdir('./new-dir', { recursive: true });   // 递归创建目录await fsp.readdir('./src');   // 列目录 → ['a.js','b.js']await fsp.writeFile('./out.txt', 'hello');    // 写文件await fsp.rm('./old', { recursive: true, force: true }); // 删除目录// stat：判断是文件还是目录const s = await fsp.stat('./a.txt');s.size;          // 字节数s.isFile();       // trues.isDirectory(); // false

import http from 'node:http';const server = http.createServer((req, res) => {  // req:  IncomingMessage（url, method, headers）  // res:  ServerResponse（writeHead / end）  res.writeHead(200, { 'Content-Type': 'application/json' });  res.end(JSON.stringify({ url: req.url, method: req.method }));});server.listen(3000, () => console.log('listening on :3000'));

import http from 'node:http';import { URL } from 'node:url';const server = http.createServer(async (req, res) => {  // new URL(urlString, baseURL)  // 例如浏览器访问：  // `http://localhost:3000/api/users?name=zhangsan`  // `req.url` 的值是：`/api/users?id=xxxxxx`  const url = new URL(req.url, 'http://localhost');    // GET /users?id=1  if (req.method === 'GET' && url.pathname === '/users') {    const id = url.searchParams.get('id');    res.writeHead(200, { 'Content-Type': 'application/json' });    return res.end(JSON.stringify({ id, name: 'Tom' }));  }  // POST /users —— req 是 Readable Stream，手动拼 chunk  if (req.method === 'POST' && url.pathname === '/users') {    const chunks = [];    for await (const chunk of req) chunks.push(chunk);    const body = JSON.parse( Buffer.concat(chunks).toString() );    res.writeHead(201, { 'Content-Type': 'application/json' });    return res.end(JSON.stringify({ created: body }));  }  res.writeHead(404, { 'Content-Type': 'application/json' });  res.end(JSON.stringify({ error: 'Not Found' }));});server.listen(3000)

// 推荐：pipe 自动处理背压import { createReadStream, createWriteStream } from 'node:fs';import { gzip } from 'node:zlib';createReadStream('big.log')  // readable stream  .pipe(gzip())   // transform stream  .pipe(createWriteStream('big.log.gz'));  // writable stream

import { pipeline } from 'node:stream/promises';import { createReadStream, createWriteStream } from 'node:fs';import { gzip } from 'node:zlib';// pipeline 会在任何一个流报错时自动销毁所有流，防止内存泄漏await pipeline(  createReadStream('big.log'),  gzip(),  createWriteStream('big.log.gz'));console.log('压缩完成');  // 压缩文件完成

import { createReadStream } from 'node:fs';const readable = createReadStream(  'large.txt',   { encoding: 'utf8' });readable.on('data', (chunk) => {  console.log('收到一块：', chunk.length);  // chunk 默认是 Buffer，指定 encoding 后是 string});readable.on('end', () => console.log('读完了'));readable.on('error', (err) => console.error(err));

import http from 'node:http';import { createReadStream } from 'node:fs';const server = http.createServer((req, res) => {  res.writeHead(200, { 'Content-Type': 'application/pdf' });  // 用 pipe 把 文件流 直接写到响应，不会占满内存  createReadStream('./report.pdf').pipe(res);})server.listen(8080);

// server.js TCP服务端，net.Socket 是原生 Dupleximport net from 'node:net'const server = net.createServer((socket) => {  console.log('客户端连接成功')  // socket 是 Duplex：可读 + 可写，读写通道独立  // 可读：监听客户端发来的数据  socket.on('data', (chunk) => {    console.log('服务端收到客户端：', chunk.toString())  })  // 可写：发消息给客户端  socket.write('服务端：hi, I am Duplex net.Socket\n')  socket.on('close', () => {    console.log('连接断开')  })})server.listen(8080, '127.0.0.1', () => {  console.log('TCP server listen on 127.0.0.1:8080')})

// client.js TCP客户端，clientSocket同样是Dupleximport net from 'net'const clientSocket = net.connect(8080, '127.0.0.1')// 可读：接收服务端推送clientSocket.on('data', (chunk) => {  console.log('客户端收到服务端：', chunk.toString())})// 可写：发送给服务端clientSocket.write('客户端 hello')clientSocket.on('close', () => {  console.log('客户端连接关闭')})