使用 MongoDB Aggregate Pipeline 实现分组查询后的排序
在 MongoDB 的日常查询场景中，我们经常需要先对数据进行分组聚合，再对分组后的结果进行排序。比如统计每个用户的订单总金额，然后按照总金额从高到低排列；或者统计每个分类下的商品数量，再按照数量升序展示。这些需求都可以通过 Aggregate Pipeline（聚合管道）来高效实现，本文将详细介绍具体的实现方法和注意事项。
聚合管道的基本流程
MongoDB 的聚合管道是由多个阶段（stage）组成的处理流水线，每个阶段会对输入的文档进行特定操作，处理完成后将结果传递给下一个阶段。要实现分组后排序，核心就是先使用 $group 阶段完成数据分组，再使用 $sort 阶段对分组结果排序。
整个流程的逻辑顺序不能颠倒：如果先排序再分组，排序操作只会对原始文档生效，分组后的新文档并不会保持之前的排序结果，所以必须严格遵循「先分组，后排序」的顺序。
基础示例：统计用户订单总金额并排序
假设我们有一个订单集合 orders，每个文档包含用户ID、订单金额、订单时间等字段，结构如下：
{
"_id": ObjectId("655a1b2c3d4e5f6a7b8c9d0e"),
"userId": "user_001",
"amount": 299.9,
"orderTime": ISODate("2024-05-01T10:30:00Z")
}现在需要统计每个用户的订单总金额，并且按照总金额从高到低排序，对应的聚合管道代码如下：
// 连接数据库后执行聚合操作
db.orders.aggregate([
// 第一阶段：按 userId 分组，计算每个用户的订单总金额
{
$group: {
_id: "$userId", // 分组的依据字段，这里按用户ID分组
totalAmount: { $sum: "$amount" }, // 累加每个用户的订单金额，得到总金额
orderCount: { $sum: 1 } // 统计每个用户的订单数量，可选字段
}
},
// 第二阶段：对分组后的结果按照总金额降序排序
{
$sort: {
totalAmount: -1 // -1 表示降序，1 表示升序
}
}
])上述代码执行后，会返回一个数组，每个元素是一个分组后的文档，包含用户ID、总金额、订单数量，并且所有结果已经按照总金额从高到低排列。如果需要升序排列，只需要把 totalAmount 对应的排序值改为 1 即可。
复杂场景示例：分组后多字段排序
实际业务中往往不止需要单字段排序，比如我们统计每个分类下的商品数量，要求先按照商品数量降序排列，如果数量相同，再按照分类名称升序排列。对应的商品集合 products 结构如下：
{
"_id": ObjectId("655a2c3d4e5f6a7b8c9d0e1f"),
"category": "手机",
"name": "XX品牌旗舰机",
"price": 3999
}实现多字段排序的聚合代码如下：
db.products.aggregate([
// 第一阶段：按分类分组，统计每个分类的商品数量
{
$group: {
_id: "$category", // 按分类字段分组
productCount: { $sum: 1 } // 统计每个分类的商品总数
}
},
// 第二阶段：多字段排序
{
$sort: {
productCount: -1, // 优先按商品数量降序
"_id": 1 // 数量相同则按分类名称升序
}
}
])在 $sort 阶段中，排序字段的书写顺序就是优先级顺序，前面的字段优先级更高，只有当前面的字段值相同时，才会比较后面的字段。
注意事项
- 分组阶段如果使用
_id: null表示不分组，对所有文档做统一聚合，这种情况下排序依然是对聚合后的单个结果生效，语法和分组后排序一致。 - 如果分组后需要筛选结果，可以在
$group之后、$sort之前添加$match阶段，比如只保留总金额大于1000的用户分组，再对结果排序，这样能减少排序的数据量，提升性能。 - 排序操作会消耗较多的内存资源，如果排序的数据量较大，建议配合索引使用，或者在聚合管道中添加
{ $limit: 100 }这样的阶段限制返回结果数量，避免内存溢出。
总结
使用 MongoDB Aggregate Pipeline 实现分组后排序的核心就是合理安排管道阶段的顺序，先通过 $group 完成数据分组聚合，再通过 $sort 对分组结果排序。单字段排序只需要在 $sort 中指定一个字段和排序方向，多字段排序则按照优先级顺序依次列出字段即可。实际使用时还可以结合 $match、$limit 等阶段，满足更复杂的业务查询需求。
MongoDB聚合管道分组查询排序Group阶段Sort阶段 本作品最后修改时间：2026-05-22 16:02:42