Java8Stream(高效处理集合数据)

简介: Java8Stream(高效处理集合数据)

🔖什么是Stream?


▐ 概述

•  这里的Stream流与之前JavaSE中的IO流是完全不同的两个概念,不要混淆!

•  IO流是:输入输出文件内容

•  java8stream是:处理数据集合,遍历数据集的高级迭代器,可以对数组、集合类进行各种操作.


•  Stream处理数据大体过程:


   数组/集合类 ----> 流 ----> 各种操作 ( 如过滤、排序 ) ----> 最终结果 ( 数组/集合类 )    


🔖获取流


▐ 获取Stream流方式常用的有三种:

•  使用Collection接口下的stream()  对应集合

•  使用Arrays中的stream()方法,将数组转成流   对应数组

•  使用Stream中的静态方法:of()

⌨️代码演示

1.  使用Collection接口下的stream()

        ArrayList<Integer> list = new ArrayList();
        list.add(1);
        list.add(2);
        list.add(3);
        Stream<Integer> stream = list.stream();

2.  使用Arrays中的stream()方法,将数组转成流

        Integer[] array =new Integer[]{1,2,3,4,5};
        Stream<Integer> stream = Arrays.stream(array);

3.  使用Stream中的静态方法:of()

Stream<Integer> stream1 = Stream.of(1, 2, 3, 4);

🔖流操作

•  流操作分为中间操作和终端操作

•  对某一数据处理的过程为:数据源 ---> 中间操纵 ---> 终端操作 ---> 结果

🏷️中间操作

常用操作有:

 filter :      过滤流中的某些元素

        Integer[] array =new Integer[]{1,2,3,4,5,2,4};
        List<Integer> list=Arrays.stream(array)//获取流
                .filter((e)->{                 //中间操作(过滤)
                    return e>3;                //过滤条件
                })
                .collect(Collectors.toList()); //终端操作(返回一个集合)
        System.out.println(list);              //输出结果:[4, 5, 4]

 sorted  排序(流中元素需要实现Comparable接口)

        Integer[] array =new Integer[]{1,2,3,4,5,2,4};
        List<Integer> list=Arrays.stream(array)//获取流
                .sorted((o1,o2)->{             //中间操作(排序)
                    return o2-o1;              //逆序
                })
                .collect(Collectors.toList()); //终端操作(返回一个集合)
        System.out.println(list);              //输出结果:[5, 4, 4, 3, 2, 2, 1]

•  distinct去掉重复元素

        Integer[] array =new Integer[]{1,2,3,4,5,2,4};
        List<Integer> list=Arrays.stream(array)//获取流
                .distinct()                    //中间操作(去掉重复元素)
                .collect(Collectors.toList()); //终端操作(返回一个集合)
        System.out.println(list);              //输出结果:[1, 2, 3, 4, 5]

limit(n) 获取n个元素

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list = Arrays.stream(array)//获取流
                .limit(4)                       //中间操作(获取n个元素)
                .collect(Collectors.toList());  //终端操作(返回一个集合)
        System.out.println(list);               //输出结果:[1, 2, 3, 4]

•  skip(n) 跳过n个元素,配合limit(n)可以实现分页

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list = Arrays.stream(array)//获取流
                .skip(3)                        //中间操作(跳过n个元素)
                .limit(4)                       //中间操作(获取n个元素)
                .collect(Collectors.toList());  //终端操作(返回一个集合)
        System.out.println(list);               //输出结果:[4, 5, 2, 4]

•  map() :  将其映射成一个新的元素

▐ 可以对数据进行多次中间操作

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list = Arrays.stream(array)//获取流
                .distinct()                      //中间操作(去掉重复元素) 12345
                .sorted((o1,o2)->{
                    return o2-o1;
                })                               //中间操作(排序,逆序)   54321
                .limit(3)                        //中间操作(获取3个元素)  543
                .collect(Collectors.toList());   //终端操作(返回一个集合)
        System.out.println(list);                //输出结果:[5, 4, 3]

🏷️终端操作


•  终端操作通常返回的是我们需要的结果(如数组、集合、单值)

常用操作有:

▐ 代码详细演示:

 forEach:遍历流中的元素

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        Arrays.stream(array)
                .forEach((e) -> {
                    System.out.print(e);//遍历:1234524
                });

•  collect:     将流中的元素倒入一个集合, Collection或Map

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        List<Integer> list =Arrays.stream(array)
                .distinct()
                .collect(Collectors.toList());//将处理后的流元素重新导入一个集合中
        System.out.println(list);//[1, 2, 3, 4, 5]

   Min:     返回流中元素最小值

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        Integer min=Arrays.stream(array)
                .distinct()
                .max((o1,o2)->{
                    return o2-o1; //o2-o1返回min  o1-o2返回max
                })
                .get();           //.get不能忘
        System.out.println(min);     //结果输出:1

                                                                                                                   ( .get 不要忘记哦!)


•    Max        返回流中元素最大值


//模仿上述求最小值,只需将o2-o1改为o1-o2即可

•   count:     返回流中元素的总个数

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        long count=Arrays.stream(array)
                .distinct()   //中间操作(去重) 12345
                .count();     //终端操作(流中元素个数)
        System.out.println(count);//结果输出:5

                                                                                                        ( 返回值是long )


•  Reduce:   所有元素求和

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        Integer sum=Arrays.stream(array)
                .distinct()
                .reduce((o1,o2)->{
                    return o1+o2;
                })                   //去重后求和 1+2+3+4+5
                .get();
        System.out.println(sum);     //结果输出:15

                                                                                                               ( .get 不要忘记哦!)  


 anyMatch:接收一个Predicate函数,只要流中有一个元素满足条件则返回true,否则返回false

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        boolean anyMatch=Arrays.stream(array)
                .anyMatch((e)->{
                    return e>4;   //流中只要有一个元素满足条件就返回true
                });
        System.out.println(anyMatch); //结果输出:true

