本文详解如何使用 Java Stream API 按 title 和 author 两个字段对 Book 列表进行分组，合并重复项，并将统计数量直接写入每个唯一 Book 对象的 count 字段，最终返回去重后的 List。
本文详解如何使用 java stream api 按 title 和 author 两个字段对 book 列表进行分组，合并重复项，并将统计数量直接写入每个唯一 book 对象的 count 字段，最终返回去重后的 list
在 Java 开发中，常需对集合按多个字段去重并聚合（如计数），同时保留原始对象结构而非仅返回 Map 或新 DTO。本例中，Book 类包含 title、author 和可变的 count 字段，目标是：对相同 (title, author) 组合的记录归并为单个 Book 实例，其 count 值等于该组合出现次数，最终输出 List
核心难点在于：标准 Collectors.groupingBy 返回 Map
以下是推荐实现（基于 Lombok Builder + 正确 setter）：
import org.apache.commons.lang3.tuple.Pair;
import java.util.*;
import java.util.stream.Collectors;
List<Book> books = posts.stream()
.collect(Collectors.groupingBy(
book -> {
book.setCount(1); // 关键：首次访问即初始化 count=1
return Pair.of(book.getTitle(), book.getAuthor());
},
Collectors.reducing(
(a, b) -> {
a.setCount(a.getCount() + 1); // 合并时只更新前者，丢弃后者
return a;
}
)
))
.values()
.stream()
.filter(Optional::isPresent) // reducing 返回 Optional，需过滤空值
.map(Optional::get)
.collect(Collectors.toList());✅ 关键要点说明：
立即学习“Java免费学习笔记（深入）”；
- reducing 的二元操作 (a, b) -> { a.setCount(...); return a; } 确保每组内除首个元素外，其余对象均被“吸收”进第一个对象，避免创建新实例；
- 初始化 book.setCount(1) 必须放在 grouping key lambda 内（而非 map 外），否则未参与分组的单例不会被初始化；
- Collectors.reducing 默认返回 Optional
，因此后续需 .filter(Optional::isPresent).map(Optional::get) 安全解包； - 此方案修改原对象状态，若需不可变语义，应改用 Collectors.collectingAndThen 构造新 Book 实例（例如 Book.builder().title(...).author(...).count(count).build()）。
⚠️ 注意事项：
- 依赖 Apache Commons Lang 的 Pair 属于第三方库，生产环境建议优先使用 AbstractMap.SimpleEntry
或自定义轻量 Key 类（如 record TitleAuthorKey(String title, String author){}），提升可读性与类型安全； - 若 Book 类未提供 setCount() 方法或字段非 public，请确保 Lombok @Setter 已启用或手动实现 setter；
- 并发场景下不可直接使用此方案（setCount 非线程安全），应改用 ConcurrentHashMap + compute 或 Collectors.toConcurrentMap。
最终结果为去重后的 List
