如何在Mongoose中实现大小为N的队列，单查询完成消息新增与溢出删除

完全可以在单次原子查询中完成需求，无需额外计数判断，MongoDB原生的$push修饰符即可直接实现固定长度的消息队列效果：

核心操作代码 #

你可以直接使用如下mongoose更新语句，在新增消息的同时自动保留最新的100条消息：

// 示例参数：chatId为目标聊天文档ID，newMessage为待新增的消息对象
await ChatModel.updateOne(
  { _id: chatId },
  {
    $push: {
      messages: {
        $each: [newMessage],
        $slice: -100
      }
    }
  }
)

参数说明 #

• $each：用于指定要插入的消息列表，即使仅插入单条消息也需要搭配该参数才能启用后续修饰符
• $slice: -100：数组插入完成后自动裁剪，仅保留最后100个元素（也就是最新的100条消息），超出长度的旧消息会自动从数组头部移除
  整个操作是原子性的，不会出现并发冲突，也无需额外前置查询判断数组长度。

可选优化 #

如果担心消息顺序出现混乱，可以额外搭配$sort修饰符统一按消息时间排序：

await ChatModel.updateOne(
  { _id: chatId },
  {
    $push: {
      messages: {
        $each: [newMessage],
        $sort: { time: 1 },
        $slice: -100
      }
    }
  }
)

替代方案说明 #

你当前的需求不需要额外引入第三方队列服务，上述MongoDB原生语法就是最简洁的固定长度队列实现，完全适配你现有的Schema结构，无需做任何模型调整。

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