node.js - 来自多个进程的 Mongodb 查询；如何实现原子性？

Question

我有一个 mongodb 数据库，其中有多个 Node 进程读取和写入文档。我想知道我怎样才能做到这一点，所以一次只有一个进程可以处理一个文档。 (某种锁定)在进程完成更新该条目后释放。

我的应用程序应该执行以下操作:

• 使用光标逐一浏览每个条目。

• (锁定条目以便其他进程无法使用它)

• 从第三方网站获取信息。

• 计算新信息并更新条目。
• (解锁文档)

此外，在解锁文档后的几个小时内，其他进程将不需要更新它。

稍后我想设置多个 mongodb 集群，这样我就可以减少数据库的负载。因此该解决方案应该适用于单个和多个数据库服务器。或者至少使用多个 mongo 服务器。

Answer 1

一个不涉及锁的优雅解决方案是:

• 将 version 属性添加到您的文档。

• 更新文档时，增加 version 属性。

• 更新文档时，在查找查询中包含最后读取的版本。如果您的文档已在别处更新，查找查询将不会产生任何结果，您的更新将失败。

• 如果更新失败，您可以重试该操作。

我过去使用这种模式取得了巨大的成功。

例子

假设您有一个文档 {_id: 123, version: 1}。

假设现在您有 3 个 Mongo 客户端同时执行 db.collection.findAndModify({ query: {_id: 123, version: 1}, update: { $inc: 1 }}); .

第一个更新将应用，其余的将失败。为什么？因为现在 version 是 2，query 包含 version: 1。