Nodejs 关于异步取信息后返回界面，求教

Nodejs 关于异步取信息后返回界面，求教

我想做一个标签列表，列出所有标签，和该标签总共有多少文章。

用mongodb和mongoose,一个tag{name:name}表,只有一个name属性,和ariticle{title:…}表。

当取得所有tag时，因为异步去执行每个tag的article.count({tag:_id}) ;所以没有取得count就返回页面了，该怎么解决？

5 回复

当然可以。根据你的描述，你需要从MongoDB中获取所有的标签，并且对于每一个标签，需要获取与之关联的文章数量。由于这些操作是异步的，我们需要确保在返回页面之前完成所有异步操作。我们可以使用async/await来处理这些异步操作，确保它们按顺序执行。

示例代码

首先，确保你已经安装了mongoose：

npm install mongoose

然后，创建一个简单的Express应用来实现这个功能：

const express = require('express');
const mongoose = require('mongoose');

// 连接到MongoDB
mongoose.connect('mongodb://localhost/test', { useNewUrlParser: true, useUnifiedTopology: true });

// 定义Schema
const tagSchema = new mongoose.Schema({
  name: String,
});

const articleSchema = new mongoose.Schema({
  title: String,
  tags: [String],
});

// 创建模型
const Tag = mongoose.model('Tag', tagSchema);
const Article = mongoose.model('Article', articleSchema);

const app = express();

app.get('/tags', async (req, res) => {
  try {
    // 获取所有标签
    const tags = await Tag.find();

    // 对每个标签，计算关联的文章数量
    const tagsWithCount = await Promise.all(
      tags.map(async (tag) => {
        const count = await Article.countDocuments({ tags: tag.name });
        return {
          ...tag.toObject(),
          articleCount: count,
        };
      })
    );

    // 返回带有文章数量的标签列表
    res.json(tagsWithCount);
  } catch (error) {
    console.error(error);
    res.status(500).json({ message: 'Internal Server Error' });
  }
});

app.listen(3000, () => {
  console.log('Server is running on port 3000');
});

解释

  1. 定义Schema和Model：

    • 我们定义了两个Schema：tagSchema和articleSchema。
    • Tag模型用于存储标签，Article模型用于存储文章。

  2. 路由处理：

    • 当访问/tags路径时，我们首先通过Tag.find()获取所有标签。
    • 使用Promise.all并结合map方法，对每个标签异步地计算其关联的文章数量。
    • 最终，将每个标签及其文章数量一起返回给客户端。

通过这种方式，你可以确保在返回页面之前完成所有的异步操作，从而避免数据不完整的问题。


就是标签文章数的统计，用mongoose该怎么做

2L 正解

也可以试试 stepify

在Node.js中处理异步操作通常需要使用Promise或者async/await来确保所有异步任务完成后再返回结果。在这个例子中，你可以使用Mongoose模型来查询所有的标签，并为每个标签异步地获取其对应的文章数量。为了确保所有异步操作都完成后才返回结果，可以使用Promise.all或async/await。

下面是一个使用async/await实现的例子：

const Tag = require('./models/tag'); // 引入标签模型
const Article = require('./models/article'); // 引入文章模型

// 获取所有标签并计算每个标签的文章数量
async function getTagsWithArticleCount() {
  try {
    const tags = await Tag.find(); // 获取所有标签
    const tagPromises = tags.map(async (tag) => {
      const count = await Article.countDocuments({ tag: tag._id }); // 计算文章数量
      return { ...tag.toObject(), articleCount: count }; // 将结果合并到标签对象中
    });
    
    const tagsWithCounts = await Promise.all(tagPromises); // 等待所有异步操作完成
    return tagsWithCounts;
  } catch (error) {
    console.error(error);
    throw new Error('Failed to fetch tags with article counts.');
  }
}

// 在路由处理函数中使用
router.get('/tags', async (req, res) => {
  try {
    const tagsWithCounts = await getTagsWithArticleCount();
    res.render('tagsList', { tags: tagsWithCounts }); // 渲染视图并传递数据
  } catch (error) {
    res.status(500).send('Internal Server Error');
  }
});

在这段代码中：

  • getTagsWithArticleCount 是一个异步函数，用于获取所有标签及其对应的文章数量。
  • 使用Tag.find()获取所有标签。
  • 对每个标签，使用Article.countDocuments计算其对应的文章数量。
  • Promise.all 用于等待所有异步操作完成。
  • 最后，将结果传递给视图进行渲染。

通过这种方式，你可以确保在返回响应之前，所有的异步操作都已经完成。

回到顶部