Gremlin ConcurrentModificationException致Node.js服务终止，无法触发catch块

核心问题 #

你遇到的服务崩溃，根源是未正确处理Gremlin异步操作的错误：.next()方法返回Promise，原代码中直接赋值变量却未等待异步操作完成，同步try/catch无法捕获异步Promise的reject，导致未处理的Promise拒绝直接终止Node.js进程。

修复方案 #

1. 将函数改为async类型，用await等待异步操作完成，让try/catch能捕获异步错误
2. 增加带退避策略的重试逻辑，避免无限递归或瞬间重试压垮服务
3. 限制最大重试次数，区分并发冲突异常和其他错误

修改后的代码示例 #

private async insertOrUpdateEdge(edge, retryCount = 0, maxRetries = 3) {
  const availableSince = new Date(edge['available_since']);

  try {
    // 构建插入边的查询逻辑
    let insertQuery = __.V(edge.from)
      .as('from')
      .V(edge.to)
      .addE(edge.label)
      .from_('from')
      .property(t.id, edge.id);

    insertQuery = this.addProperties(insertQuery, edge);

    // 用await等待异步操作完成，错误会被try/catch捕获
    await this.g
      .E(edge.id)
      .fold()
      .coalesce(unfold(), insertQuery)
      .has('available_since', P.gt(availableSince))
      .property('available_since', availableSince)
      .next();
  } catch (err) {
    // 仅针对并发修改异常且未达最大重试次数时重试
    if (err.code === 'ConcurrentModificationException' && retryCount < maxRetries) {
      // 指数退避：每次重试等待时间翻倍，减轻Neptune并发压力
      const delay = Math.pow(2, retryCount) * 100;
      await new Promise(resolve => setTimeout(resolve, delay));
      return this.insertOrUpdateEdge(edge, retryCount + 1, maxRetries);
    }
    // 其他错误或重试耗尽，记录日志并抛出
    console.error('边插入/更新失败:', err);
    throw err;
  }
}

关键改动说明 #

• 函数添加async声明，调用.next()时用await，确保异步错误能进入try/catch块
• 增加重试次数参数，限制最大重试次数，避免无限递归栈溢出
• 加入指数退避延迟，避免并发重试加剧Neptune的冲突问题
• 只针对ConcurrentModificationException进行重试，其他错误直接抛出或记录

你之前提到改为async Promise类型时错误率更高，大概率是因为只改了async却没加await，导致Promise错误依然未被处理，现在的写法能彻底解决错误捕获问题。

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