Koa.js结合MongoDb开发：如何将查询结果返回至ctx.body

这个问题的核心是异步回调的执行顺序：你的ctx.body = 'END OF FILE!!!'是在MongoDB连接和查询的回调函数外面执行的，而数据库操作是异步的——当Koa返回这个响应的时候，数据库查询还没完成，所以客户端自然拿不到查询结果。

要解决这个问题，我们可以利用Koa对async/await的良好支持，把异步回调转换成Promise风格的代码，确保在数据库查询完成后再设置ctx.body。

修改后的代码示例 #

router.get('/', async (ctx, next) => {
  // 用try/catch捕获数据库操作可能出现的错误
  try {
    // 连接数据库，使用await等待连接完成
    const client = await MongoClient.connect(url, { useNewUrlParser: true });
    const dbo = client.db("mydb");
    const query = { address: "Highway 37" };
    
    // 将find().toArray()转换成Promise并等待结果
    const result = await dbo.collection("customers").find(query).toArray();
    
    // 查询完成后，将结果赋值给ctx.body
    ctx.body = result;
    
    // 关闭数据库连接
    client.close();
  } catch (err) {
    // 处理错误，比如返回500状态码和错误信息
    ctx.status = 500;
    ctx.body = { error: err.message };
  }
});

关键改动说明 #

• 将路由处理函数改成async函数，这样就能在内部使用await等待异步操作完成。
• 把MongoClient.connect和toArray()的回调式调用改成Promise式，用await等待它们执行完毕，确保拿到结果后再设置ctx.body。
• 添加try/catch块来捕获数据库操作中的错误，避免程序崩溃，同时给客户端返回合适的错误响应。
• 注意：原来的代码里用的是db.close()，现在因为用了MongoClient的新写法，应该调用client.close()（MongoClient.connect返回的是client实例，而不是db）。

这样修改后，当客户端请求这个路由时，Koa会等待数据库查询完成，然后把查询结果作为响应返回给客户端，而不是提前返回"END OF FILE!!!"。

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