Mongoose中watch方法仅触发插入事件的解决方案

在使用Mongoose的watch方法监控MongoDB集合变更时，开发者可能会遇到一个常见问题：变更流(change stream)只捕获到插入(insert)操作，而忽略了更新(update)和删除(delete)事件。这种现象通常与变更流配置和文档查询方式有关。

问题现象

当开发者使用如下代码设置变更监听时：

const s = Member.watch([
    {
        $match: {"fullDocument.user_id": user_id, "operationType": {$in: ["insert", "update", "delete"]}},
    }
]);

变更流只会对插入操作作出响应，而更新和删除操作则不会被捕获。这导致开发者无法获得完整的集合变更通知。

问题根源

这个问题的根本原因在于变更流的默认配置。MongoDB的变更流在默认情况下，对于更新和删除操作，不会返回完整的文档内容(fullDocument)。只有在插入操作时，变更流才会包含完整的文档信息。

当我们在$match阶段查询fullDocument.user_id字段时，由于更新和删除操作不包含fullDocument，这些变更事件就会被过滤掉，无法传递到监听器。

解决方案

要解决这个问题，需要在watch方法中显式配置fullDocument选项：

const s = Member.watch([
    {
        $match: {"fullDocument.user_id": user_id, "operationType": {$in: ["insert", "update", "delete"]}},
    }
], { fullDocument: 'updateLookup' });

通过设置fullDocument: 'updateLookup'，MongoDB会在变更事件中：

1. 对于插入操作：包含完整的文档内容
2. 对于更新操作：会查询集合获取更新后的完整文档
3. 对于删除操作：会包含删除前的文档信息

实现原理

updateLookup选项的工作原理是：

• 当文档被更新时，变更流会立即通知变更事件
• 然后MongoDB会执行一次额外的查询，获取文档的最新状态
• 最后将查询结果作为fullDocument包含在变更事件中

这种机制确保了无论操作类型如何，变更事件中都包含完整的文档信息，使得基于fullDocument的过滤条件能够正常工作。

最佳实践

在实际开发中，建议：

1. 明确指定需要监听的操作类型，避免不必要的事件处理
2. 对于更新操作密集的场景，注意updateLookup可能带来的性能影响
3. 考虑使用projection减少返回的数据量，提高效率
4. 合理设置resume token，确保断开连接后能恢复监听

通过正确配置变更流选项，开发者可以构建出稳定可靠的实时数据监控机制，满足各种业务场景的需求。