Node.js调用导出async函数返回Promise{pending}及异步原理咨询

为什么会输出 Promise { pending } #

所有被async标记的函数，返回值必然是一个Promise对象——不管你在函数里return的是什么值，都会被自动包装成Promise实例。你直接打印checkService.isUserExists(username)，本质上是打印了一个还在等待异步操作（数据库查询）完成的Promise，所以显示Promise { pending }。

两种正确的调用方式 #

方式一：用await（需在async函数内调用） #

如果你的调用代码本身在async函数中，可以这样写：

// 示例：在async函数内调用
async function checkUser() {
  const username = "testUser";
  const exists = await checkService.isUserExists(username);
  console.log('function:', exists); // 此处会输出true或false
}
checkUser();

方式二：用.then()链式处理 #

如果不想用async/await，可以直接通过Promise的.then()方法获取结果：

const username = "testUser";
checkService.isUserExists(username)
  .then(exists => {
    console.log('function:', exists); // 此处会输出true或false
  })
  .catch(err => {
    // 务必处理可能的错误，比如数据库连接失败
    console.error('查询出错:', err);
  });

额外优化：数据库连接复用 #

你的代码每次调用isUserExists都新建并关闭数据库连接，效率很低，建议改成复用连接：

const express = require("express");
const mongoDB = require('mongodb').MongoClient;
const url = "your-database-url";

let dbInstance;

class CheckService {
  // 提前初始化数据库连接
  async init() {
    const connection = await mongoDB.connect(url);
    dbInstance = connection.db("users");
  }

  async isUserExists(username) {
    if (!dbInstance) {
      throw new Error('请先调用init()初始化数据库连接');
    }
    const query = {name: username};
    const result = await dbInstance.collection("users").find(query).toArray();
    return result.length !== 0;
  }
}

const checkService = new CheckService();
// 启动服务前先完成连接初始化
checkService.init().then(() => console.log('数据库连接初始化完成'));

module.exports = checkService;

Promise、async/await 核心知识点 #

• Promise：JS中处理异步操作的对象，代表一个未来完成的操作，有三种状态：pending（进行中）、fulfilled（已成功）、rejected（已失败），状态一旦改变就不会再变。
• async函数：Promise的语法糖，执行时自动返回Promise，函数内部的return值会作为Promise的resolve结果；若内部抛出错误，则作为Promise的reject结果。
• await：只能在async函数内使用，作用是等待Promise完成并获取其resolve值；若Promise被reject，await会抛出错误，需用try/catch捕获。

基础学习内容梳理 #

Promise核心用法 #

1. 创建Promise：

   const promise = new Promise((resolve, reject) => {
     // 异步操作
     if (操作成功) {
       resolve(结果);
     } else {
       reject(错误);
     }
   });
   

2. 常用方法：
   • .then()：处理Promise成功的结果
   • .catch()：处理Promise失败的错误
   • .finally()：无论成功失败都会执行的逻辑
3. 静态方法：
   • Promise.all([p1, p2])：等待所有Promise完成后返回结果数组
   • Promise.race([p1, p2])：返回第一个完成的Promise的结果

async/await进阶技巧 #

1. 用try/catch捕获错误：

   async function handleAsync() {
     try {
       const result = await someAsyncTask();
     } catch (err) {
       console.error('操作出错:', err);
     }
   }
   

2. 并行执行异步操作：
   多个互不依赖的异步操作，用Promise.all()比依次await效率更高：

   async function getMultiData() {
     const [userData, orderData] = await Promise.all([
       fetchUserInfo(),
       fetchUserOrders()
     ]);
   }
   

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