如何在MongoDB中实现数据的实时推送功能

const { MongoClient } = require('mongodb');

// 创建数据库连接
async function connect() {
  const uri = 'mongodb://localhost:27017';
  const client = new MongoClient(uri);

  try {
    // 连接数据库
    await client.connect();

    // 监听指定集合的变化
    const collection = client.db('mydb').collection('mycollection');
    const changeStream = collection.watch();

    // 处理变化的回调函数
    changeStream.on('change', (change) => {
      // 推送变化的数据给客户端，可以通过WEBSocket或其他方式发送
      console.log('数据发生变化:', change);
    });

    // 等待变化的发生
    await new Promise((resolve) => setTimeout(resolve, 10000));

    // 关闭数据库连接
    await client.close();
  } catch (error) {
    console.error('连接数据库出错:', error);
  }
}

// 启动推送功能
connect();