Collectors是Java 8 Stream API中用于数据收集的核心工具类,提供toList、toSet实现元素收集,summing、averaging、summarizing支持数值聚合,groupingBy、partitioningBy实现分组与分区,joining、mapping、collectingAndThen支持字符串拼接、类型转换和结果封装,通过下游收集器组合实现复杂操作,提升代码简洁性与可读性。
在Java 8引入的Stream API中,Collectors 是一个非常强大的工具类,用于将流中的元素收集到集合、分组、聚合等。它配合 stream().collect() 方法使用,可以简洁高效地处理数据。掌握 Collectors 的常见用法和技巧,能大幅提升代码可读性和开发效率。
1. 收集到集合:toList、toSet、toMap
最常见的需求是把流中的元素收集到一个集合中。Collectors 提供了多种工厂方法:
- toList():收集为 List
- toSet():收集为 Set(自动去重)
- toCollection(构造器):自定义集合类型,如 LinkedList、TreeSet 等
Listnames = users.stream() .map(User::getName) .collect(Collectors.toList()); Set uniqueNames = users.stream() .map(User::getName) .collect(Collectors.toSet()); TreeSet sortedNames = users.stream() .map(User::getName) .collect(Collectors.toCollection(TreeSet::new));
2. 聚合操作:summing、averaging、summarizing
对数值型字段进行统计时,Collectors 提供了便捷的聚合方法:
- summingInt/Long/Double:求和
- averagingInt/Long/Double:求平均值
- summarizingInt/Long/Double:返回一个包含 count、sum、min、max、average 的摘要对象
int totalAge = users.stream()
.collect(Collectors.summingInt(User::getAge));
DoubleSummaryStatistics stats = users.stream()
.collect(Collectors.summarizingDouble(User::getSalary));
System.out.println(stats.getAverage());
System.out.println(stats.getMax());
3. 分组与分区:groupingBy、partitioningBy
按条件对数据进行分类是常见需求,Collectors 提供了灵活的分组方式:
-
groupingBy(Function):按某个属性或函数结果分组,返回 Map
- groupingBy(Function, downstream):支持二级收集器,比如分组后求和
- partitioningBy(Predicate):按布尔条件分为两组(true/false)
// 按年龄分组 Map> byAge = users.stream() .collect(Collectors.groupingBy(User::getAge)); // 按性别分组,并统计每组人数 Map countByGender = users.stream() .collect(Collectors.groupingBy(User::getGender, Collectors.counting())); // 按薪资是否高于5000分区 Map > highEarnerPartition = users.stream() .collect(Collectors.partitioningBy(u -> u.getSalary() > 5000));
4. 自定义收集与joining、mapping
除了基础操作,Collectors 还支持字符串拼接、类型转换等高级功能:
- joining(CharSequence):将元素拼接成字符串,可指定分隔符、前缀、后缀
- mapping(Function, Collector):先转换元素类型,再用下游收集器处理
- collectingAndThen:在收集完成后执行额外操作
// 拼接用户名,逗号分隔 String namesStr = users.stream() .map(User::getName) .collect(Collectors.joining(", ", "[", "]")); // 先转大写,再收集为列表 List
upperNames = users.stream() .collect(Collectors.mapping(u -> u.getName().toUpperCase(), Collectors.toList())); // 收集为不可修改列表 List immutableList = users.stream() .collect(Collectors.collectingAndThen( Collectors.toList(), Collections::unmodifiableList));
基本上就这些常用技巧。合理使用 Collectors 可以让流式处理更加简洁有力,避免手动遍历和条件判断。关键是理解“下游收集器”的组合思想,灵活搭配使用。不复杂但容易忽略的是,很多方法都支持第二参数作为下游收集器,这是实现复杂逻辑的关键。









