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流的介绍能对大家有所帮助,欢迎大佬们留言或私信与我交流~~学海漫浩浩,我亦苦作舟!大家一起学习,一起进步!


相关文章
|
16天前
|
前端开发 JavaScript Java
java常用数据判空、比较和类型转换
本文介绍了Java开发中常见的数据处理技巧,包括数据判空、数据比较和类型转换。详细讲解了字符串、Integer、对象、List、Map、Set及数组的判空方法,推荐使用工具类如StringUtils、Objects等。同时,讨论了基本数据类型与引用数据类型的比较方法,以及自动类型转换和强制类型转换的规则。最后,提供了数值类型与字符串互相转换的具体示例。
|
9天前
|
存储 缓存 安全
Java 集合江湖:底层数据结构的大揭秘!
小米是一位热爱技术分享的程序员,本文详细解析了Java面试中常见的List、Set、Map的区别。不仅介绍了它们的基本特性和实现类,还深入探讨了各自的使用场景和面试技巧,帮助读者更好地理解和应对相关问题。
30 5
|
22天前
|
存储 缓存 安全
Java 集合框架优化:从基础到高级应用
《Java集合框架优化:从基础到高级应用》深入解析Java集合框架的核心原理与优化技巧,涵盖列表、集合、映射等常用数据结构,结合实际案例,指导开发者高效使用和优化Java集合。
33 4
|
23天前
|
JSON Java 程序员
Java|如何用一个统一结构接收成员名称不固定的数据
本文介绍了一种 Java 中如何用一个统一结构接收成员名称不固定的数据的方法。
25 3
|
1月前
|
Java 程序员 容器
Java中的变量和常量:数据的‘小盒子’和‘铁盒子’有啥不一样?
在Java中,变量是一个可以随时改变的数据容器,类似于一个可以反复打开的小盒子。定义变量时需指定数据类型和名称。例如:`int age = 25;` 表示定义一个整数类型的变量 `age`,初始值为25。 常量则是不可改变的数据容器,类似于一个锁死的铁盒子,定义时使用 `final` 关键字。例如:`final int MAX_SPEED = 120;` 表示定义一个名为 `MAX_SPEED` 的常量,值为120,且不能修改。 变量和常量的主要区别在于变量的数据可以随时修改,而常量的数据一旦确定就不能改变。常量主要用于防止意外修改、提高代码可读性和便于维护。
|
1月前
|
存储 缓存 安全
在 Java 编程中,创建临时文件用于存储临时数据或进行临时操作非常常见
在 Java 编程中,创建临时文件用于存储临时数据或进行临时操作非常常见。本文介绍了使用 `File.createTempFile` 方法和自定义创建临时文件的两种方式,详细探讨了它们的使用场景和注意事项,包括数据缓存、文件上传下载和日志记录等。强调了清理临时文件、确保文件名唯一性和合理设置文件权限的重要性。
71 2
|
1月前
|
Java
Java 8 引入的 Streams 功能强大,提供了一种简洁高效的处理数据集合的方式
Java 8 引入的 Streams 功能强大,提供了一种简洁高效的处理数据集合的方式。本文介绍了 Streams 的基本概念和使用方法,包括创建 Streams、中间操作和终端操作,并通过多个案例详细解析了过滤、映射、归并、排序、分组和并行处理等操作,帮助读者更好地理解和掌握这一重要特性。
30 2
|
1月前
|
存储 Java
判断一个元素是否在 Java 中的 Set 集合中
【10月更文挑战第30天】使用`contains()`方法可以方便快捷地判断一个元素是否在Java中的`Set`集合中,但对于自定义对象,需要注意重写`equals()`方法以确保正确的判断结果,同时根据具体的性能需求选择合适的`Set`实现类。
|
1月前
|
安全 Java
Java多线程集合类
本文介绍了Java中线程安全的问题及解决方案。通过示例代码展示了使用`CopyOnWriteArrayList`、`CopyOnWriteArraySet`和`ConcurrentHashMap`来解决多线程环境下集合操作的线程安全问题。这些类通过不同的机制确保了线程安全,提高了并发性能。
|
1月前
|
存储 Java 开发者
在 Java 中,如何遍历一个 Set 集合?
【10月更文挑战第30天】开发者可以根据具体的需求和代码风格选择合适的遍历方式。增强for循环简洁直观,适用于大多数简单的遍历场景;迭代器则更加灵活,可在遍历过程中进行更多复杂的操作;而Lambda表达式和`forEach`方法则提供了一种更简洁的函数式编程风格的遍历方式。
下一篇
DataWorks