17370845950

Collectors 是 Stream 的终端收集器，用于将流结果规整装入指定容器；必须配合 collect() 使用，提供 toList、groupingBy、joining、toMap 等模板，需注意 key 冲突处理、下游收集器嵌套规则及返回集合的可变性与线程安全性。

Collectors 的作用很直接：把 Stream 流处理后的结果，规整地“装进”你想要的容器或结构里。它不是用来过滤、转换或排序的（那是中间操作的事），而是流的“终点打包员”——没有它，collect() 就没法知道该生成 List、Map 还是统计值。

什么时候必须用 Collectors？

只要调用了 stream().collect(...)，你就绕不开 Collectors。它提供的是「怎么收」的模板，不是可选项。

• 想把员工流变成 List？→ 用 Collectors.toList()
• 要按部门分组，每个部门对应一个员工列表？→ 用 Collectors.groupingBy(Employee::getDepartment)
• 需要把所有用户名拼成逗号分隔字符串？→ 用 Collectors.joining(", ")
• 连并行流合并中间结果都靠它（比如 toList() 的 combiner 函数）

toMap() 为什么总抛 IllegalStateException: Duplicate key？

这是最常踩的坑：toMap(keyMapper, valueMapper) 默认不处理重复 key。一旦两个元素映射出相同 key，就直接炸。

• ✅ 正确写法（加冲突解决策略）：

  Map map = list.stream()
      .collect(Collectors.toMap(
          Person::getName,
          Person::getAge,
          (oldVal, newVal) -> oldVal  // 保留旧值
      ));

• ⚠️ 注意：第三个参数（merge function）不可为 null；若想强制报错，得显式 throw
• ? 进阶：想用 TreeMap 或 ConcurrentHashMap？用四参数重载版，传构造函数引用

分组后还想统计，别嵌套两层 collect()

很多人写：groupingBy(...).values().stream().map(...).collect(...) —— 这样做既多走一遍流，又丢掉了分组的上下文信息。

• ✅ 正确姿势：用下游收集器（downstream collector）直接嵌套：

  Map deptTotal = employees.stream()
      .collect(Collectors.groupingBy(
          Employee::getDepartment,
          Collectors.summingInt(Employee::getSalary)
      ));

• ✅ 支持任意组合：比如 groupingBy(dept, mapping(..., toSet())) 或 groupingBy(dept, filtering(..., counting()))
• ⚠️ 注意：下游收集器不能是 toList() 这类“无状态”的简单收集器以外的终端操作；否则编译不过

性能与不可变性：别默认以为 toList() 返回的是 ArrayList

从 Java 16 开始，Collectors.toList() 的返回类型是未指定的不可变 List（通常是 ImmutableCollections.ListN）。如果你后续要 add() 或 remove()，会直接抛 UnsupportedOperationException。

• ✅ 需要可变列表？显式指定：

  .collect(Collectors.toCollection(ArrayList::new))

• ✅ 需要线程安全？用 toCollection(CopyOnWriteArrayList::new)
• ✅ 想要有序唯一集合？toCollection(TreeSet::new) 比 toSet() 更可控

真正容易被忽略的，是下游收集器的“惰性组合”机制——它让一次流遍历完成多层聚合，但一旦写错嵌套层级或 merge 策略，错误往往延迟到运行时才暴露，且堆栈信息不友好。写 groupingBy 或 toMap 时，先想清楚 key 冲突和空值场景，比补 try-catch 有用得多。