【五分钟了解MongoDB 1】Change Stream 和MongoDB 4.x

MongoDB中文社区，一个mongoers都会来的社区（微信公众号：mongoing-mongoing）

充分获知数据库的数据变动是从MongoDB向其他数据服务进行数据同步的关键点。与直接查询collection来获取数据变动相比，通过流式的方式进行监听会有效并及时的多。这是一种非常强大的“响应式编程”模式。随着MongoDB的版本更新，流式的获取方式将变得原来越易用。

让我们来一同回顾一下。在MongoDB3.6之前，如果我们希望对MongoDB数据库中的数据变动进行监听，我们通常是通过 “监听并回放oplog”（“tail the oplog”）的模式（oplog表将会记录复制集中的数据变动）。在生产环境中这种方式（“监听并回放oplog”）通常较为复杂，并且难以保证其稳定与可靠性。

Change Streams and Collections

从MongoDB3.6开始支持的 Change Streams打破了这个僵局。 Change Streams使得数据的变动监听变得简单易用。以下是一个示例，该示例演示了通过Node.js对“movieDetails”表的变动监听。

javascript
const MongoClient = require("mongodb").MongoClient;
const uri = "MONGODBURL";
const client = new MongoClient(uri, { useNewUrlParser: true });
client.connect().then(db => {
 const changeStream = client.db("video").collection("movieDetails").watch();
 changeStream.on("change", next => {
   console.log(next);
 });
});