快捷導(dǎo)航

java stream中Collectors的用法實(shí)例精講

更新時(shí)間：2023年09月15日 10:08:44 作者：flydean

這篇文章主要為大家介紹了java stream中Collectors的用法實(shí)例精講,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

簡(jiǎn)介
Collectors.toList()
Collectors.toSet()
Collectors.toCollection()
Collectors.toMap()
Collectors.collectingAndThen()
Collectors.joining()
Collectors.counting()
Collectors.summarizingDouble/Long/Int()
Collectors.averagingDouble/Long/Int()
Collectors.summingDouble/Long/Int()
Collectors.maxBy()/minBy()
Collectors.groupingBy()
Collectors.partitioningBy()
總結(jié)

簡(jiǎn)介

在java stream中，我們通常需要將處理后的stream轉(zhuǎn)換成集合類，這個(gè)時(shí)候就需要用到stream.collect方法。collect方法需要傳入一個(gè)Collector類型，要實(shí)現(xiàn)Collector還是很麻煩的，需要實(shí)現(xiàn)好幾個(gè)接口。

于是java提供了更簡(jiǎn)單的Collectors工具類來(lái)方便我們構(gòu)建Collector。

下面我們將會(huì)具體講解Collectors的用法。

假如我們有這樣兩個(gè)list：

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

上面一個(gè)是無(wú)重復(fù)的list，一個(gè)是帶重復(fù)數(shù)據(jù)的list。接下來(lái)的例子我們會(huì)用上面的兩個(gè)list來(lái)講解Collectors的用法。

Collectors.toList()

List&lt;String&gt; listResult = list.stream().collect(Collectors.toList());
        log.info("{}",listResult);

將stream轉(zhuǎn)換為list。這里轉(zhuǎn)換的list是ArrayList，如果想要轉(zhuǎn)換成特定的list，需要使用toCollection方法。

Collectors.toSet()

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

toSet將Stream轉(zhuǎn)換成為set。這里轉(zhuǎn)換的是HashSet。如果需要特別指定set，那么需要使用toCollection方法。

因?yàn)閟et中是沒有重復(fù)的元素，如果我們使用duplicateList來(lái)轉(zhuǎn)換的話，會(huì)發(fā)現(xiàn)最終結(jié)果中只有一個(gè)jack。

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

Collectors.toCollection()

上面的toMap,toSet轉(zhuǎn)換出來(lái)的都是特定的類型，如果我們需要自定義，則可以使用toCollection()

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

上面的例子，我們轉(zhuǎn)換成了LinkedList。

Collectors.toMap()

toMap接收兩個(gè)參數(shù)，第一個(gè)參數(shù)是keyMapper，第二個(gè)參數(shù)是valueMapper:

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

如果stream中有重復(fù)的值，則轉(zhuǎn)換會(huì)報(bào)IllegalStateException異常：

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

怎么解決這個(gè)問(wèn)題呢？我們可以這樣：

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

在toMap中添加第三個(gè)參數(shù)mergeFunction，來(lái)解決沖突的問(wèn)題。

Collectors.collectingAndThen()

collectingAndThen允許我們對(duì)生成的集合再做一次操作。

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

Collectors.joining()

Joining用來(lái)連接stream中的元素：

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

可以不帶參數(shù)，也可以帶一個(gè)參數(shù)，也可以帶三個(gè)參數(shù)，根據(jù)我們的需要進(jìn)行選擇。

Collectors.counting()

counting主要用來(lái)統(tǒng)計(jì)stream中元素的個(gè)數(shù)：

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

Collectors.summarizingDouble/Long/Int()

SummarizingDouble/Long/Int為stream中的元素生成了統(tǒng)計(jì)信息，返回的結(jié)果是一個(gè)統(tǒng)計(jì)類：

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

輸出結(jié)果：

22:22:35.238 [main] INFO com.flydean.CollectorUsage - IntSummaryStatistics{count=4, sum=16, min=3, average=4.000000, max=5}

Collectors.averagingDouble/Long/Int()

averagingDouble/Long/Int()對(duì)stream中的元素做平均：

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

Collectors.summingDouble/Long/Int()

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

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

Collectors.maxBy()/minBy()

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

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

Collectors.groupingBy()

GroupingBy根據(jù)某些屬性進(jìn)行分組，并返回一個(gè)Map：

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

Collectors.partitioningBy()

PartitioningBy是一個(gè)特別的groupingBy，PartitioningBy返回一個(gè)Map，這個(gè)Map是以boolean值為key，從而將stream分成兩部分，一部分是匹配PartitioningBy條件的，一部分是不滿足條件的：

Map<Boolean, List<String>> partitionResult = list.stream()
                .collect(Collectors.partitioningBy(s -> s.length() > 3));
        log.info("{}",partitionResult);

看下運(yùn)行結(jié)果：