如何彻底解决Parse Server并发场景下的数据重复问题？

我太懂这种挫败感了——明明在beforeSave云代码里加了重复检查，甚至还加了外部中间件前置校验，结果高并发一来，重复的Category还是冒出来了。核心问题其实出在应用层校验的非原子性：多个请求可能同时通过你的检查逻辑，在第一个请求把数据写入数据库之前，第二个请求已经完成了“是否存在”的判断，最后就导致了重复写入。

下面给你几个从根本上解决问题的方案，按优先级排序：

1. 数据库层面添加唯一约束（最可靠的兜底方案） #

不管应用层做多少校验，数据库层面的唯一索引才是阻止重复数据的最后一道防线。以MongoDB为例（Parse Server最常用的数据库），你可以给Category类的唯一标识字段（比如name）添加唯一索引：

# 在MongoDB shell中执行
db.Category.createIndex({ name: 1 }, { unique: true })

如果是复合字段唯一（比如name+parentId），就创建复合唯一索引：

db.Category.createIndex({ name: 1, parentId: 1 }, { unique: true })

然后修改你的beforeSave云代码，捕获数据库抛出的唯一索引冲突错误，给客户端返回友好提示：

Parse.Cloud.beforeSave("Category", async (request, response) => {
  const newCategory = request.obj;
  const uniqueName = newCategory.get("name");

  try {
    // 先做应用层检查（提前拦截大部分重复请求，减少数据库压力）
    const query = new Parse.Query("Category");
    query.equalTo("name", uniqueName);
    const existingCategory = await query.first({ useMasterKey: true });

    if (existingCategory) {
      return response.error(`Category "${uniqueName}" already exists`);
    }

    // 应用层检查通过，交给数据库的唯一索引兜底
    response.success();
  } catch (error) {
    // 捕获MongoDB唯一索引冲突错误（错误码11000/11001）
    if (error.code === 11000 || error.code === 11001) {
      response.error(`Category "${uniqueName}" already exists`);
    } else {
      response.error(`Failed to check duplicate: ${error.message}`);
    }
  }
});

2. 使用原子化的查询+保存操作 #

如果你的Parse Server版本支持MongoDB事务（Parse Server 3.0+），可以在beforeSave里用事务把“检查是否存在”和“保存新对象”变成一个原子操作，确保中间不会被其他请求打断：

Parse.Cloud.beforeSave("Category", async (request, response) => {
  const session = await Parse.Cloud.startSession();
  const uniqueName = request.obj.get("name");

  try {
    await Parse.Cloud.runTransaction(async (transaction) => {
      // 在事务内查询是否存在
      const query = new Parse.Query("Category").equalTo("name", uniqueName);
      const existing = await query.first({ session, useMasterKey: true });

      if (existing) {
        throw new Error(`Category "${uniqueName}" already exists`);
      }

      // 事务内保存新对象
      await transaction.save(request.obj, { useMasterKey: true });
    });

    response.success();
  } catch (error) {
    response.error(error.message);
  } finally {
    await session.end();
  }
});

3. 分布式锁（多实例部署场景） #

如果你的Parse Server是多实例部署的，上面的方法可能还不够——因为不同实例的请求可能同时进入事务。这时候可以用Redis之类的分布式锁，在处理请求前先获取锁，确保同一时间只有一个请求能处理相同的Category创建：

// 假设你已经在Parse Server里集成了Redis客户端
const redis = require("redis");
const client = redis.createClient();

Parse.Cloud.beforeSave("Category", async (request, response) => {
  const uniqueName = request.obj.get("name");
  const lockKey = `category_lock:${uniqueName}`;
  const lockTTL = 5000; // 锁的过期时间，防止死锁

  try {
    // 尝试获取锁
    const lockAcquired = await client.set(lockKey, "locked", {
      NX: true,
      PX: lockTTL
    });

    if (!lockAcquired) {
      return response.error(`Category "${uniqueName}" is being created, please try again later`);
    }

    // 锁获取成功，执行检查和保存逻辑
    const query = new Parse.Query("Category").equalTo("name", uniqueName);
    const existing = await query.first({ useMasterKey: true });

    if (existing) {
      return response.error(`Category "${uniqueName}" already exists`);
    }

    response.success();
  } catch (error) {
    response.error(`Failed to process request: ${error.message}`);
  } finally {
    // 释放锁
    await client.del(lockKey);
  }
});

关键提醒 #

• 先清理已存在的重复数据，再添加数据库唯一索引，否则索引创建会失败。
• 应用层校验还是要保留，能减少数据库的压力，避免频繁触发索引冲突错误。
• 如果是复合唯一字段，要确保所有相关字段都被包含在索引里。

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