如何使用 MongoDB 的 Change Streams？

推荐答案

// www.javascriptcn.com code example
const { MongoClient } = require('mongodb');

async function watchCollection() {
    const uri = 'mongodb://localhost:27017';
    const client = new MongoClient(uri);

    try {
        await client.connect();
        const database = client.db('testdb');
        const collection = database.collection('testcollection');

        const changeStream = collection.watch();

        changeStream.on('change', (change) => {
            console.log('Change detected:', change);
        });

        // Keep the change stream open
        await new Promise(() => {});
    } finally {
        await client.close();
    }
}

watchCollection().catch(console.error);

本题详细解读

什么是 Change Streams？

Change Streams 是 MongoDB 提供的一种功能，允许应用程序实时监听数据库中的变化。它类似于数据库触发器，但更加灵活和强大。通过 Change Streams，你可以监听集合中的插入、更新、删除等操作，并在这些操作发生时立即得到通知。

如何使用 Change Streams？

1. 连接到 MongoDB 数据库：首先，你需要使用 MongoDB 的客户端库（如 mongodb 或 mongoose）连接到你的数据库。

2. 选择要监听的集合：在连接成功后，选择你想要监听的数据库和集合。

3. 创建 Change Stream：使用 collection.watch() 方法创建一个 Change Stream。这个方法返回一个可读流，你可以监听这个流上的 change 事件。

4. 处理变化事件：当集合中的数据发生变化时，change 事件会被触发，你可以在事件处理函数中处理这些变化。

5. 保持 Change Stream 打开：为了持续监听变化，你需要确保 Change Stream 保持打开状态。可以通过 Promise 或其他方式阻止程序退出。

示例代码解析

• 连接数据库：使用 MongoClient 连接到 MongoDB 实例。
• 选择集合：通过 client.db('testdb').collection('testcollection') 选择要监听的集合。
• 创建 Change Stream：使用 collection.watch() 创建 Change Stream。
• 监听变化：通过 changeStream.on('change', callback) 监听变化事件，并在回调函数中处理变化。
• 保持流打开：使用 Promise 保持程序运行，以便持续监听变化。

注意事项

• 权限：使用 Change Streams 需要适当的权限，确保你的 MongoDB 用户有 changeStream 权限。
• 性能：Change Streams 会占用一定的系统资源，特别是在高并发的场景下，需要合理使用。
• 版本兼容性：Change Streams 需要 MongoDB 3.6 及以上版本，并且只能在副本集或分片集群中使用。