在Java中如何使用Stream.collect将处理结果收集_Stream收集技巧

author Java

2025-11-04 0 442

Stream.collect 是Java中用于将流元素收集到集合或数据结构中的终端操作，支持列表、去重、映射构建、分组分区及字符串拼接等。1. 使用 toList、toSet 可将流转换为对应集合；2. toMap 按键生成映射，需处理重复键的合并策略；3. groupingBy 实现按字段分组，支持多级分组，partitioningBy 按布尔条件分为两组；4. join

在Java中，Stream.collect 是一个强大的终端操作，用于将流中的元素累积到集合、容器或其他数据结构中。它不仅支持常见的 List 或 Set 收集，还能实现分组、分区、拼接字符串等复杂操作。掌握 collect 的使用技巧，能显著提升代码的可读性和功能性。

基本收集：toList、toSet、toCollection

最简单的收集方式是将流元素放入集合中。Java 8 提供了 Collectors 工具类来简化这些操作。

常用方法包括：

Collectors.toList()：收集为 List
Collectors.toSet()：收集为 Set（自动去重）
Collectors.toCollection(LinkedList::new)：指定具体集合类型

示例：

<font> List<String> names = users.stream()
     .map(User::getName)
     .collect(Collectors.toList());

 Set<String> uniqueNames = users.stream()
     .map(User::getName)
     .collect(Collectors.toSet());</font>

收集为Map：toMap

当需要以某个字段作为键构建映射时，Collectors.toMap 非常实用。

立即学习“Java免费学习笔记（深入）”；

方法签名：

<font>toMap(keyMapper, valueMapper)</font>

如果存在重复键，会抛出异常。此时应提供合并策略：

<font> Map<Long, User> userMap = users.stream()
     .collect(Collectors.toMap(User::getId, user -> user,
                               (existing, replacement) -> existing));</font>

第三个参数用于解决冲突，这里保留第一个值。

分组与分区：groupingBy 与 partitioningBy

groupingBy 按条件分组，返回 Map<K, List<T>>。

集简云

软件集成平台，快速建立企业自动化与智能化

22
查看详情

<font> Map<String, List<User>> byDepartment = users.stream()
     .collect(Collectors.groupingBy(User::getDepartment));</font>

支持多级分组：

<font> Map<String, Map<Integer, List<User>>> grouped = users.stream()
     .collect(Collectors.groupingBy(
         User::getDepartment,
         Collectors.groupingBy(User::getAge)
     ));</font>

partitioningBy 是特殊的分组，按布尔条件分为两组（true/false）：

<font> Map<Boolean, List<User>> adults = users.stream()
     .collect(Collectors.partitioningBy(u -> u.getAge() >= 18));</font>

自定义收集：StringBuilder、汇总统计

使用 collect 可以灵活构建字符串或计算统计值。

拼接姓名：

<font> String names = users.stream()
     .map(User::getName)
     .collect(Collectors.joining(", ", "Users: ", "."));</font>

结果如：Users: Alice, Bob.

数值统计（如年龄总和、平均值）：

<font> IntSummaryStatistics stats = users.stream()
     .collect(Collectors.summarizingInt(User::getAge));

 int sum = stats.getSum();
 double avg = stats.getAverage();</font>