Node.js 使用 cluster/pm2 避免数据库竞争状况

Question

我有一个 Node 应用程序，它使用 pm2 以集群模式运行。

我还有一个函数可以检查特定行是否在数据库表中。如果该行丢失，它将创建该行，否则将设置并保存一个值。

对于 userId 和 groupId 的每个组合，我只需要一行。

function someFunction()={
  return Activation.findOne({ where: { userId: userId, groupId: groupId } })
    .then(activationObject => {
        if (!activationObject) {
          return Activation.create({ userId: userId, groupId: groupId, activationTime: sequelize.fn('NOW') })
        } else {
          activationObject.activationTime = sequelize.fn('NOW');
          return activationObject.save()
        }
    })      
}

在集群模式下运行节点时如何避免竞争条件？ 目前，如果第一个工作人员检查该行是否可用，而第二个同时检查都没有结果，最后我们有两个新创建的行而不是一个。

我知道 Sequelize 提供了一个

findOrCreate()

方法，但我想要一个简单易懂的示例。

Answer 1

最简单的方法是使用

UNIQUE

子句为

userId

和

groupId

的组合添加

ON CONFLICT REPLACE

约束，并始终创建新行而不是更新。这将导致新插入的行与新的

activationTime

替换旧行。

您还可以检查插入的行数来判断插入是否成功。

示例：

UNIQUE (userId, groupId) ON CONFLICT REPLACE

Answer 2

我迟到了，但是如果您在第一个查询中需要检查更复杂的事情，那么使用具有适当隔离级别的事务可能会有所帮助

这个答案给出了一个很好的例子：TypeORM Database Lock：请解释如何使用 setLock() 函数在 TypeORM 中使用数据库锁