介绍

"Stream流"通常指的是数据流（Data Stream），在计算机科学中是指一系列连续的数据元素，以流的形式传输。数据流可以是输入数据流（Input Stream）或输出数据流（Output Stream），常见的应用包括网络数据传输、文件读写操作等。在编程中，利用流的概念可以方便地处理大量的数据，实现数据的分块传输和处理。

Stream流

流

流水线

先得到流水线 把数据都放上面去

在利用stream流中的API进行操作

使用stream流

用集合去调用stream（）方法

获得流水线 并把集合里面的数据放到流水线上

我们这边是使用链式编程的思想

双列集合

数组

零散数据

Stream流里的静态方法of

方法的形参是一个可变参数，可以传递一堆零散的数据，也可以传递数组

但是数组必须是引用数据类型

如果传递基本数据类型，是会把整个数组当做一个元素放到Stream里

我们要做的是把数据放到Stream流里

中间方法

过滤 *

注意

stream流关闭后不可再使用

所以优先使用链式编程的思想

获取前几个元素

跳过前几个元素

实例操作

import java.util.Collections;
import java.util.Scanner;

public class Main {
    public static void main(String[] args) {
        Scanner sc=new Scanner(System.in);
        ArrayList<String>list=new ArrayList<>();
        Collections.addAll(list,"张无忌","周正若","赵敏","张强",
                                          "张三丰","张翠山","张良","王二麻子","谢广坤");
        list.stream()
                .skip(3)
                .filter(s ->s.startsWith("张"))
                .forEach(s -> System.out.println(s));
        //"张强","张三丰","张翠山","张良"
    }
}

import java.util.Collections;
import java.util.Scanner;

public class Main {
    public static void main(String[] args) {
        Scanner sc=new Scanner(System.in);
        ArrayList<String>list=new ArrayList<>();
        Collections.addAll(list,"张无忌","周正若","赵敏","张强",
                                          "张三丰","张翠山","张良","王二麻子","谢广坤");
        list.stream()
                .skip(3)
                .limit(4)
                .forEach(s -> System.out.println(s));
        //"张强","张三丰","张翠山","张良"
    }
}

去重

合并

转换流里面的数据类型

如图使用map方法

当map方法执行完毕之后，流上的数据就变成了整数

所以在下面的forEach当中

s依次表示流里面的每一个数据

上述代码等价于

终结方法

终结方法是流里面的最后一步

之后就不能在使用流里面的其他方法了

上述代码等价于

收集方法Collect

收集流中的数据，放到集合中

import java.util.Collections;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;

public class Main {
    public static void main(String[] args) {
        ArrayList<String> list=new ArrayList<>();
        Collections.addAll(list,"张无忌-男-25",
                "周正若-女-14","赵敏-女-13","张强-男-20");

        List<String> man=list.stream()
                .filter(s ->"男".equals(s.split("-")[1]))
                .collect(Collectors.toList());
        System.out.println(man);

        Set<String> woman=list.stream()
                .filter(s ->"女".equals(s.split("-")[1]))
                .collect(Collectors.toSet());

    }
}

搜集到HashSet集合里面时

会去掉重复的元素

收集使用了collect这个方法

当收集到Map双列集合里的时候

键和值的规则要分别书写

收集到Map集合中，键是不能重复的

不然就会报错

完整版

转换成Lambda表达式

import java.util.stream.Collectors;

public class Main {
    public static void main(String[] args) {
        ArrayList<String> list=new ArrayList<>();
        Collections.addAll(list,"张无忌-男-25",
                "周正若-女-14","赵敏-女-13","张强-男-20");

        Map<String,Integer>map=list.stream()
                .filter(s ->"男".equals(s.split("-")[1]))
                .collect(Collectors.toMap(
                        s ->s.split("-")[0],
                        s ->Integer.parseInt(s.split("-")[2])));
        System.out.println(map);

    }
}

总结