我的问题 #

我是MEAN栈开发新手，正处于学习阶段。尝试开发一个简单应用，在前端展示搜索记录列表，同时显示搜索记录的总条数和数据集中唯一客户名的数量。

我在Node.js中编写了相关逻辑来返回总条数和唯一数量，但由于Node.js的异步特性，响应代码（Code3）在统计唯一客户数的代码（Code2）执行前就运行了，导致唯一客户数始终为0。

以下是我的代码：

function xyz(req, res, next) { 
  //Code 1 - Get the data 
  query = Recs.find({ $and: searchQuery }); 

  //Code 2 - Query to get distict cust name count 
  query.find().distinct('custName',function (err, distinct_cust_count) { 
    cust_count = distinct_cust_count.length; 
  }); 

  //Code 3 - Response 
  if (query == null) 
    res.send({total: 0,c_count:0}); 
  else 
    query.count(function(err, total) { 
      res.send({total: total,c_count:cust_count}); 
    }); 
}

请告诉我如何确保Code2始终在Code3之前执行，我见过一些使用回调的示例，但都是用于不同函数而非同一函数内的代码段。

解决方案 #

核心问题确实是Node.js的异步特性——你的distinct和count都是异步数据库操作，它们会在后台执行，主线程会直接往下运行Code3，所以当res.send执行时，cust_count还没被赋值。

针对你的场景，这里提供两种实用方案，从适合新手理解的基础写法，到更现代的优雅写法：

方式1：嵌套回调（最直接的入门方案） #

把Code3的响应逻辑放到Code2的回调函数内部，这样就能保证只有当distinct查询完成、cust_count被正确赋值后，才会执行统计总数和响应的逻辑：

function xyz(req, res, next) { 
  //Code 1 - Get the data 
  const query = Recs.find({ $and: searchQuery }); 

  // 先处理query异常情况（一般Recs.find()不会返回null，可根据实际场景调整）
  if (!query) {
    return res.send({total: 0, c_count: 0});
  }

  //Code 2 - Query to get distinct cust name count 
  query.distinct('custName', function (err, distinct_cust) { 
    // 必须处理数据库查询错误
    if (err) {
      return res.status(500).send({error: '获取唯一客户列表失败'});
    }
    const cust_count = distinct_cust.length; 

    //Code 3 - 现在在回调内执行响应逻辑，确保cust_count已赋值
    query.count(function(err, total) { 
      if (err) {
        return res.status(500).send({error: '统计记录总数失败'});
      }
      res.send({total: total, c_count: cust_count}); 
    }); 
  }); 
}

方式2：使用Promise + Async/Await（更现代易读的写法） #

Mongoose的所有查询方法都支持Promise，所以你可以用async-await语法让异步代码看起来像同步代码，逻辑更清晰，也避免了回调嵌套的问题：

// 给函数加上async关键字
async function xyz(req, res, next) { 
  try {
    //Code 1 - Get the data 
    const query = Recs.find({ $and: searchQuery }); 

    if (!query) {
      return res.send({total: 0, c_count: 0});
    }

    //Code 2 - 等待distinct查询完成，拿到结果
    const distinct_cust = await query.distinct('custName');
    const cust_count = distinct_cust.length; 

    //Code 3 - 等待count查询完成，再返回响应
    const total = await query.count();
    res.send({total: total, c_count: cust_count}); 
  } catch (err) {
    // 统一捕获所有异步操作的错误
    res.status(500).send({error: err.message});
  }
}

关键注意事项 #

• 异步操作的结果绝对不能在回调/await外部直接使用，因为你无法确定异步操作何时完成
• 永远不要忽略错误处理！数据库查询可能会因为各种原因失败，必须捕获并处理这些错误，避免服务崩溃
• Mongoose的find()方法返回的是Query对象，通常不会是null，所以if (query == null)的判断可以根据你的实际业务场景决定是否保留

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