本文介绍如何利用 Java Stream API 对具有相同 ID 的对象进行分组合并，通过 groupingBy 与 reduce 组合实现字段非空值的智能填充，最终得到每个 ID 对应的完整对象列表。
本文介绍如何利用 java stream api 对具有相同 id 的对象进行分组合并，通过 `groupingby` 与 `reduce` 组合实现字段非空值的智能填充，最终得到每个 id 对应的完整对象列表。
在实际开发中，我们常遇到“分散数据需按主键聚合补全”的场景：多个对象共享同一 id，但各自治理部分字段（如 first 或 second），需将其合并为单个完整对象。Java Stream API 本身不支持直接“流式键控合并”，因此需借助 Collectors.groupingBy 先构建 Map<integer list>></integer>，再对每个分组执行归约（reduce）以合并字段。
以下是核心实现逻辑：
List<Test> merged = Stream.of(test1, test2, test3, test4, test5, test6)
.collect(Collectors.groupingBy(Test::getId)) // 分组：Map<Integer, List<Test>>
.values() // 提取所有分组列表
.stream()
.map(group -> group.stream()
.reduce((a, b) -> new Test(
a.getId(),
firstNonNullable(a.getFirst(), b.getFirst()),
firstNonNullable(a.getSecond(), b.getSecond())
))
.orElseThrow(() -> new IllegalStateException("Empty group encountered"))) // 安全兜底
.collect(Collectors.toList());为提升可读性与复用性，建议将字段合并逻辑封装为工具方法：
private static String firstNonNullable(String a, String b) {
return a != null ? a : b;
}⚠️ 注意事项：
立即学习“Java免费学习笔记（深入）”；
-
reduce中每次合并都会创建新Test实例，若数据量大或对象复杂，可能带来额外 GC 压力； - 此方案假设每组内
id一致且至少有一个非空字段；若存在冲突值（如两个非空但不同的first），需自行定义策略（如优先取第一个、抛异常或日志告警）； - 若
Test类含更多字段，需在reduce中逐一处理，建议配合 Lombok 的@Builder或自定义mergeWith(Test other)方法增强可维护性。
相比纯函数式写法，对于复杂业务逻辑，传统 for 循环 + Map<integer test></integer> 缓存的方式往往更直观、高效且易于调试。Stream 方案适用于简洁场景或作为学习范式，生产环境应结合性能实测与团队规范权衡选择。
