如何用Mongoose同步获取文档？解决Express启动计数器为空问题

我明白你遇到的麻烦了——MongoDB的查询都是异步操作，你的服务器在计数器还没从数据库加载完成时就已经启动了，这时候快速发请求自然会因为myCounter还是null而报错。下面我一步步帮你修改代码，彻底解决这个问题：

问题根源 #

你当前的代码里，Counter.count()和Counter.findOne()都是异步执行的，但Express服务器启动是同步进行的。这就导致服务器已经开始监听请求了，计数器却还没初始化完成，myCounter仍然是null，调用myCounter.increment()肯定会抛出错误。

解决方案思路 #

核心思路是确保计数器初始化完成后再启动Express服务器，同时用async/await处理所有异步操作，让代码更清晰易读。另外还要修正increment方法的异步逻辑，避免潜在的数据不一致问题。

修改后的完整代码 #

import express from 'express';
import mongoose, { Schema } from 'mongoose';

// 定义计数器Schema和模型
const CounterSchema = new Schema({ value: Number });
CounterSchema.methods.increment = async function() {
  this.value++;
  await this.save(); // 用await确保保存操作完成，避免异步遗漏
};
const Counter = mongoose.model('Counter', CounterSchema);

let myCounter = null;

// 异步初始化计数器的函数
async function initCounter() {
  try {
    const count = await Counter.countDocuments({});
    if (count === 0) {
      // 数据库为空，创建新计数器并保存到数据库
      myCounter = new Counter({ value: 0 });
      await myCounter.save();
      console.log('Created new counter with value:', myCounter.value);
    } else if (count === 1) {
      // 获取已有的计数器文档
      myCounter = await Counter.findOne({});
      console.log('Loaded existing counter with value:', myCounter.value);
    } else {
      // 处理多个计数器文档的异常情况
      throw new Error('Multiple counter documents found in database');
    }
  } catch (err) {
    console.error('Failed to initialize counter:', err);
    process.exit(1); // 初始化失败时直接退出服务器，避免后续请求报错
  }
}

const app = express();

// 修改路由为异步函数，处理计数器递增的异步操作
app.get('/', async (req, res) => {
  try {
    await myCounter.increment();
    res.json({ counterValue: myCounter.value });
  } catch (err) {
    res.status(500).json({ error: 'Failed to increment counter' });
  }
});

// 先连接MongoDB，再初始化计数器，最后启动服务器
mongoose.connect('mongodb://localhost/test')
  .then(async () => {
    console.log('Successfully connected to MongoDB');
    await initCounter();
    // 计数器初始化完成后才启动服务器，确保请求过来时myCounter已就绪
    app.listen(3000, () => {
      console.log('Server is running on port 3000');
    });
  })
  .catch(err => {
    console.error('MongoDB connection failed:', err);
    process.exit(1);
  });

关键修改点说明 #

• 异步初始化计数器：把计数器的初始化逻辑封装到initCounter异步函数中，用await等待所有数据库操作完成，确保myCounter有值后再启动服务器。
• 修正increment方法：将原来的回调式改成async/await，确保计数器的保存操作完成后再响应请求，避免数据不一致。
• 调整服务器启动时机：把服务器启动放在MongoDB连接成功且计数器初始化完成之后，从根源上避免了myCounter为null的情况。
• 完善错误处理：添加了全链路的错误捕获，无论是数据库连接失败还是计数器初始化出错，都会及时退出服务器并打印错误信息，方便排查问题。

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