Dự án: dịch vụ backend nhỏ

cây thư mục dự án - mỗi file một việc

kho-ca/
├── package.json   # "type": "module" + scripts start/test
├── db.js          # TẦNG DỮ LIỆU: hàm thuần trên DB (không đụng HTTP)
├── server.js      # HTTP: định tuyến REST, gọi xuống db.js + giao việc cho worker
├── worker.js      # VIỆC NỀN: chạy luồng riêng, nhận việc qua message
└── db.test.js     # TEST: kiểm tầng dữ liệu trên kho :memory:

package.json - npm start chạy server, npm test chạy mọi *.test.js

{
  "name": "kho-ca",
  "version": "1.0.0",
  "type": "module",
  "scripts": {
    "start": "node server.js",
    "test": "node --test"
  }
}

db.js - tầng dữ liệu, không một dòng HTTP nào ở đây

import { DatabaseSync } from "node:sqlite";

// Mở (hoặc tạo) tệp kho-ca.db rồi dựng bảng nếu chưa có.
// Trả về một object gồm DB và các hàm truy vấn - gọi từ server/test.
export function moKho(duongDan = "kho-ca.db") {
  const db = new DatabaseSync(duongDan);
  db.exec(`CREATE TABLE IF NOT EXISTS ca (
    id         INTEGER PRIMARY KEY AUTOINCREMENT,
    ten        TEXT NOT NULL,
    khoi_luong REAL NOT NULL
  )`);

  // prepare MỘT lần, dùng lại nhiều lần (nhanh + an toàn injection)
  const stmtThem = db.prepare("INSERT INTO ca (ten, khoi_luong) VALUES (?, ?)");
  const stmtDs = db.prepare("SELECT id, ten, khoi_luong FROM ca ORDER BY id");
  const stmtLay = db.prepare("SELECT id, ten, khoi_luong FROM ca WHERE id = ?");
  const stmtMua = db.prepare("UPDATE ca SET khoi_luong = ? WHERE id = ?");

  return {
    db,
    // Tầng dữ liệu là hàm THUẦN trên DB: không đụng HTTP, không in gì → test thẳng.
    themCa(ten, khoiLuong) {
      const kq = stmtThem.run(ten, khoiLuong);
      return { id: Number(kq.lastInsertRowid), ten, khoi_luong: khoiLuong };
    },
    dsCa() {
      return stmtDs.all();
    },
    layCa(id) {
      return stmtLay.get(id) ?? null; // không có → null (server dịch thành 404)
    },
    datMua(id, khoiLuongMoi) {
      return stmtMua.run(khoiLuongMoi, id).changes; // số dòng đổi: 0 = không có id đó
    }
  };
}

demo-db.js - gọi thẳng tầng dữ liệu (lược 2 dòng cảnh báo experimental ở cuối)

import { moKho } from "./db.js";

const kho = moKho("kho-ca.db");
console.log(kho.themCa("cá thu", 2.4));
console.log(kho.themCa("cá hồi", 5.2));
console.log("cả kho:", kho.dsCa());
console.log("lấy id 2:", kho.layCa(2));
console.log("số dòng đổi:", kho.datMua(1, 2.6));
kho.db.close();

{ id: 1, ten: 'cá thu', khoi_luong: 2.4 }
{ id: 2, ten: 'cá hồi', khoi_luong: 5.2 }
cả kho: [
  [Object: null prototype] { id: 1, ten: 'cá thu', khoi_luong: 2.4 },
  [Object: null prototype] { id: 2, ten: 'cá hồi', khoi_luong: 5.2 }
]
lấy id 2: [Object: null prototype] { id: 2, ten: 'cá hồi', khoi_luong: 5.2 }
số dòng đổi: 1

server.js - REST API: định tuyến tay, gọi xuống kho (worker ở Bước 4)

import { createServer } from "node:http";
import { Worker } from "node:worker_threads";
import { moKho } from "./db.js";

const kho = moKho("kho-ca.db");
const worker = new Worker("./worker.js"); // một worker chạy nền - xem Bước 4

function tinhTongKg(dsCa) { // giao việc cho worker, chờ đúng một message - Bước 4
  return new Promise((ok) => {
    worker.once("message", ok);
    worker.postMessage(dsCa);
  });
}

function traJSON(res, status, duLieu) {
  const body = JSON.stringify(duLieu);
  res.writeHead(status, {
    "Content-Type": "application/json; charset=utf-8",
    "Content-Length": Buffer.byteLength(body)
  });
  res.end(body);
}

const server = createServer(async (req, res) => {
  const url = new URL(req.url, `http://${req.headers.host}`);
  const khopId = url.pathname.match(/^\/ca\/(\d+)$/); // "/ca/2" -> khopId[1] là "2"

  if (req.method === "GET" && url.pathname === "/bao-cao") {        // Bước 4
    return traJSON(res, 200, await tinhTongKg(kho.dsCa()));
  }

  if (req.method === "GET" && url.pathname === "/ca") return traJSON(res, 200, kho.dsCa());

  if (req.method === "POST" && url.pathname === "/ca") {
    const chunks = [];
    for await (const chunk of req) chunks.push(chunk); // gom body: req là Readable
    try {
      const { ten, khoiLuong } = JSON.parse(Buffer.concat(chunks).toString("utf8"));
      return traJSON(res, 201, kho.themCa(ten, khoiLuong));
    } catch {
      return traJSON(res, 400, { loi: "body không phải JSON hợp lệ" });
    }
  }

  if (req.method === "GET" && khopId) {
    const ca = kho.layCa(Number(khopId[1]));
    return ca ? traJSON(res, 200, ca) : traJSON(res, 404, { loi: "không có cá id " + khopId[1] });
  }

  return traJSON(res, 404, { loi: "không có endpoint này" });
});

