Neo4J并发请求报错：会话存在未关闭事务，求解决方案

架构老林

2026-7-28

解决Neo4J并发请求报错问题

报错核心原因

你遇到的错误本质是Neo4j的Session对象并非线程安全，若同一个Session被多个并发请求共享，或是Session上存在未正确收尾的事务，就会触发该报错。单请求正常但并发出错，大概率是代码里存在Session复用的情况，或是Session的生命周期管理不规范。

解决方案

1. 每个请求单独创建并销毁Session

绝对不能跨请求复用Session实例，每个请求都要单独创建Session，使用完毕后立即关闭。修改后的代码示例：

async function registerUser(database) {
  // 每个请求独立创建Session
  const session = driver.session({ database });
  try {
    // 执行Cypher查询（默认自动提交事务）
    const result = await session.run(`CREATE (u:USER {name:"Test Demo"}) RETURN u`);
    // 处理查询结果
    return result.records[0]?.get('u').properties;
  } catch (err) {
    // 捕获并抛出错误
    throw err;
  } finally {
    // 无论成功失败，确保关闭Session释放资源
    await session.close();
  }
}

2. 显式控制事务（可选，更严谨）

如果需要精准控制事务的提交与回滚，可使用显式事务模式，避免隐式事务的潜在问题：

async function registerUser(database) {
  const session = driver.session({ database });
  let transaction;
  try {
    // 开启显式事务
    transaction = session.beginTransaction();
    const result = await transaction.run(`CREATE (u:USER {name:"Test Demo"}) RETURN u`);
    // 提交事务
    await transaction.commit();
    return result.records[0]?.get('u').properties;
  } catch (err) {
    // 出错时回滚事务
    if (transaction) await transaction.rollback();
    throw err;
  } finally {
    await session.close();
  }
}