allMatch:  接收一个Predicate函数,当流中每个元素都符合条件时才返回true,否则返回false

       Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
        boolean allMatch=Arrays.stream(array)
                .allMatch((e)->{
                    return e>1;   //流中所有元素满足条件才返回true
                });
        System.out.println(allMatch); //结果输出:false

findFirst:  返回流中第一个元素

        Integer[] array = new Integer[]{6, 2, 3, 4, 5, 2, 4};
        Integer first=Arrays.stream(array)
                .findFirst()
                .get();
        System.out.println(first); //结果输出:6

 toArray: 将流中的元素倒入一个数组

        Integer[] array = new Integer[]{1, 2, 3, 4, 5, 2, 4};
         Object[] a=Arrays.stream(array)
                .distinct()
                .toArray();     //将处理后的流元素重新导入一个数组中
        System.out.println(Arrays.toString(a));//[1, 2, 3, 4, 5]

▐ 结语:

      希望这篇关于java8中Stream流的介绍能对大家有所帮助,欢迎大佬们留言或私信与我交流~~学海漫浩浩,我亦苦作舟!大家一起学习,一起进步!


相关文章
|
19天前
|
安全 Java API
【Java面试题汇总】Java基础篇——String+集合+泛型+IO+异常+反射(2023版)
String常量池、String、StringBuffer、Stringbuilder有什么区别、List与Set的区别、ArrayList和LinkedList的区别、HashMap底层原理、ConcurrentHashMap、HashMap和Hashtable的区别、泛型擦除、ABA问题、IO多路复用、BIO、NIO、O、异常处理机制、反射
【Java面试题汇总】Java基础篇——String+集合+泛型+IO+异常+反射(2023版)
|
6天前
|
安全 Java 开发者
Java修饰符与封装:理解访问权限、行为控制与数据隐藏的重要性
Java中的修饰符和封装概念是构建健壯、易维护和扩展的Java应用程序的基石。通过合理利用访问权限修饰符和非访问修饰符,开发者能够设计出更加安全、灵活且高效的代码结构。封装不仅是面向对象编程的核心原则之一,也是提高软件项目质量和可维护性的关键策略。
10 1
|
8天前
|
存储 安全 Java
Java 常用集合分类
Java 常用集合分类
13 2
|
2月前
|
Java
用JAVA架建List集合为树形结构的代码方法
这段代码定义了一个表示树形结构的 `Node` 类和一个用于构建树形结构的 `TreeController`。`Node` 类包含基本属性如 `id`、`pid`、`name` 和 `type`,以及子节点列表 `children`。`TreeController` 包含初始化节点列表并将其转换为树形结构的方法。通过过滤和分组操作实现树形结构的构建。详情可见:[代码示例链接1](http://www.zidongmutanji.com/zsjx/43551.html),[代码效果参考链接2](https://www.257342.com/sitemap/post.html)。
31 5
|
1月前
|
Java API 开发者
代码小妙招:用Java轻松获取List交集数据
在Java中获取两个 `List`的交集可以通过 `retainAll`方法和Java 8引入的流操作来实现。使用 `retainAll`方法更为直接,但会修改原始 `List`的内容。而使用流则提供了不修改原始 `List`、更为灵活的处理方式。开发者可以根据具体的需求和场景,选择最适合的方法来实现。了解和掌握这些方法,能够帮助开发者在实际开发中更高效地处理集合相关的问题。
28 1
|
2月前
|
存储 Java 程序员
Java中的集合框架:从入门到精通
【8月更文挑战第30天】在Java的世界里,集合框架是一块基石,它不仅承载着数据的存储和操作,还体现了面向对象编程的精髓。本篇文章将带你遨游Java集合框架的海洋,从基础概念到高级应用,一步步揭示它的奥秘。你将学会如何选择合适的集合类型,掌握集合的遍历技巧,以及理解集合框架背后的设计哲学。让我们一起探索这个强大工具,解锁数据结构的新视角。
|
2月前
|
存储 算法 Java
Java中的集合框架深度解析云上守护:云计算与网络安全的协同进化
【8月更文挑战第29天】在Java的世界中,集合框架是数据结构的代言人。它不仅让数据存储变得优雅而高效,还为程序员提供了一套丰富的工具箱。本文将带你深入理解集合框架的设计哲学,探索其背后的原理,并分享一些实用的使用技巧。无论你是初学者还是资深开发者,这篇文章都将为你打开一扇通往高效编程的大门。
|
2月前
|
监控 Java 开发工具
【事件中心 Azure Event Hub】Event Hub Java SDK的消费端出现不消费某一个分区中数据的情况,出现IdleTimerExpired错误消息记录
【事件中心 Azure Event Hub】Event Hub Java SDK的消费端出现不消费某一个分区中数据的情况,出现IdleTimerExpired错误消息记录
|
2月前
|
存储 Java Apache
|
2月前
|
开发者 Java Spring
【绝技揭秘】掌握Vaadin数据绑定:一键同步Java对象,告别手动数据烦恼,轻松玩转Web应用开发!
【8月更文挑战第31天】Vaadin不仅是一个功能丰富的Java Web应用框架,还提供了强大的数据绑定机制,使开发者能轻松连接UI组件与后端Java对象,简化Web应用开发流程。本文通过创建一个简单的用户信息表单示例,详细介绍了如何使用Vaadin的`Binder`类实现数据绑定,包括字段与模型属性的双向绑定及数据验证。通过这个示例,开发者可以更专注于业务逻辑而非繁琐的数据同步工作,提高开发效率和应用可维护性。
51 0
下一篇
无影云桌面