文章目录

  • 一、Stream流概述
  • 二、获取Stream流
    • 2.1 集合获取 Stream 流
    • 2.2 数组获取 Stream 流
  • 三、中间方法
  • 四、终结方法
  • 五、Stream流的综合应用
  • 六、收集Stream流

一、Stream流概述

在 Java8 中，得益于 Lambda 所带来的函数式编程， 引入了一个全新的 Stream 流概念。

目的：用于简化集合和数组操作的API。

Stream 流思想：先得到集合或者数组的 Stream 流（就是一根传送带）；把元素放上去；然后就用这个 Stream 流简化的 API 来方便的操作元素。

Stream 流的三类方法

① 获取 Stream 流：创建一条流水线，并把数据放到流水线上准备进行操作。
② 中间方法：流水线上的操作，一次操作完毕之后，还可以继续进行其他操作。
③ 终结方法：一个Stream流只能有一个终结方法，是流水线上的最后一个操作。

二、获取Stream流

Stream 操作集合或者数组的第一步是先得到 Stream 流，然后才能使用流的功能。

2.1 集合获取 Stream 流

Collection 系列集合：默认方法 stream​() 生成流。

Collection<String> list = new ArrayList<>();Stream<String> s1 = list.stream();

Map 系列集合使用 stream() 方法获取键流、值流、键值对的流。

Map<String, Integer> map = new HashMap<>();// 键流Stream<String> s2 = map.keySet().stream();// 值流Stream<Integer> s3 = map.values().stream();// 键值对Stream<Map.Entry<String, Integer>> s4 = map.entrySet().stream();

2.2 数组获取 Stream 流

String[] strs = {"张三丰", "灭绝师太", "东方不败"};Stream<String> s5 = Arrays.stream(strs);Stream<String> s6 = Stream.of(strs);

三、中间方法

Stream 流的中间方法，即中间操作方法，也称为非终结方法。常用的 API 如下：

注意：调用完成后返回新的 Stream 流可以继续使用，支持链式编程；在 Stream 流中无法直接修改集合、数组中的数据。

四、终结方法

Stream 流的终结方法，即终结操作方法。常用的 API 如下：在这里插入代码片

注意：终结操作方法，调用完成后流就无法继续使用了，原因是不会返回 Stream 流。

五、Stream流的综合应用

案例1：从集合中找到姓张，且名称长度是3的姓名。

public class StreamDemo1 {public static void main(String[] args) {ArrayList<String> names = new ArrayList<>();Collections.addAll(names, "张三丰", "张无忌", "张三", "李四", "李明", "张强"); // 从集合中找到姓张，且名称长度是3的姓名。names.stream().filter(new Predicate<String>() {@Overridepublic boolean test(String s) {return s.startsWith("张");}}).filter(new Predicate<String>() {@Overridepublic boolean test(String s) {return s.length()==3;}}).forEach(new Consumer<String>() {@Overridepublic void accept(String s) {System.out.println(s);}});// Lambda 化简names.stream().filter(s -> s.startsWith("张")).filter(s -> s.length()==3).forEach(s-> System.out.println(s));names.stream().filter(s -> s.startsWith("张")&&s.length()==3).forEach(System.out::println);}}

案例2：测试 map 加工方法

public class StreamDemo2 {public static void main(String[] args) {List<String> list = new ArrayList<>();Collections.addAll(list, "张三丰", "张无忌", "张三", "李四", "李明", "张强");// map加工方法// new Function() 第一个参数原材料,第二个参数是加工后的结果。// 1. 需求1：给集合元素的前面都加上一个：黑马的：list.stream().map(new Function<String, String>() {@Overridepublic String apply(String s) { // 形参类型是第一个参数，方法返回类型是第二个参数return "黑马的" + s;}});// Lambda 化简list.stream().map(s -> "黑马的" + s).forEach(System.out::println);// 2. 需求2：把所有的名称 都加工成一个学生对象。list.stream().map(new Function<String, Student>() {@Overridepublic Student apply(String s) {return new Student(s);}});list.stream().map(s -> new Student(s)).forEach(System.out::println);list.stream().map(Student::new).forEach(System.out::println); // 构造器引用，方法引用}}

案例3：测试合并流

public class StreamDemo3 {public static void main(String[] args) {List<String> list = new ArrayList<>();Collections.addAll(list, "张三丰", "张无忌", "张三", "李四", "李明", "张强");// 合并流Stream<String> s1 = list.stream().filter(s -> s.startsWith("张"));Stream<String> s2 = Stream.of("java1", "java2");// public static  Stream concat(StreamStream<String> s3 = Stream.concat(s1, s2);//s3.forEach(System.out::println);s3.distinct().forEach(System.out::println); // 去重后输出// distinct 依赖 hasCode 和 equals 方法ArrayList<Student> students = new ArrayList<>();Collections.addAll(students, new Student("张无忌"), new Student("张无忌"), new Student("张三丰"), new Student("张三丰"), new Student("李有田"));students.stream().distinct().forEach(System.out::println); // Student{name='张无忌'}, Student{name='张三丰'}Student{name='李有田'}}}

六、收集Stream流

收集 Stream 流，就是把 Stream 流操作后的结果数据转回到集合或者数组中去。

Stream流只是方便操作集合/数组的手段，得到集合/数组才是开发中的目的。

Stream 流的收集方法：

Collectors 工具类提供了具体的收集方式：

public class StreamDemo5 {public static void main(String[] args) {List<String> list = new ArrayList<>();Collections.addAll(list, "张无忌", "周芷若", "赵敏", "张强", "张三丰", "张三丰");Stream<String> s1 = list.stream().filter(s -> s.startsWith("张"));List<String> zhangList = s1.collect(Collectors.toList());//List zhangList = s1.toList(); // jdk16新添加方法 这种写法，返回不可变集合zhangList.add("新添加的元素"); //如果添加元素 s1.toList()，方法会报错System.out.println(zhangList); // [张无忌, 张强, 张三丰, 张三丰, 新添加的元素]// 注意：流只能使用一次，若要重新使用流，需要重新定义Stream<String> s2 = list.stream().filter(s -> s.startsWith("张"));Set<String> zhangSet = s2.collect(Collectors.toSet()); // 收集成SetSystem.out.println(zhangSet); // [张强, 张三丰, 张无忌]Stream<String> s3 = list.stream().filter(s -> s.startsWith("张"));Object[] arrs = s3.toArray();// 收集成数组System.out.println(Arrays.toString(arrs)); // [张无忌, 张强, 张三丰, 张三丰]// 拓展：收集成指定流，如 String 流Stream<String> s4 = list.stream().filter(s -> s.startsWith("张"));String[] array = s4.toArray(new IntFunction<String[]>() {@Overridepublic String[] apply(int value) {return new String[value];}});// 收集成数组// String[] array = s4.toArray( value -> new String[value] );// String[] array = s4.toArray(String[]::new);System.out.println(Arrays.toString(array)); // [张无忌, 张强, 张三丰, 张三丰]}}

文章参考：Java入门基础视频教程，java零基础自学就选黑马程序员Java入门教程（含Java项目和Java真题）