# 简介

在 java stream 中，我们通常需要将处理后的 stream 转换成集合类，这个时候就需要用到 stream.collect 方法。 collect 方法需要传入一个 Collector 类型，要实现 Collector 还是很麻烦的，需要实现好几个接口。

于是 java 提供了更简单的 Collectors 工具类来方便我们构建 Collector 。

下面我们将会具体讲解 Collectors 的用法。

假如我们有这样两个 list：

1
2

List<String> list = Arrays.asList("jack", "bob", "alice", "mark");
List<String> duplicateList = Arrays.asList("jack", "jack", "alice", "mark");

上面一个是无重复的 list ，一个是带重复数据的 list 。接下来的例子我们会用上面的两个 list 来讲解 Collectors 的用法。

# Collectors.toList()

1
2

List<String> listResult = list.stream().collect(Collectors.toList());
        log.info("{}",listResult);

将 stream 转换为 list 。这里转换的 list 是 ArrayList ，如果想要转换成特定的 list ，需要使用 toCollection 方法。

# Collectors.toSet()

1
2

Set<String> setResult = list.stream().collect(Collectors.toSet());
        log.info("{}",setResult);

# Collectors.toCollection()

上面的 toMap,toSet 转换出来的都是特定的类型，如果我们需要自定义，则可以使用 toCollection()

1
2

List<String> custListResult = list.stream().collect(Collectors.toCollection(LinkedList::new));
        log.info("{}",custListResult);

# Collectors.toMap()

toMap 接收两个参数，第一个参数是 keyMapper ，第二个参数是 valueMapper :

1
2
3

Map<String, Integer> mapResult = list.stream()
                .collect(Collectors.toMap(Function.identity(), String::length));
        log.info("{}",mapResult);

如果 stream 中有重复的值，则转换会报 IllegalStateException 异常：

1
2

Map<String, Integer> duplicateMapResult = duplicateList.stream()
                .collect(Collectors.toMap(Function.identity(), String::length));

解决方案:

1
2
3

Map<String, Integer> duplicateMapResult2 = duplicateList.stream()
                .collect(Collectors.toMap(Function.identity(), String::length, (item, identicalItem) -> item));
        log.info("{}",duplicateMapResult2);

在 toMap 中添加第三个参数 mergeFunction ，来解决冲突的问题。

# Collectors.collectingAndThen()

collectingAndThen 允许我们对生成的集合再做一次操作。

1
2
3

List<String> collectAndThenResult = list.stream()
                .collect(Collectors.collectingAndThen(Collectors.toList(), l -> {return new ArrayList<>(l);}));
        log.info("{}",collectAndThenResult);

# Collectors.joining()

Joining 用来连接 stream 中的元素：

1
2
3
4
5
6

String joinResult = list.stream().collect(Collectors.joining());
        log.info("{}",joinResult);
        String joinResult1 = list.stream().collect(Collectors.joining(" "));
        log.info("{}",joinResult1);
        String joinResult2 = list.stream().collect(Collectors.joining(" ", "prefix","suffix"));
        log.info("{}",joinResult2);

可以不带参数，也可以带一个参数，也可以带三个参数，根据我们的需要进行选择。

# Collectors.counting()

counting 主要用来统计 stream 中元素的个数：

1
2

Long countResult = list.stream().collect(Collectors.counting());
        log.info("{}",countResult);

# Collectors.summarizingDouble/Long/Int()

SummarizingDouble/Long/Int 为 stream 中的元素生成了统计信息，返回的结果是一个统计类：

1
2
3

IntSummaryStatistics intResult = list.stream()
                .collect(Collectors.summarizingInt(String::length));
        log.info("{}",intResult);

# Collectors.averagingDouble/Long/Int()

averagingDouble/Long/Int() 对 stream 中的元素做平均：

1
2

Double averageResult = list.stream().collect(Collectors.averagingInt(String::length));
        log.info("{}",averageResult);

# Collectors.summingDouble/Long/Int()

summingDouble/Long/Int() 对 stream 中的元素做 sum 操作：

1
2

Double summingResult = list.stream().collect(Collectors.summingDouble(String::length));
        log.info("{}",summingResult);

# Collectors.maxBy()/minBy()

maxBy()/minBy() 根据提供的 Comparator ，返回 stream 中的最大或者最小值：

1
2

Optional<String> maxByResult = list.stream().collect(Collectors.maxBy(Comparator.naturalOrder()));
        log.info("{}",maxByResult);

# Collectors.groupingBy()

GroupingBy 根据某些属性进行分组，并返回一个 Map ：

1
2
3

Map<Integer, Set<String>> groupByResult = list.stream()
                .collect(Collectors.groupingBy(String::length, Collectors.toSet()));
        log.info("{}",groupByResult);

# Collectors.partitioningBy()

PartitioningBy 是一个特别的 groupingBy，PartitioningBy 返回一个 Map ，这个 Map 是以 boolean 值为 key ，从而将 stream 分成两部分，一部分是匹配 PartitioningBy 条件的，一部分是不满足条件的：