Java?中如何使用?stream?流
前言
如果你了解過 Liunx ，了解過 Liunx 的中管道命令 | ，那么你會發(fā)現(xiàn)，其實 Java 8 的 stream 和 Liunx 非常類似的。
Liunx 中的管道命令也是將上一個命令的輸出流作為下一條命令的輸入流。
今天主要聊起的是如何使用 stream 流，關(guān)于它為什么被引入，有什么樣的優(yōu)勢，還有一些平時未曾注意到的知識點的話，就在下一次再講吧~
能基礎的使用，是深入了解它的一個基礎吧，我覺得~
在本文中，你將會看到Stream API支持的許多操作。這些操作能讓你快速完成復雜的數(shù)據(jù)查詢，如篩選、切片、映射、查找、匹配和歸約。
一、篩選和切片
1.1、篩選 filter
filter 會接受一個 Predicate 接口的參數(shù)，其本質(zhì)就是一個布爾值函數(shù)（官方稱為謂詞，說成白話，即為一個布爾值函數(shù)）
準備好的數(shù)據(jù)~
? ? ? static ? List<Student> students = new ArrayList<>();
??
? ? ?static {
? ? ? ? ? ? ? ? students.add(new Student("學生A", "大學1", 18));
? ? ? ? ?students.add(new Student("學生A", "大學1", 18));
? ? ? ? ?students.add(new Student("學生A", "大學1", 18));
? ? ? ? ?students.add(new Student("學生A", "大學1", 18));
? ? ? ? ?students.add(new Student("學生B", "大學1", 18));
? ? ? ? ?students.add(new Student("學生C", "大學1", 19));
? ? ? ? ?students.add(new Student("學生D", "大學2", 20));
? ? ? ? ?students.add(new Student("學生E", "大學2", 21));
? ? ? ? ?students.add(new Student("學生F", "大學2", 20));
? ? ? ? ?students.add(new Student("學生G", "大學3", 22));
? ? ? ? ?students.add(new Student("學生H", "大學3", 23));
? ? ? ? ?students.add(new Student("學生I", "大學3", 19));
? ? ? ? ?students.add(new Student("學生J", "大學4", 20));
? ? }1、從中篩選出小于20的學生們組成一個新的集合
jdk 8 之前的寫法：
?List<Student> result = new ArrayList<>();
?for (Student student : students) {
? ? ?if (student.getAge() < 20) {
? ? ? ? ?result.add(student);
? ? }
?}Jdk 8 及之后的寫法：使用stream流操作
?/**
? ? ? * 選出小于20的學生組成一個集合
? ? ? *
? ? ? * @param students
? ? ? */
?private static List<Student> selectAgeLt18(List<Student> students) {
? ? ?// 最基礎的寫法， filter的參數(shù)是一個 Predicate,而它是一個FunctionalInterface 式的接口， 唯一的接口就是表示一個參數(shù)的謂詞（布爾值函數(shù)）。
? ? ?// ? ? ? List<Student> list = students.stream().filter(new Predicate<Student>() {
? ? ?// ? ? ? ? ? @Override
? ? ?// ? ? ? ? ? public boolean test(Student student) {
? ? ?// ? ? ? ? ? ? ? return student.getAge()<20;
? ? ?// ? ? ? ? ? }
? ? ?// ? ? ? }).collect(Collectors.toList());
? ? ?// 因此可以簡化寫成 以下這種寫法
? ? ?// ? ? ? List<Student> list = students.stream().filter(student -> {
? ? ?// ? ? ? ? ? return student.getAge() < 20;
? ? ?// ? ? ? }).collect(Collectors.toList());
? ? ?//又因為filter 的參數(shù)實際上是一個lambda表達式，當只有一條返回語句時，又可以省略大括號和return
? ? ?List<Student> list = students.stream().filter(student -> student.getAge() < 20).collect(Collectors.toList());
? ? ?return list;
?}1.2、去重 distinct
distinct（）它會返回一個元素各異（根據(jù)流所生成元素的 hashCode和equals方法實現(xiàn)）的流。
jdk 8之前對集合的一些去重方式
?/**
? ? ? * 去重操作，去除掉數(shù)據(jù)集合中重復的數(shù)據(jù)
? ? ? */
?private static void selectSchoolRepresent(List<Student> students) {
? ? ?// ? ? ? ? jdk 8之前的一些方式，
? ? ?// ? ? ? ? 1、set集合去重
? ? ?HashSet<Student> set = new HashSet<>();
? ? ?for (Student student : students) {
? ? ? ? ?set.add(student);
? ? }
? ? ?// ? ? ? ? 還可以簡寫成
? ? ?List<Student> newList = new ArrayList<>(new HashSet<>(students));
??
? ? ?// ? ? ? ? 2、 利用 list的contains() 方法
? ? ?List<Student> list = new ArrayList<>();
? ? ?for (Student student : students) {
? ? ? ? ?if(!list.contains(student)){
? ? ? ? ? ? ?list.add(student);
? ? ? ? }
? ? }
?}Java 8 及之后使用stream中的 distinct（）方法，其實咋說勒，就是方便，其他的也木有
?/**
? ? ? * 去重操作，去除掉數(shù)據(jù)集合中重復的數(shù)據(jù)
? ? ? */
?private static void selectSchoolRepresent(List<Student> students) {
? ? ?List<Student> collect = students.stream().distinct().collect(Collectors.toList());
? ? ?collect.forEach(System.out::println);
?}1.3、切片 limit
流支持limit(n)方法，該方法會返回一個不超過給定長度的流。
如果流是有序的，則最多會返回前n個元素。無序的則不會以任何方式排序。
Jdk 8 之前的寫法
?/**
? ? ? * 選出集合中前五位同學 組成一個新的集合
? ? ? *
? ? ? * @param students
? ? ? */
?private static void selectLimit(List<Student> students) {
? ? ?List<Student> list = new ArrayList<>();
? ? ?for (int i = 0; i < students.size(); i++) {
? ? ? ? ?if (i < 5) {
? ? ? ? ? ? ?list.add(students.get(i));
? ? ? ? }
? ? }
? ? ?list.forEach(System.out::println);
?}Jdk 8的 stream 流中的 limit 的寫法
?/**
? ? ? * 選出集合中前五位同學 組成一個新的集合
? ? ? *
? ? ? * @param students
? ? ? */
?private static void selectLimit(List<Student> students) {
??
? ? ?List<Student> collect = students.stream().limit(5).collect(Collectors.toList());
??
? ? ?collect.forEach(System.out::println);
?}1.4、跳過元素 skip
流還支持skip(n)方法，返回一個扔掉了前n個元素的流。如果流中元素不足n個，則返回一 個空流。
?/**
? ? ? * 從第二個同學開始組成新的集合
? ? ? *
? ? ? * @param students
? ? ? */
?private static void selectSkip(List<Student> students) {
? ? ?List<Student> collect = students.stream().skip(2).collect(Collectors.toList());
? ? ?collect.forEach(System.out::println);
? ? ?/**
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=90.0)
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=76.0)
? ? ? ? ? * Student(name=學生B, school=大學1, age=18, score=91.0)
? ? ? ? ? * Student(name=學生C, school=大學1, age=19, score=65.0)
? ? ? ? ? * Student(name=學生D, school=大學2, age=20, score=80.0)
? ? ? ? ? * Student(name=學生E, school=大學2, age=21, score=78.0)
? ? ? ? ? * Student(name=學生F, school=大學2, age=20, score=67.0)
? ? ? ? ? * Student(name=學生G, school=大學3, age=22, score=87.0)
? ? ? ? ? * Student(name=學生H, school=大學3, age=23, score=79.0)
? ? ? ? ? * Student(name=學生I, school=大學3, age=19, score=92.0)
? ? ? ? ? * Student(name=學生J, school=大學4, age=20, score=84.0)
? ? ? ? ? */
?}1.5、排序 sorted
這個就是排序啦，沒啥能說的啦吧~偷個懶哈
? ? ?/**
? ? ? * 給這群學生按年齡排序
? ? ? *
? ? ? *
? ? ? * @param students
? ? ? */
? ? ?private static void sortedDemo(List<Student> students) {
? ? ? ? ?List<Student> collect = students.stream()
? ? ? ? ? ? ? ? .sorted((student1, student2) -> student1.getAge() - student2.getAge())
? ? ? ? ? ? ? ? .collect(Collectors.toList());
? ? ? ? ?collect.forEach(System.out::println);
??
? ? ? ? ?/**
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=98.0)
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=91.0)
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=90.0)
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=76.0)
? ? ? ? ? * Student(name=學生B, school=大學1, age=18, score=91.0)
? ? ? ? ? * Student(name=學生C, school=大學1, age=19, score=65.0)
? ? ? ? ? * Student(name=學生I, school=大學3, age=19, score=92.0)
? ? ? ? ? * Student(name=學生D, school=大學2, age=20, score=80.0)
? ? ? ? ? * Student(name=學生F, school=大學2, age=20, score=67.0)
? ? ? ? ? * Student(name=學生J, school=大學4, age=20, score=84.0)
? ? ? ? ? * Student(name=學生E, school=大學2, age=21, score=78.0)
? ? ? ? ? * Student(name=學生G, school=大學3, age=22, score=87.0)
? ? ? ? ? * Student(name=學生H, school=大學3, age=23, score=79.0)
? ? ? ? ? */
? ? }1.6、小結(jié)與綜合應用
filter 、distinct、limit、skip、sorted 對比起 Java 8 之前的一些實現(xiàn)，從我個人看來是方便了許多的。
如果是看起來不習慣，我覺得可以試著多用上幾次，會慢慢愛上它的。
綜合應用
filter 、distinct、limit、skip、sorted 這些操作，他們的執(zhí)行結(jié)果的返回值仍然是 stream，所以在使用中,他們完全可以無縫鏈接.
如: 我要去這一群學生中找到 年齡在 20 歲以下，分數(shù)在90分以上的前3名學生。
? ? ?/**
? ? ? * 如: 我要去這一群學生中找到 年齡在 20 歲以下，分數(shù)在90分以上的前3名學生。
? ? ? *
? ? ? * @param students
? ? ? */
? ? ?private static void select(List<Student> students) {
? ? ? ? ?List<Student> collect = students.stream()
? ? ? ? ? ? ? ? .filter(student -> student.getAge() < 20)
? ? ? ? ? ? ? ? .filter(student -> student.getScore() > 90.0)
? ? ? ? ? ? ? ? .limit(3)
? ? ? ? ? ? ? ? .collect(Collectors.toList());
? ? ? ? ?collect.forEach(System.out::println);
? ? ? ? ?/**
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=98.0)
? ? ? ? ? * Student(name=學生A, school=大學1, age=18, score=91.0)
? ? ? ? ? * Student(name=學生B, school=大學1, age=18, score=91.0)
? ? ? ? ? */
? ? }二、映射 map
這個map的映射其實不光Java 有，JavaScript 也是有的，用法我感覺是一樣的~
一個非常常見的數(shù)據(jù)處理套路就是從某些對象中選擇信息。比如在SQL里，你可以從表中選 擇一列。
用我個人的話來說，filter 是用來過濾元素的，而這一小節(jié)的 map 是用來創(chuàng)建一個新的元素。（在官方中的使用的映射一詞，是因為map 會接受一個函數(shù)作為參數(shù)，并且將其映射成一個新的元素。）
可能說起來還是不如實踐來的實在。
數(shù)據(jù)還是上一節(jié)造的那些數(shù)據(jù)。
如：找出集合中所有學生的姓名，去除掉重復的名稱，組成一個 List 集合
?/**
? ? ? * 找出集合中所有學生的姓名，去除掉重復的名稱，組成一個 List<String> 集合
? ? ? *
? ? ? * @param students
? ? ? */
?private static void selectAllStudentName(List<Student> students) {
??
? ? ?List<String> collect = students.stream().map(new Function<Student, String>() {
? ? ? ? ?@Override
? ? ? ? ?public String apply(Student student) {
? ? ? ? ? ? ?return student.getName();
? ? ? ? }
? ? }).distinct().collect(Collectors.toList());
??
? ? ?List<String> list = students.stream().map(student -> {
? ? ? ? ?return student.getName();
? ? }).distinct().collect(Collectors.toList());
??
? ? ?List<String> collect1 = students.stream()
? ? ? ? .map(student -> student.getName())
? ? ? ? .distinct()
? ? ? ? .collect(Collectors.toList());
? ? ?collect1.forEach(System.out::println);
??
? ? ?/**
? ? ? ? ? * 學生A
? ? ? ? ? * 學生B
? ? ? ? ? * 學生C
? ? ? ? ? * 學生D
? ? ? ? ? * 學生E
? ? ? ? ? * 學生F
? ? ? ? ? * 學生G
? ? ? ? ? * 學生H
? ? ? ? ? * 學生I
? ? ? ? ? * 學生J
? ? ? ? ? */
?}三、查找和匹配
3.1、匹配 anyMatch、allMatch和noneMatch 方法
anyMatch方法可以回答“流中是否有一個元素能匹配給定的謂詞”
這里的謂詞也就是filter那部分所說的一個 布爾值函數(shù)。
其實看到 any 的第一眼，大家也明白，任一，只有集合中含有你需要的，那就是返回 true。
? ? ?/**
? ? ? * 判斷這群學生中有木有年齡大于20歲的學生
? ? ? *
? ? ? * @param students
? ? ? */
? ? ?private static void anyMatchDemo(List<Student> students) {
? ? ? ? ?boolean anyMatch = students.stream().anyMatch(student -> student.getAge() > 20);
? ? ? ? ?System.out.println(anyMatch);
? ? ? ? ?/**
? ? ? ? ? * true
? ? ? ? ? */
? ? }還有 allMatch 和 noneMatch 他們都和 anyMatch 類似。
allMatch 要求全部元素都滿足要求，
noneMatch 則是要求全部元素都不滿足要求時返回true。
3.2、查找 findAny 與 findFirst
findAny 方法將返回當前流中的任意元素。
它的搭檔一般是 filter，和 filter 使用可以實現(xiàn)很多操作。
如我想要當確定這群學生中有20歲以上的學生時立馬返回結(jié)果。
?/**
? ? ? * 當確定這群學生中有20歲以上的學生時即返回。
? ? ? *
? ? ? * @param students
? ? ? */
?private static void findAnyDemo(List<Student> students) {
? ? ?Optional<Student> student1 = students.stream().filter(student -> student.getAge() > 20).findAny();
? ? ?Student student = student1.get();
? ? ?System.out.println(student);
? ? ?/**
? ? ? ? ? * Student(name=學生E, school=大學2, age=21, score=78.0)
? ? ? ? ? */
?}這里的 Optional 是 Java 8 新增的一個 容器類，作用就是用來判斷存在和不存在。也就是大家常談到的更優(yōu)雅的判空操作。
Optional 幾個常見的Api
isPresent()將在Optional包含值的時候返回true, 否則返回falseifPresent(Consumer<T> block)會在值存在的時候執(zhí)行給定的代碼塊。T get()會在值存在時返回值，否則拋出一個NoSuchElement異常。T orElse(T other)會在值存在時返回值，否則返回一個默認值。
詳細的用法，大家也可以去了解了解，這也是非常好用的一個東東。
findFirst 其實就是確定返回第一個元素。它也和 filter 一起搭配使用。
咋一看， findany 和 findFirst 不是一樣嗎，其實在你對于返回的第一個元素沒有明確要求時，你可以理解成他們確實就是一樣的。
但其實他們真實區(qū)別并非體現(xiàn)如此，而是在 stream 中的并行流中。
今天沒談這個，大家可以去了解了解，了解并行流就會和常常聊到的性能相關(guān)啦，到底那種好一些啥的~
3.3、小結(jié)
anyMatch、allMatch和noneMatch這三個操作都用到了我們所謂的短路。
就是我們剛學語法時的 && 和 || 運算符，這也算是他們在 stream 的實現(xiàn)。
最簡單的理解方式，就是他們通過遍歷，組成了一個很長很長的布爾表達式。
除去他們能實現(xiàn)短路操作， findAny 與 findFirst 也是同樣如此，并非都需要遍歷結(jié)束才會得到最終的結(jié)果。只要在其中某一次中達成條件，即可返回結(jié)果。
四、歸約
官方的說法，成為歸約，如果用簡單的話語來說的話，可以理解為將多個東西歸為一堆。
4.1、元素求和 reduce
? ? ?private static void reduceDemo() {
? ? ? ? ?List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
??
? ? ? ? ?Integer reduce = list.stream().reduce(0, (a, b) -> a + b);
? ? ? ? ?System.out.println("list集合的總和：==>" + reduce);
??
? ? ? ? ?Integer reduce1 = list.stream().reduce(1, (a, b) -> a * b);
? ? ? ? ?System.out.println("list集合中的元素相乘結(jié)果==>" + reduce1);
??
? ? ? ? ?Optional<Integer> reduce2 = list.stream().reduce((a, b) -> a + b);
? ? ? ? ?Integer integer = reduce2.get();
? ? ? ? ?System.out.println("list 集合的總和==>"+integer);
? ? ? ? ?/**
? ? ? ? ? * list集合的總和：==>55
? ? ? ? ? * list集合中的元素相乘結(jié)果==>3628800
? ? ? ? ? * list 集合的總和==>55
? ? ? ? ? */
? ? }
reduce接受兩個參數(shù)：
一個初始值，這里是0；
一個 BinaryOperator 來將兩個元素結(jié)合起來產(chǎn)生一個新值，BinaryOperator 也是funcational 接口，所以也可以使用lambda 表達式 lambda (a, b) -> a + b 來表示。
?Integer reduce = list.stream().reduce(0, (a, b) -> a + b);
另外還有一個重載函數(shù)，就是沒有初始值版本的，它的返回值是Optional<Integer> 的容器類。
? ?Optional<Integer> reduce2 = list.stream().reduce((a, b) -> a + b);
最大值與最小值：
?private static void reduceDemo2(){
? ? ?List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
? ? ?Optional<Integer> max = list.stream().reduce(Integer::max);
? ? ?Optional<Integer> min = list.stream().reduce(Integer::min);
? ? ?System.out.println("max==>"+max.get());
? ? ?System.out.println("min==>"+min.get());
? ? ?/**
? ? ? ? ? * max==>10
? ? ? ? ? * min==>1
? ? ? ? ? */
?}后記
到此這篇關(guān)于Java 中如何使用 stream 流的文章就介紹到這了,更多相關(guān)Java stream 流內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了java開發(fā)中遇到的異常匯總詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-07-07
Spring Boot 2.4.x引入了新的配置導入方式,通過spring.config.import屬性可以靈活地導入多種類型的配置文件,本文就來介紹一下,感興趣的可以了解一下2024-11-11
這篇文章主要介紹了Spring Boot的Controller控制層和頁面,需要的朋友可以參考下2017-04-04
這篇文章主要介紹了淺談Spring Boot 屬性配置和自定義屬性配置,小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-03-03
SpringBoot整合Druid數(shù)據(jù)源過程詳解
這篇文章主要介紹了SpringBoot整合Druid數(shù)據(jù)源過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了java 中迭代器的使用方法詳解的相關(guān)資料,希望通過本文能幫助到大家，需要的朋友可以參考下2017-09-09
java serialVersionUID解決序列化類版本不一致問題面試精講
這篇文章主要為大家介紹了serialVersionUID解決序列化類版本不一致問題的面試精講,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10
詳解Java的Hibernate框架中的set映射集與SortedSet映射
這篇文章主要介紹了詳解Java的Hibernate框架中的set映射集與SortedSet映射,Hibernate是Java的SSH三大web開發(fā)框架之一,需要的朋友可以參考下2015-12-12
這篇文章主要為大家介紹了Autowired的注入過程源碼解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-09-09
這篇文章主要介紹了java獲取一個文本文件的編碼(格式)信息，文章圍繞主題展開詳細的內(nèi)容介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-09-09