server.listen(3000, () => console.log("Kho Cá mở cửa: http://localhost:3000"));

phien-fetch.js - terminal thứ hai (chạy trên kho-ca.db vừa tạo mới): đủ 200 / 201 / 404 / 400 / báo cáo

async function goi(method, duong, body) {
  const res = await fetch("http://localhost:3000" + duong, {
    method,
    headers: body ? { "Content-Type": "application/json" } : {},
    body
  });
  console.log(method, duong, "->", res.status, await res.text());
}

await goi("GET", "/ca");
await goi("POST", "/ca", JSON.stringify({ ten: "cá thu", khoiLuong: 2.4 }));
await goi("POST", "/ca", JSON.stringify({ ten: "cá hồi", khoiLuong: 5.2 }));
await goi("GET", "/ca/1");
await goi("GET", "/ca/99");
await goi("POST", "/ca", "đây không phải JSON");
await goi("GET", "/bao-cao");

GET /ca -> 200 []
POST /ca -> 201 {"id":1,"ten":"cá thu","khoi_luong":2.4}
POST /ca -> 201 {"id":2,"ten":"cá hồi","khoi_luong":5.2}
GET /ca/1 -> 200 {"id":1,"ten":"cá thu","khoi_luong":2.4}
GET /ca/99 -> 404 {"loi":"không có cá id 99"}
POST /ca -> 400 {"loi":"body không phải JSON hợp lệ"}
GET /bao-cao -> 200 {"soCa":2,"tongKg":7.6}

worker.js - chạy trong luồng RIÊNG, nhận việc qua message

import { parentPort } from "node:worker_threads";

// Worker chạy trong luồng RIÊNG: nhận danh sách cá qua message,
// cộng tổng khối lượng (việc CPU mẫu) rồi gửi kết quả về luồng chính.
// Luồng phục vụ request không phải đứng chờ phép tính này.
parentPort.on("message", (dsCa) => {
  const tongKg = dsCa.reduce((tong, ca) => tong + ca.khoi_luong, 0);
  parentPort.postMessage({ soCa: dsCa.length, tongKg });
});

trích từ server.js - giao việc cho worker rồi await kết quả

const worker = new Worker("./worker.js"); // tạo MỘT lần, dùng lại cho mọi request

function tinhTongKg(dsCa) {
  return new Promise((ok) => {
    worker.once("message", ok);  // chờ đúng một message trả về
    worker.postMessage(dsCa);    // giao việc - luồng chính chạy tiếp ngay
  });
}

// trong handler:  return traJSON(res, 200, await tinhTongKg(kho.dsCa()));

db.test.js - kiểm tầng dữ liệu trên kho :memory: (lược 2 dòng cảnh báo experimental)

import { test } from "node:test";
import assert from "node:assert/strict";
import { moKho } from "./db.js";

// ':memory:' - kho tạm trong RAM, mỗi test một kho sạch, không đụng đĩa thật.
test("themCa rồi dsCa trả đúng con cá vừa thêm", () => {
  const kho = moKho(":memory:");
  const ca = kho.themCa("cá thu", 2.4);
  assert.equal(ca.id, 1);
  const ds = kho.dsCa();
  assert.equal(ds.length, 1);
  assert.equal(ds[0].ten, "cá thu"); // node:sqlite trả object null-prototype → so từng cột
  assert.equal(ds[0].khoi_luong, 2.4);
});

test("layCa trả null khi không có id đó", () => {
  const kho = moKho(":memory:");
  kho.themCa("cá hồi", 5.2);
  assert.equal(kho.layCa(99), null);
});

test("datMua đổi khối lượng và đếm đúng số dòng", () => {
  const kho = moKho(":memory:");
  const ca = kho.themCa("cá cơm", 0.1);
  assert.equal(kho.datMua(ca.id, 0.3), 1); // 1 dòng đổi
  assert.equal(kho.datMua(99, 0.3), 0);    // id không có → 0 dòng
  assert.equal(kho.layCa(ca.id).khoi_luong, 0.3);
});

✔ themCa rồi dsCa trả đúng con cá vừa thêm (1.4ms)
✔ layCa trả null khi không có id đó (0.5ms)
✔ datMua đổi khối lượng và đếm đúng số dòng (0.5ms)
ℹ tests 3
ℹ pass 3
ℹ fail 0

thêm vào cuối server.js - graceful shutdown

// Graceful shutdown: nhận tín hiệu → ngừng nhận request mới → đóng worker + DB → thoát.
function dongGonGang() {
  console.log("\nNhận tín hiệu dừng - đóng gọn gàng...");
  server.close(() => {       // 1. ngừng nhận kết nối MỚI, chờ request đang dở xong
    worker.terminate();      // 2. đóng worker chạy nền
    kho.db.close();          // 3. đóng cơ sở dữ liệu
    console.log("Đã đóng server, worker và DB. Tạm biệt!");
    process.exit(0);         // 4. dọn xong mới thoát, mã 0 = ổn
  });
}
process.on("SIGINT", dongGonGang);
process.on("SIGTERM", dongGonGang);

Kho Cá mở cửa: http://localhost:3000
^C
Nhận tín hiệu dừng - đóng gọn gàng...
Đã đóng server, worker và DB. Tạm biệt!