如何从MongoDB的嵌套数组中获取最后N条文档？

现在有个MongoDB的chat集合，文档里的消息存在messages数组里，结构如下：

{
"_id" : ObjectId("65d64029a16e5d5a9d00f1e6"),
"name" : "Untitled chat",
"messages" : [ 
    {
        "_id" : ObjectId("65dfbba726752480ef0c4167"),
        "text" : "message 1"
    },
    {
        "_id" : ObjectId("65dfbba726752480ef0c4167"),
        "text" : "message 2"
    }
 ]}

我要从指定聊天文档的messages数组里拿最后N条消息，还要支持limit和skip参数。之前消息存在独立集合的时候，用的PHP查询是这样的：

$cursor = $DB->messages->find(
    ['_id' => new MongoDB\BSON\ObjectID($cid)],
    ['sort' => ['_id' => -1], 'limit' => $limit, 'skip' => $skip]
);

现在消息嵌套在chat文档的数组里，试了好多种aggregate()和find()的写法都没搞定，用的是PHP+MongoDB驱动+MongoDB Atlas。

因为消息是嵌套在文档的数组里，没法直接用普通find()的sort/limit/skip参数，得用数组操作符或者聚合管道来实现：

方法1：用find()配合$project和$slice #

$slice可以从数组指定位置截取元素，用负数索引就能拿数组末尾的内容。要实现skip和limit，得算好截取的起始位置：

• 起始位置：-($skip + $limit)（从数组倒数第skip+limit个元素开始截）
• 截取长度：$limit

PHP代码示例：

$cid = "65d64029a16e5d5a9d00f1e6"; // 目标聊天文档的ID
$skip = 1; // 要跳过的消息数
$limit = 2; // 要获取的消息数

$cursor = $DB->chat->find(
    ['_id' => new MongoDB\BSON\ObjectID($cid)],
    [
        'projection' => [
            'name' => 1, // 保留name字段，按需调整
            'messages' => [
                '$slice' => ['$messages', -($skip + $limit), $limit]
            ]
        ]
    ]
);

// 取出结果
$chat = $cursor->toArray()[0];
$targetMessages = $chat['messages'];

注意：要是skip + limit超过了数组总长度，会返回从数组开头到末尾的limit个元素，得自己做好边界判断。

方法2：用聚合管道（更灵活，适合复杂场景） #

如果需要先按消息的_id倒序再做skip/limit，用聚合管道更靠谱：

$cid = "65d64029a16e5d5a9d00f1e6";
$skip = 1;
$limit = 2;

$pipeline = [
    // 先定位到目标聊天文档
    ['$match' => ['_id' => new MongoDB\BSON\ObjectID($cid)]],
    // 把messages数组反转，让最新的消息（原数组末尾）移到开头
    ['$addFields' => [
        'messages' => ['$reverseArray' => '$messages']
    ]],
    // 对反转后的数组执行skip和limit
    ['$addFields' => [
        'messages' => [
            '$slice' => ['$messages', $skip, $limit]
        ]
    ]],
    // 可选：如果需要把消息恢复成旧到新的顺序，就再反转一次
    ['$addFields' => [
        'messages' => ['$reverseArray' => '$messages']
    ]]
];

$cursor = $DB->chat->aggregate($pipeline);
$chat = $cursor->toArray()[0];
$targetMessages = $chat['messages'];

步骤解释：

1. $match：精准找到要操作的聊天文档
2. $reverseArray：反转数组，让最新消息排在前面
3. $slice：跳过指定数量的消息，再取限制条数
4. 二次反转：如果需要消息保持发送顺序（旧→新），就加这一步

额外提醒 #

• 要保证消息数组里的_id是按时间递增生成的（MongoDB的ObjectID默认带时间戳），这样数组顺序才是消息的发送顺序
• 如果消息数组特别大，嵌套存储可能影响性能，这时候还是把消息拆去独立集合（就是你之前的存储方式）更适合分页查询

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