
本文介绍如何基于 java stream api 和 collectors.groupingby,根据对象的指定字段(如 shape、size 或二者组合)将 list>,适用于多策略分组场景。
在实际开发中,常需根据业务类型(如 "type_1"、"type_2")对同一组对象执行不同维度的分组逻辑。核心需求是:给定一个 List>(即每个子列表包含具有相同分组键的对象)
✅ 基础分组:按单字段(如 shape)
使用 Collectors.groupingBy(Obj::getShape) 可将列表按 shape 字段归类为 Map
public List> groupByShape(List
objs) { return new ArrayList<>(objs.stream() .collect(Collectors.groupingBy(Obj::getShape)) .values()); }
⚠️ 注意:确保 Obj 类已提供 getShape()(及 getSize())等标准 getter 方法;若字段为 private,缺少 getter 将导致编译错误。
✅ 扩展分组:按 size 或联合键(shape + size)
-
按 size 分组:仅替换 key 提取器:
.collect(Collectors.groupingBy(Obj::getSize))
按 shape 和 size 联合分组(即唯一组合):推荐使用 AbstractMap.SimpleEntry 或自定义键类,但最简洁安全的方式是构造复合字符串键(需注意避免 shape="a_b" 与 size="c" 和 shape="a" 与 size="b_c" 的歧义)。更健壮的做法是使用 Record(Java 14+)或匿名内部类,但兼容性最佳的是 Map.entry(Java 9+):
public List> groupByShapeAndSize(List
objs) { return new ArrayList<>(objs.stream() .collect(Collectors.groupingBy( obj -> Map.entry(obj.getShape(), obj.getSize()) )) .values()); }
若使用 Java 8,可改用 Arrays.asList(obj.getShape(), obj.getSize()) 作为 key(需确保 shape/size 不为 null,否则抛 NPE):
.collect(Collectors.groupingBy(obj -> Arrays.asList(obj.getShape(), obj.getSize())))
✅ 整合进主函数:动态路由分组策略
将上述逻辑封装后,嵌入原 functionName 中,实现清晰可维护的分支处理:
public void functionName(Map> objMap) { objMap.forEach((type, objs) -> { List > groupedLists; switch (type) { case "type_1": groupedLists = groupByShape(objs); break; case "type_2": groupedLists = groupBySize(objs); break; case "type_3": groupedLists = groupByShapeAndSize(objs); break; default: groupedLists = Collections.singletonList(objs); // 不分组,保留原列表 } // ✅ 此处对 groupedLists 进行后续业务处理(如统计、转换、持久化等) processGroups(groupedLists); }); } private void processGroups(List
> groups) { for (int i = 0; i < groups.size(); i++) { System.out.println("Group " + (i + 1) + ": " + groups.get(i)); } }
? 验证示例输出
以题设 "type_1" 输入为例:
[
{"size":"m1","shape":"s1","name":"Obj_1"},
{"size":"m2","shape":"s1","name":"Obj_2"},
{"size":"m3","shape":"s2","name":"Obj_3"}
]→ groupByShape 输出为:
[ [Obj_1, Obj_2], // shape="s1" [Obj_3] // shape="s2" ]
完全符合预期。
✅ 总结
- 核心工具:Stream.collect(Collectors.groupingBy(...)) 是实现动态分组的声明式首选;
- 灵活性关键:通过函数式接口传入不同 key 提取器(Function
),轻松切换分组维度; - 安全提示:确保 getter 方法存在且非空;联合分组时优先使用不可变结构(如 Map.entry 或 record)避免哈希冲突;
- 性能友好:整个流程为单次流遍历,时间复杂度 O(n),无需额外嵌套循环。
该方案简洁、可读性强,且易于扩展新分组类型(如新增 "type_4" 按 name 首字母分组),是 Java 8+ 项目中处理条件分组任务的标准实践。










