Node.js中如何将MongoDB find()方法获取的数据用于JSON响应？

这个问题的核心是JavaScript异步操作的执行顺序问题，你的代码里MongoClient.connect和find().toArray()都是异步方法——它们会在后台默默执行，而你的exports.get方法会直接跳过等待，先执行res.end()。这时候数据库查询还没完成，path和direct自然还是初始的空字符串，所以根本拿不到数据。

下面给你两种可行的解决方案，优先推荐更清晰的async/await写法：

方案一：使用async/await处理异步流程 #

把数据库操作放到get方法内部，并用async/await等待异步操作完成，确保拿到数据后再返回响应：

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');
const url = 'mongodb://localhost:27017/serverad';

exports.get = async function(req, res) {
  try {
    // 等待数据库连接完成
    const db = await MongoClient.connect(url);
    
    // 等待查询结果返回
    const docs = await db.collection("adchar").find(
      { target_gender: 'female' },
      { ad_path: 1, ad_direct: 1, _id: 0 }
    ).toArray();

    // 初始化数据，避免查询结果为空时报错
    let path = '';
    let direct = '';
    if (docs.length > 0) {
      path = docs[0].ad_path;
      direct = docs[0].ad_direct;
    }

    // 构造并返回JSON响应
    res.writeHead(200, { 'Content-Type': 'application/json' });
    const myObj = { AdUrl: path, dirURL: direct };
    res.end(JSON.stringify(myObj));

    // 关闭数据库连接
    db.close();
  } catch (err) {
    // 捕获并返回错误信息
    res.writeHead(500, { 'Content-Type': 'application/json' });
    res.end(JSON.stringify({ error: '数据库操作失败：' + err.message }));
  }
};

方案二：使用回调嵌套（传统写法） #

如果你习惯传统的回调方式，也可以把响应逻辑放到查询完成的回调里，确保顺序执行：

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');
const url = 'mongodb://localhost:27017/serverad';

exports.get = function(req, res) {
  MongoClient.connect(url, function(err, db) {
    if (err) {
      res.writeHead(500, { 'Content-Type': 'application/json' });
      res.end(JSON.stringify({ error: '数据库连接失败：' + err.message }));
      return;
    }
    assert.equal(err, null);

    db.collection("adchar").find(
      { target_gender: 'female' },
      { ad_path: 1, ad_direct: 1, _id: 0 }
    ).toArray(function(err, docs) {
      if (err) {
        res.writeHead(500, { 'Content-Type': 'application/json' });
        res.end(JSON.stringify({ error: '查询失败：' + err.message }));
        db.close();
        return;
      }
      assert.equal(err, null);

      let path = '';
      let direct = '';
      if (docs.length > 0) {
        path = docs[0].ad_path;
        direct = docs[0].ad_direct;
      }

      res.writeHead(200, { 'Content-Type': 'application/json' });
      const myObj = { AdUrl: path, dirURL: direct };
      res.end(JSON.stringify(myObj));
      db.close();
    });
  });
};

关键说明： #

1. 异步操作的顺序：必须等待数据库连接、查询都完成后，才能构造响应返回。原来的代码把异步操作放在模块加载阶段，而get方法是独立执行的，完全没等异步操作结束。
2. 错误处理：添加了错误捕获逻辑，避免数据库操作失败时服务器崩溃，同时给客户端返回明确的错误提示。
3. 空结果处理：判断docs.length，避免查询不到匹配数据时，访问docs[0]导致报错。

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