MongoDB社交媒体帖子功能Schema设计方案咨询

针对你的需求，我设计了三个核心集合，兼顾功能实现与查询性能：

1. Users（用户集合） #

存储用户基础信息与社交关系：

{
  _id: ObjectId,          // 主键
  username: String,       // 唯一用户名
  displayName: String,    // 昵称
  avatarUrl: String,      // 头像地址
  followings: [ObjectId], // 关注的用户ID数组（关联Users._id）
  createdAt: Date,        // 账号创建时间
  updatedAt: Date         // 信息更新时间
}

• 索引建议：给followings建数组索引，给username建唯一索引

2. Posts（帖子集合） #

存储帖子核心内容，预聚合常用统计字段提升性能：

{
  _id: ObjectId,          // 主键
  authorId: ObjectId,     // 作者ID（关联Users._id，建索引）
  mediaUrls: [String],    // 图片/视频地址数组（必填，适配Ins风格多媒体帖子）
  caption: String,        // 帖子文案/说明
  content: String,        // 额外文本内容（可选）
  likesCount: Number,     // 预聚合点赞数
  commentsCount: Number,  // 预聚合评论数
  createdAt: Date,        // 发布时间（建索引）
  updatedAt: Date         // 更新时间
}

• 索引建议：复合索引{ authorId: 1, createdAt: -1 }（用于个人主页帖子排序），{ createdAt: -1 }（用于全局信息流排序）

3. PostViews（帖子查看记录集合） #

专门记录用户完成查看的帖子（停留满5秒），避免嵌套文档导致的性能问题：

{
  _id: ObjectId,          // 主键
  userId: ObjectId,       // 查看用户ID（关联Users._id）
  postId: ObjectId,       // 被查看帖子ID（关联Posts._id）
  viewedAt: Date          // 完成查看的时间点
}

• 索引建议：复合唯一索引{ userId: 1, postId: 1 }，确保同一用户不会重复记录同一帖子的查看状态

针对需求的具体实现逻辑 #

1. 发布帖子
   直接向Posts集合插入文档，若需要统计用户发帖数，可在Users集合中添加postsCount字段并更新（预聚合）。

2. 浏览其他用户帖子

   • 个人主页：通过authorId查询Posts，按createdAt倒序排序，配合分页。
   • 关注信息流：先获取当前用户的followings数组，再查询Posts中authorId属于该数组的文档，按createdAt倒序分页。分页建议用createdAt+_id组合条件，避免同一时间发布的帖子重复/遗漏：

     db.Posts.find({
       authorId: { $in: [用户关注的ID列表] },
       createdAt: { $lt: 上一页最后一条帖子的createdAt },
       _id: { $lt: 上一页最后一条帖子的_id }
     }).sort({ createdAt: -1, _id: -1 }).limit(20)
     

3. 记录已查看帖子

   • 前端监听帖子在可视区域停留满5秒的事件，调用后端接口。
   • 后端先通过PostViews的复合唯一索引判断该用户是否已记录过此帖子的查看状态，若未记录则插入新文档：

     db.PostViews.updateOne(
       { userId: ObjectId("用户ID"), postId: ObjectId("帖子ID") },
       { $setOnInsert: { viewedAt: new Date() } },
       { upsert: true }
     )
     

   用upsert: true+$setOnInsert确保不会重复创建记录。

4. 已查看帖子出现在信息流

   • 标记已查看状态：查询信息流时，通过$lookup关联PostViews，给每个帖子添加isViewed字段：

     db.Posts.aggregate([
       { $match: { authorId: { $in: [用户关注的ID列表] } } },
       { $sort: { createdAt: -1, _id: -1 } },
       { $lookup: {
           from: "PostViews",
           let: { postId: "$_id", userId: ObjectId("当前用户ID") },
           pipeline: [
             { $match: {
                 $expr: {
                   $and: [
                     { $eq: ["$userId", "$$userId"] },
                     { $eq: ["$postId", "$$postId"] }
                   ]
                 }
               }
             }
           ],
           as: "viewRecord"
         }
       },
       { $addFields: { isViewed: { $gt: [{ $size: "$viewRecord" }, 0] } } },
       { $project: { viewRecord: 0 } }, // 移除临时字段
       { $limit: 20 }
     ])
     

   • 若需要优先展示未查看帖子，可先查询未被PostViews记录的帖子，再补充已查看的帖子。

性能优化补充 #

• 对于超大规模数据，可按createdAt对Posts集合分片，降低单节点压力。
• 点赞、评论操作时，用$inc原子更新likesCount和commentsCount，避免全文档更新。
• 前端可缓存已查看帖子ID，减少后端查询压力，但需定期与后端同步状态。

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