一文帶你了解Java8?Stream流處理中的收集器技巧
Java 8 引入的 Stream 極大地簡化了集合數(shù)據(jù)的處理，提供了一種現(xiàn)代、函數(shù)式的方式來處理數(shù)據(jù)。然而，在處理流時(shí)，我們經(jīng)常需要將流的結(jié)果匯總到集合中或者進(jìn)行各種統(tǒng)計(jì)計(jì)算。這就是收集器（Collectors）發(fā)揮作用的地方。本文將深入探討 Java 8 Stream 中的收集器，介紹收集器的各種用法和技巧，幫助你更好地利用收集器處理數(shù)據(jù)。
什么是收集器（Collectors）
收集器是 Stream 提供的一個(gè)重要功能，用于將流的元素收集到一個(gè)結(jié)果容器中。通過使用收集器，可以讓代碼更加方便的進(jìn)行簡化與重用。其內(nèi)部主要核心是通過 Collectos 完成更加復(fù)雜的計(jì)算轉(zhuǎn)換從而獲取到最終結(jié)果。
Java 8 在 Collectors 類中預(yù)定義了多個(gè)用于收集的方法，使得我們可以輕松地對(duì)流的元素進(jìn)行匯總、分組、分區(qū)以及其他各種操作。
常見的收集器用法
通過 toList 將元素收集到集合中
List<String> names = peopleStream.map(Person::getName)
.collect(Collectors.toList());通過 counting 統(tǒng)計(jì)集合總數(shù)
Long collect = studentList.stream().collect(Collectors.counting());
通過 maxBy 和 minBy 獲取最大值最小值
Optional<Student> optional = studentList.stream().collect(Collectors.maxBy(Comparator.comparing(Student::getAge));)
if (optional.isPresent()){
Student student = optional.get();
System.out.println(student);
}通過 summingLnt 進(jìn)行數(shù)據(jù)匯總
Integer collect = peopleStream.collect(Collectors.summingLnt(Person::getAge)); int sum = peopleStream.mapToInt(Person::getAge).sum();
通過 averagingLnt 進(jìn)行平均值獲取
Double collect = peopleStream.collect(Collectors.averagingLnt(Person::getAge));
其內(nèi)部是在收集過程中，對(duì)所有年齡進(jìn)行累加，最后除以平均值
通過 joining 進(jìn)行數(shù)據(jù)拼接
Person collect = peopleStream.collect(Collectors.joining());
這種方式相當(dāng)于將流中每一個(gè)元素的name屬性獲取映射，內(nèi)部通過StringBuilder來把每一個(gè)映射的值進(jìn)行拼接。
通過 groupingBy 將數(shù)據(jù)進(jìn)行分組
Map<Integer,List<Student>> map = peopleStream.collect(Collectors.groupingBy(Person::getAge));
自定義收集器
已經(jīng)通過Collectors中提供的靜態(tài)方法，完成了諸多的收集器操作，雖然它本身提供了諸多方法，但是不一定能夠覆蓋日常開發(fā)中的所有需求，因此，有時(shí)還需要我們根據(jù)自身的業(yè)務(wù)去自定義收集器的實(shí)現(xiàn)。通過實(shí)現(xiàn) Collector 接口，我們可以完全掌控收集的過程。
源碼分析
根據(jù)源碼，Collector 接口需要三個(gè)參數(shù)。
- T: 流中要收集的元素類型
- A: 累加器的類型
- R：收集的結(jié)果類型
如果想要自定義收集器，需要實(shí)現(xiàn) Collector 接口中的五個(gè)方法 Supplier、Accumulator、finisher、combiner、characteristics
supplier：用于創(chuàng)建一個(gè)容器，在調(diào)用它時(shí)，需要?jiǎng)?chuàng)建一個(gè)空的累加器實(shí)例，供后續(xù)方法使用。
accumulator：基于supplier中創(chuàng)建的累加容器，進(jìn)行累加操作。
finisher：當(dāng)遍歷完流后，在其內(nèi)部完成最終轉(zhuǎn)換，返回一個(gè)最終結(jié)果。
combiner：用于在并發(fā)情況下，將每個(gè)線程的容器進(jìn)行合并。
characteristics：用于定義收集器行為，如是否可以并行或使用哪些優(yōu)化。其本身是一個(gè)枚舉，內(nèi)部有三個(gè)值，分別為：
- CONCURRENT：表明收集器是并行的且只會(huì)存在一個(gè)中間容器。
- UNORDERED：表明結(jié)果不受流中順序影響，收集是無序的。
- IDENTITY_FINISH：表明累積器的結(jié)果將會(huì)直接作為歸約的最終結(jié)果，跳過finisher()。
實(shí)戰(zhàn)示例：收集合格的學(xué)生
定義自定義收集器
package com.jdk8.features.stream.collector;
import com.jdk8.features.lambda.Student;
import java.util.ArrayList;
import java.util.EnumSet;
import java.util.List;
import java.util.Set;
import java.util.function.BiConsumer;
import java.util.function.BinaryOperator;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collector;
public class MyCollector implements Collector<Student, List<Student>,List<Student>> {
@Override
public Supplier<List<Student>> supplier() {
return ArrayList::new;
}
@Override
public BiConsumer<List<Student>, Student> accumulator() {
return ((studentList, student) -> {
if (student.getIsPass()){
studentList.add(student);
}
});
}
@Override
public BinaryOperator<List<Student>> combiner() {
return null;
}
@Override
public Function<List<Student>, List<Student>> finisher() {
return Function.identity();
}
@Override
public Set<Characteristics> characteristics() {
return EnumSet.of(Characteristics.IDENTITY_FINISH,Characteristics.UNORDERED);
}
}使用自定義收集器
import com.jdk8.features.lambda.Student;
import java.util.ArrayList;
import java.util.List;
public class MyCollectorDemo {
public static void main(String[] args) {
List<Student> studentList = new ArrayList<>();
studentList.add(new Student(1,"張三",18,19));
studentList.add(new Student(2,"李四",19,18));
studentList.add(new Student(3,"王五",20,21));
studentList.add(new Student(4,"趙六",21,80));
List<Student> list = studentList.stream().collect(new MyCollector());
System.out.println(list);
}
}結(jié)語
掌握收集器的使用是精通 Java 8 Stream 不可或缺的一部分。在處理流數(shù)據(jù)時(shí)，收集器可以幫助我們更輕松地完成數(shù)據(jù)的匯總、分組、分區(qū)等操作。通過本文的介紹，相信你已經(jīng)對(duì)收集器有了更深入的了解，并能夠在實(shí)際項(xiàng)目中靈活運(yùn)用收集器的各種技巧。讓我們?cè)诹魈幚淼穆贸讨懈佑稳杏杏啵?/p>
到此這篇關(guān)于一文帶你了解Java8 Stream流處理中的收集器技巧的文章就介紹到這了,更多相關(guān)Java8 Stream內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java中對(duì)list集合進(jìn)行分頁的四種方式介紹
這篇文章主要為大家詳細(xì)介紹了Java中對(duì)list集合進(jìn)行分頁的四種方式,文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,感興趣的小伙伴可以了解下2025-12-12
java+mysql模擬實(shí)現(xiàn)銀行系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了java+mysql模擬實(shí)現(xiàn)銀行系統(tǒng)，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-05-05
springboot2.1.3配置sftp自定義sftp連接池的詳細(xì)過程
這篇文章主要介紹了springboot2.1.3配置sftp自定義sftp連接池的詳細(xì)過程,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-08-08
SpringBoot和Vue實(shí)現(xiàn)動(dòng)態(tài)二維碼的示例代碼
二維碼在現(xiàn)代社交和營銷活動(dòng)中被廣泛使用,本文主要介紹了SpringBoot和Vue實(shí)現(xiàn)動(dòng)態(tài)二維碼的示例代碼,文中通過示例代碼介紹的非常詳細(xì),需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-02-02
Java依賴倒轉(zhuǎn)原則_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要介紹了Java依賴倒轉(zhuǎn)原則的定義及問題由來解決方案，感興趣的朋友一起看看吧2017-08-08
這篇文章主要介紹了MyBatis中#{}占位符與${}拼接符的用法說明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2021-02-02
本篇文章介紹了，在java中"==" 與equals方法的使用。需要的朋友參考下2013-04-04
大家一致認(rèn)為springBoot使用swagger太麻煩了，每次都需要編寫config，今天小編告訴大家一種超簡單配置方法，教大家如何整合swagger，感興趣的朋友跟隨小編一起看看吧2021-07-07
@PathVariable和@RequestParam傳參為空問題及解決
這篇文章主要介紹了@PathVariable和@RequestParam傳參為空問題及解決，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-11-11
Java數(shù)組轉(zhuǎn)換為List的四種方式
這篇文章主要介紹了Java開發(fā)技巧數(shù)組轉(zhuǎn)List的四種方式總結(jié),每種方式結(jié)合實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-09-09