NodeJS使用MongoDB时如何在指定文档全量变更状态后触发事件

以下几种方案都可以避免频繁全量扫描带来的高负载问题：

方案1：新增独立统计字段/集合，使用原子更新维护计数 #

• 新增一个专门的barcode_status_stats集合，每个barcode对应一条文档，结构示例：

{
  "barcode": "0666",
  "total_ongoing_count": 3, // 记录当前该barcode下actualStatus为onBranch的文档总数
  "is_all_sold": false
}

• 每次你更新任意文档的actualStatus从onBranch改为sold时，同步对对应barcode的统计文档执行原子减1操作：

// 以MongoDB语法为例
db.barcode_status_stats.updateOne(
  { barcode: updatedDoc.barcode },
  { $inc: { total_ongoing_count: -1 } }
)

• 减操作完成后直接判断total_ongoing_count是否等于0，等于0时直接触发自定义事件即可，全程不需要查询业务集合的全量数据，负载极低。

注意：初始化统计集合时要先批量统计所有barcode对应的初始onBranch数量，保证初始计数准确。

方案2：添加联合索引优化查询效率 #

你觉得每次查询负载高，本质是没有加合适的索引，只要给barcode和actualStatus加联合索引，查询剩余onBranch文档的操作时间复杂度是O(1)，完全不会带来过高负载：

• 先创建联合索引：

db.your_collection.createIndex({ barcode: 1, actualStatus: 1 })

• 每次更新完某一个barcode: '0666'的文档为sold后，只需要执行一次轻量查询：

const hasRemaining = db.your_collection.findOne({
  barcode: '0666',
  actualStatus: 'onBranch'
})
// 如果查询结果为null，说明所有都变为sold，触发自定义事件即可

这个查询只会走索引，不会扫描全表，性能损耗可以忽略不计。

方案3：使用数据库变更流（Change Stream）异步触发 #

如果你用的是MongoDB、PostgreSQL这类支持变更流的数据库，可以直接监听业务集合的更新事件，过滤出barcode: '0666'且actualStatus变为sold的事件，异步触发统计校验逻辑，不会阻塞主业务流程。

内容的提问来源于stack exchange，提问作者Lilian Bideau