带writeConcern回调完成后Node MongoDB生产环境记录无法查询

这是个典型的生产/开发环境不一致问题，结合你用到的技术栈（MongoDB 3.2、node-mongodb-native 2.2、Node.js 4.x），我来拆解可能的原因和对应的解决办法：

核心差异点分析 #

开发环境一般是单节点MongoDB，而生产环境大概率是副本集部署——这是问题的关键。writeConcern: {w:1}仅保证主节点确认数据写入内存，但如果查询请求被路由到了还没同步完成的从节点，自然读不到刚写入的记录。此外，客户端驱动的配置或版本bug也可能触发这类异常。

具体解决方案 #

1. 强制查询路由到主节点 #

如果生产环境是副本集，默认读偏好（比如primaryPreferred）可能在主节点负载高时自动路由到从节点。显式指定查询走主节点，确保读取的是已确认写入的数据：

// 单查询设置读偏好
collection.find(yourQuery)
  .setReadPreference('primary')
  .toArray(function(err, docs) {
    // 处理查询结果
  });

// 全局连接时设置默认读偏好
MongoClient.connect(mongoUrl, {
  readPreference: 'primary'
}, function(err, db) {
  // 后续所有查询默认使用主节点
});

2. 确认批量操作的WriteConcern配置生效 #

确保批量操作确实应用了w:1的写入确认，避免代码中被其他配置覆盖：

// 初始化批量操作时指定WriteConcern
const bulk = collection.initializeUnorderedBulkOp({
  writeConcern: { w: 1 }
});

// 添加批量写入操作
bulk.insert(yourDoc1);
bulk.insert(yourDoc2);

// 执行后在回调中查询
bulk.execute(function(err, result) {
  if (err) {
    console.error('批量写入失败:', err);
    return;
  }
  // 这里执行查询逻辑
});

3. 排查索引同步延迟 #

如果查询依赖特定索引，确认生产环境的索引是前台构建（默认行为）而非后台构建。后台构建的索引在高负载下可能存在同步延迟，导致刚写入的文档无法被索引匹配。可以通过MongoDB Shell检查索引状态：

db.yourCollection.getIndexes()

4. 升级node-mongodb-native到同版本最新补丁 #

node-mongodb-native 2.2.x的早期版本存在批量操作回调时机的bug，比如在主节点真正确认写入前就触发了回调。升级到2.2分支的最新补丁版本（如2.2.36）可以修复这类已知问题。

5. 添加日志辅助定位问题 #

在生产环境中增加详细日志，当异常出现时记录关键信息，方便后续排查：

bulk.execute(function(err, result) {
  if (err) {
    console.error('批量写入错误:', err);
    return;
  }
  console.log(`成功写入 ${result.nInserted} 条记录`);
  
  collection.find(yourQuery)
    .setReadPreference('primary')
    .toArray(function(err, docs) {
      if (err) {
        console.error('查询错误:', err);
        return;
      }
      console.log(`查询到 ${docs.length} 条记录`);
      if (docs.length !== result.nInserted) {
        // 记录查询条件、写入的文档ID等关键信息
        console.error(`数据不匹配：写入${result.nInserted}条，仅查询到${docs.length}条`, {
          query: yourQuery,
          insertedIds: result.getInsertedIds()
        });
      }
    });
});

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