Change stream là gì?

Question

Accepted Answer

**Change stream** cho phép ứng dụng **đăng ký nhận các thay đổi real-time** trong dữ liệu MongoDB — nhận thông báo khi document được chèn, cập nhật, hoặc xóa. Chúng cho phép các tính năng phản ứng, hướng sự kiện (cập nhật real-time, đồng bộ, trigger) mà không cần polling cơ sở dữ liệu. Được xây dựng trên oplog của replica set.

## Theo dõi các thay đổi

```js
// theo dõi một collection để phát hiện thay đổi — nhận thông báo real-time
const changeStream = db.collection("orders").watch();

changeStream.on("change", (change) => {
  console.log(change.operationType);   // "insert", "update", "delete", "replace"
  console.log(change.fullDocument);     // document đã thay đổi (cho insert/update)
  // phản ứng: đẩy tới websocket, cập nhật cache, kích hoạt workflow, v.v.
});
```

Một change stream phát ra một sự kiện cho mỗi thay đổi (insert/update/delete), với chi tiết về cái gì đã thay đổi — để ứng dụng phản ứng real-time.

## Lọc và resume

```js
// chỉ theo dõi các thay đổi cụ thể với một filter aggregation pipeline
db.collection("orders").watch([
  { $match: { operationType: "insert", "fullDocument.status": "urgent" } }
]);

// resume từ nơi bạn đã dừng (chịu được mất kết nối)
db.collection("orders").watch([], { resumeAfter: lastChangeToken });
```

Bạn có thể **lọc** các thay đổi (chỉ theo dõi một số thao tác hoặc document) và **resume** sau khi mất kết nối (dùng một resume token) — khiến change stream chịu lỗi tốt.

## Các trường hợp sử dụng phổ biến

```text
✓ Tính năng REAL-TIME — đẩy cập nhật trực tiếp tới client (websocket) khi dữ liệu thay đổi
✓ ĐỒNG BỘ — giữ cache, search index (Elasticsearch), hoặc hệ thống khác đồng bộ
✓ Kiến trúc HƯỚNG SỰ KIỆN — kích hoạt workflow/thông báo khi dữ liệu thay đổi
✓ AUDIT — ghi log thay đổi; phân tích trên sửa đổi dữ liệu
→ Tất cả KHÔNG cần polling cơ sở dữ liệu lặp đi lặp lại (hiệu quả, real-time)
```

## Change stream vs polling

```text
❌ POLLING — liên tục truy vấn "cái gì đã thay đổi?" → kém hiệu quả, độ trễ, tải lên DB
✅ CHANGE STREAM — cơ sở dữ liệu ĐẨY các thay đổi tới bạn real-time → hiệu quả, tức thì
→ Cách đúng để phản ứng với thay đổi dữ liệu (yêu cầu một replica set).
```

## Tại sao điều này quan trọng

Change stream là một tính năng MongoDB giá trị để xây dựng **ứng dụng real-time, phản ứng, hướng sự kiện**, nên hiểu chúng là kiến thức cấp senior hữu ích cho ứng dụng hiện đại cần phản ứng dữ liệu trực tiếp.

Giá trị cốt lõi là cho phép ứng dụng **phản ứng với thay đổi dữ liệu real-time** — nhận thông báo đẩy khi document được chèn, cập nhật, hoặc xóa — vốn cung cấp các khả năng quan trọng: **tính năng real-time** (đẩy cập nhật trực tiếp tới client qua websocket khi dữ liệu thay đổi — một nhu cầu phổ biến cho ứng dụng cộng tác, dashboard, thông báo), **đồng bộ** (giữ cache, search index như Elasticsearch, hoặc các hệ thống khác nhất quán với MongoDB khi dữ liệu thay đổi), **kiến trúc hướng sự kiện** (kích hoạt workflow, thông báo, hoặc xử lý khi dữ liệu thay đổi), và **audit**.

Ưu điểm then chốt là làm tất cả điều này **mà không cần polling** — change stream cho cơ sở dữ liệu *đẩy* các thay đổi tới ứng dụng tức thì và hiệu quả, thay thế mẫu lãng phí, độ trễ cao của việc liên tục truy vấn "cái gì đã thay đổi?" (vốn tải lên cơ sở dữ liệu và có độ trễ).

Hiểu cách theo dõi collection, lọc các thay đổi (chỉ các thao tác/document liên quan), và resume sau khi mất kết nối (dùng resume token cho khả năng chịu lỗi) bao quát việc sử dụng thực tế.

Biết rằng change stream yêu cầu một replica set cũng liên quan.

Vì phản ứng real-time và giữ các hệ thống đồng bộ ngày càng là nhu cầu ứng dụng quan trọng, và vì change stream cung cấp một cách dựa-trên-đẩy hiệu quả để phản ứng với thay đổi dữ liệu MongoDB (tốt hơn nhiều polling), nên hiểu change stream — chúng làm gì, các trường hợp sử dụng (tính năng real-time, đồng bộ, xử lý hướng sự kiện), khả năng resume/lọc, và ưu điểm so với polling — là kiến thức cấp senior giá trị để xây dựng ứng dụng MongoDB hiện đại, phản ứng, một tính năng hữu ích cho nhu cầu phổ biến phản hồi với thay đổi dữ liệu real-time và một chủ đề phản ánh sự hiểu biết về các mẫu ứng dụng hướng sự kiện và real-time với MongoDB.