NodeJS使用async await处理商品颜色模型时出现数据偶发缺失问题

AI 小北

2026-10-4

问题原因

偶发空值的问题确实由async/await的错误使用导致。Array.prototype.forEach 不对传入的异步函数做等待处理，遍历启动后所有数据库读写操作还在执行时，后续的product.save()就已经触发，此时colorsDocIds还未被赋值，就会出现空值情况。

修复方案

方案1：for...of串行执行（适合数据量较小的场景）

按顺序执行每个颜色的查询/写入逻辑，可读性更高：

const colorsArray = colors.split(',').map((color) => color.trim());
const colorsDocIds = [];

for (const color of colorsArray) {
  const colorDocument = await Color.findOne({ color });

  if (!colorDocument) {
    // 注意product字段如果是数组类型，初始化要传入数组格式
    const newColor = await Color.create({ product: [product.id], color });
    colorsDocIds.push(newColor.id);
  } else {
    colorsDocIds.push(colorDocument.id);
    colorDocument.product.push(product.id);
    await colorDocument.save();
  }
}

product.colors = colorsDocIds;
await product.save();

方案2：Promise.all并行执行（性能更高，适合数据量较大的场景）

同时启动所有异步任务，全部完成后再执行后续保存逻辑：

const colorsArray = colors.split(',').map((color) => color.trim());
const colorPromises = colorsArray.map(async (color) => {
  const colorDocument = await Color.findOne({ color });

  if (!colorDocument) {
    const newColor = await Color.create({ product: [product.id], color });
    return newColor.id;
  } else {
    colorDocument.product.push(product.id);
    await colorDocument.save();
    return colorDocument.id;
  }
});

// 等待所有异步任务执行完成，直接拿到完整的id数组
const colorsDocIds = await Promise.all(colorPromises);

product.colors = colorsDocIds;
await product.save();