Java Streams 中按双字段分组并聚合计数到原对象的完整实践

文章小白一枚，正在不断学习积累知识，现将学习到的知识记录一下，也是将我的所得分享给大家！而今天这篇文章《Java Streams 中按双字段分组并聚合计数到原对象的完整实践 》带大家来了解一下##content_title##，希望对大家的知识积累有所帮助，从而弥补自己的不足，助力实战开发！

本文详解如何使用 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>，而 Collectors.counting() 只能产出 Long；但我们需复用原始对象实例，并在归并过程中就地更新 count。解决方案是结合 Collectors.reducing 与副作用初始化——利用 groupingBy 的分类键生成阶段对每个元素预设 count = 1，再通过 reducing 在同组内逐个合并，每次将后一个对象的计数累加到前一个对象上。

以下是推荐实现（基于 Lombok Builder + 正确 setter）：

import org.apache.commons.lang3.tuple.Pair;
import java.util.*;
import java.util.stream.Collectors;

List 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());

✅ 关键要点说明：

• 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，每个元素代表唯一的 (title, author) 组合，且 count 字段准确反映其在原始列表中的频次——简洁、高效，且完全符合函数式流式处理的设计意图。

本篇关于《Java Streams 中按双字段分组并聚合计数到原对象的完整实践 》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！