Bài 4. Bất đồng bộ, event loop, sự kiện và stream

Một số khái niệm

Node.js chạy mã JavaScript trên một luồng. Khi gặp thao tác I/O, Node giao cho hệ điều hành/libuv và tiếp tục chạy mã khác; khi I/O xong, callback được xếp vào hàng đợi và event loop lấy ra chạy. Vì vậy: không viết vòng lặp tính toán nặng trong máy chủ (sẽ “đóng băng” mọi yêu cầu), hãy chuyển sang worker_threads hoặc dịch vụ riêng.

async/await và song song

import { setTimeout as cho } from 'node:timers/promises';

async function taiDiem(ma) { await cho(500); return { ma, diem: Math.round(Math.random() * 10) }; }

// Tuần tự: ~1500ms
for (const ma of ['SV1', 'SV2', 'SV3']) console.log(await taiDiem(ma));

// Song song: ~500ms
const kq = await Promise.all(['SV1', 'SV2', 'SV3'].map(taiDiem));

// Không dừng khi một tác vụ lỗi
const tatCa = await Promise.allSettled([taiDiem('SV1'), Promise.reject(new Error('Mạng lỗi'))]);
tatCa.forEach(r => console.log(r.status, r.value ?? r.reason.message));

// Xử lý lỗi
try { await fetch('https://khong-ton-tai.invalid'); }
catch (e) { console.error('Lỗi:', e.message); }

EventEmitter

import { EventEmitter } from 'node:events';
class LopHoc extends EventEmitter {
  themSinhVien(ten) { this.emit('them', ten); }
}
const lop = new LopHoc();
lop.on('them', ten => console.log('Chào mừng', ten));
lop.once('them', () => console.log('Sinh viên đầu tiên!'));
lop.themSinhVien('An'); lop.themSinhVien('Bình');

Rất nhiều đối tượng Node.js là EventEmitter: máy chủ HTTP (sự kiện request), stream (data, end), process (exit).

Stream: xử lý dữ liệu lớn

import { createReadStream, createWriteStream } from 'node:fs';
import { createGzip } from 'node:zlib';
import { pipeline } from 'node:stream/promises';
import readline from 'node:readline';

// Nén tệp log 2GB mà chỉ dùng vài MB bộ nhớ
await pipeline(createReadStream('nhat-ky.log'), createGzip(), createWriteStream('nhat-ky.log.gz'));

// Đọc CSV từng dòng
const rl = readline.createInterface({ input: createReadStream('diem.csv') });
let dem = 0;
for await (const dong of rl) { if (dem++ === 0) continue; const [ma, ten, diem] = dong.split(','); /* xử lý */ }
console.log('Đã đọc', dem - 1, 'dòng');

Stream chia dữ liệu thành từng khối nhỏ; pipeline nối các stream và tự xử lý lỗi, đóng tệp.