当前位置：首页 > article >正文

Stream流的思想和获取Stream流

article 2024/9/20 5:34:25

首先介绍流的概念：

流可以理解为一条流水线，在这条流水线中有许多操作，比如筛选所需要的数据，输出打印等，

经过这条流水线，可以获取到自己所需要的数据：

-->所以：

Stream流的作用：

结合了Lambda表达式，可以简化集合以及数组的操作；

Stream流的使用步骤：
1. 先得到一条Stream流(流水线)，并把数据放上去
2. 利用Stream流中的中间API即中间方法（如数据过滤，类型转换）对流水线上的数据进行操作
3. 利用Stream流中的终结API即终结方法（如数据统计，数据打印）对流水线上的数据进行操作
  
  中间方法：该方法调用完毕后，还可以调用其他方法；
  
  终结方法：最后一步，该方法调用完毕之后，不能再调用其他方法。

一.先得到一条Stream流(流水线)，并把数据放上去：

1.获取Stream流的方法：

注：1)双列集合无法直接使用stream流，必须先用keySet方法(获取所有的键)或entrySet方法(获取到所有键值对对象的单

列集合)将其转换为单列集合，才能使用stream流

2)一堆零散数据必须是同种数据类型。

3)类Arrays里的stream方法：在类Arrays里,stream方法为静态的，可以直接类名.方法名进行调用：

4）一堆零散的数据获取stream流要用到接口Stream中的静态方法of(可以直接类名.方法名进行调用)，该方法的形参

属于可变参数(可变参数底层就是一个数组)，of方法返回Stream流。

2.获取Stream流的方法演示：

a.单列集合获取stream流：

获取stream流方法一：

package com.itheima.a01mystream;

import java.util.ArrayList;
import java.util.Collections;
import java.util.function.Consumer;
import java.util.stream.Stream;

public class StreamDemo2 {
    public static void main(String[] args) {
        //1.创建集合
        ArrayList<String> list=new ArrayList<>();

        //2.利用集合的工具类（Collections）添加数据
        Collections.addAll(list,"a","b","c","d","e");

        //3.获取stream流：要用到Collection这个接口中的默认方法stream
        /* ArrayList集合是Collection这个接口的实现类，所以可以直接调用默认方法stream */
        //获取到一条流水线，并把集合中的数据放到流水线上
        Stream<String> stream1 = list.stream();

        //4.使用终结方法打印一下流水线上的所有数据（用到了匿名内部类）
        stream1.forEach(new Consumer<String>() {
            @Override
            public void accept(String s) {
                //s:依次表示流水线上的每一个数据
                System.out.println(s);
            }
        });
    }
}

获取stream流方法二：

package com.itheima.a01mystream;

import java.util.ArrayList;
import java.util.Collections;

public class StreamDemo2 {
    public static void main(String[] args) {
        //1.创建集合
        ArrayList<String> list=new ArrayList<>();

        //2.利用集合的工具类（Collections）添加数据
        Collections.addAll(list,"a","b","c","d","e");

        //3.利用链式编程，forEach方法和Lambda表达式进行遍历
        list.stream().forEach(s -> System.out.println(s));
                            //s:依次表示流水线上的每一个数据
    }
}

代码解读：

stream方法：

forEach方法(可用于遍历)：该方法的形参是函数式接口，因此可以写成匿名内部类，再改写为Lambda表达式

b.双列集合无法直接使用stream流，需要先用keySet方法(获取所有的键)或entrySet方法(获取到所有键值对对象的单列集合)将其转换为单列集合，才能使用stream流：

获取stream流方法一：

package com.itheima.a01mystream;

import java.util.HashMap;

public class StreamDemo3 {
    public static void main(String[] args) {
        //1.创建双列集合
        HashMap<String,Integer> hm=new HashMap<>();

        //2.添加数据
        hm.put("aaa",111);
        hm.put("bbb",222);
        hm.put("ccc",333);
        hm.put("ddd",444);

        //3.获取stream流
        /* hm.keySet()获取到了所有的键，是一个单列集合(Set集合)；
           hm.keySet().stream()代表把所有的键放到了stream流这个流水线上
          */
        hm.keySet().stream().forEach(s -> System.out.println(s));
    }
}

获取stream流方法二：

package com.itheima.a01mystream;

import java.util.HashMap;

public class StreamDemo3 {
    public static void main(String[] args) {
        //1.创建双列集合
        HashMap<String,Integer> hm=new HashMap<>();

        //2.添加数据
        hm.put("aaa",111);
        hm.put("bbb",222);
        hm.put("ccc",333);
        hm.put("ddd",444);

        //3.第二种获取stream流
        hm.entrySet().forEach(s-> System.out.println(s));
                            //s依次表示键值对对象
    }
}

运行结果：

问题：添加数据的顺序和输出数据的顺序不一样，这是为什么？

因为HashMap集合底层是哈希表，它不能保证存和取的顺序一致，因此只要数据没错即可，顺序无所谓。

c.数组获取stream流：

存基本数据类型的数组获取stream流：

package com.itheima.a01mystream;

import java.util.Arrays;

public class StreamDemo4 {
    public static void main(String[] args) {
        //1.创建数组
        int[] arr={1,2,3,4,5,6,7,8,9,10};

        //2.获取stream流
        Arrays.stream(arr).forEach(s-> System.out.println(s));
    }
}

存引用数据类型的数组获取stream流：

package com.itheima.a01mystream;

import java.util.Arrays;

public class StreamDemo4 {
    public static void main(String[] args) {
        //1.创建数组
        String[] arr={"a","b","c"};

        //2.获取stream流
        Arrays.stream(arr).forEach(s-> System.out.println(s));
    }
}

代码解读：

1. 类Arrays里的stream方法：在类Arrays里,stream方法为静态的，可以直接类名.方法名进行调用

2.类Arrays里重载了许多stream方法：

当数组存引用数据类型时，会用上述图片中第一个stream方法来获取stream流。

d.一堆零散的数据获取stream流：这堆零散的数据必须是同种类型

方法of的形参是基本数据类型时：

package com.itheima.a01mystream;

import java.util.stream.Stream;

public class StreamDemo5 {
    public static void main(String[] args) {
        Stream.of(1,2,3,4,5).forEach(s-> System.out.println(s));
    }
}

方法of的形参是引用数据类型时：

package com.itheima.a01mystream;

import java.util.stream.Stream;

public class StreamDemo5 {
    public static void main(String[] args) {
        Stream.of("a","aa","aaa").forEach(s-> System.out.println(s));
    }
}

二.注意事项：

用接口Stream中的静态方法of获取stream流除了一堆零散的数据外可用，比如数组也是可以的，因为of方法的形参

属于可变参数(可变参数底层就是一个数组)，例如：

package a41practice;

import java.util.stream.Stream;

public class Test {
    public static void main(String[] args) {
        //1.创建数组
        String[] arr2={"a","b","c"};

        //2.获取stream流
        Stream.of(arr2).forEach(s-> System.out.print(s+" "));
        /* 运行结果为a b c */
    }
}

但上述的方式是错误的，因为数组存的不仅仅有引用数据类型，还有基本数据类型，如下：

package a41practice;

import java.util.stream.Stream;

public class Test {
    public static void main(String[] args) {
        //1.创建数组
        int[] arr1={1,2,3,4,5,6,7,8,9,10};

        //2.获取stream流
        Stream.of(arr1).forEach(s-> System.out.print(s+" "));
        /* 运行结果为[I@7291c18f */
    }
}

此时无法做到遍历数据，打印出了地址值。