Mongoose how to listen for collection changes

在使用 Mongoose 进行 MongoDB 数据管理时，如果需要监听数据集合的更改，我们主要可以使用以下两种方法：

1. 使用 Change Streams

Change Streams 是 MongoDB 3.6+ 提供的功能，允许应用程序访问实时数据更改，而无需轮询集合的更改。Mongoose 通过其 API 支持这一功能，可以非常方便地实现对集合更改的监听。

实现示例：

假设我们有一个名为 Product 的模型，我们希望监听该模型的更改：

javascript
const mongoose = require('mongoose');
const Product = require('./models/product'); // 引入你的模型

// 连接数据库
mongoose.connect('mongodb://localhost:27017/yourdb', {
  useNewUrlParser: true,
  useUnifiedTopology: true,
});

const changeStream = Product.watch();

changeStream.on('change', (change) => {
  console.log('Change detected:', change);
  // 你可以根据 change.operationType 类型来做不同的业务处理
  // 例如 'insert', 'delete', 'update', 'replace' 等
});

这个示例中，Product.watch() 方法创建了一个监听当前 Product 集合更改的 stream，任何对 Product 集合的更改都会触发 change 事件，并通过回调函数进行处理。

2. 使用 Middleware (中间件)

Mongoose 提供了中间件的功能，可以在执行数据库操作如保存（save）、更新（update）之前或之后运行你的代码。通过中间件，你可以在数据更改时执行特定的逻辑。

实现示例：

javascript
const ProductSchema = new mongoose.Schema({
  name: String,
  price: Number,
});

// 使用 pre 中间件，在数据保存前执行
ProductSchema.pre('save', function (next) {
  console.log('A new product is about to be saved:', this);
  next();
});

// 使用 post 中间件，在数据保存后执行
ProductSchema.post('save', function(doc) {
  console.log('A product has been saved:', doc);
});

const Product = mongoose.model('Product', ProductSchema);

在这个例子中，每当一个 Product 实例被保存时，pre('save', ...) 中间件首先被调用，然后是 post('save', ...) 中间件。通过这种方式，你可以在数据更改前后加入日志记录、错误检查或其他业务逻辑。

总结

以上两种方法各有其用途和优势。Change Streams 非常适合于需要实时反馈的应用场景，而 Middleware 则适用于需要在数据操作前后插入特定逻辑的场景。根据具体需求选择合适的方法来监听和响应数据的更改。