Stream流的使用
本篇主要讲解JDK8中 Stream流的使用， 包括如何 筛选 、切片、映射 、查找、匹配 、归约 等等 每个类型都会有对应的案例 简单易懂
1.Stream的概念
Stream API是JDK8新添加的处理集合的关键组件，这里的Stream流和I/O流不同，Stream是对集合对象功能的增强，它专注对集合对象提供各种便利的操作，只要给出需要对其包含的元素执行什么操作，比如“过滤掉长度大于10的字符串”、“获取每个字符串的首字母”等，Stream会隐式地在内部进行遍历，做出相应的数据转换。
2.Stream流的创建
2.1 从集合创建
<code> List<integer> list = new ArrayList<>();/<integer>/<code>
<code> //1.从集合创建流
list.stream();
list.parallelStream();/<code>
2.2 从数组创建
<code> //Arrays的静态方法 stream
Arrays.stream(new int[] {1, 2, 3,});/<code>
2.3 创建数字流
<code> //IntStream流
int intarr[] = {1,2,3};
IntStream.of(1,2,3);
IntStream.of(intarr);/<code>
<code> //LongStream流
long longarr[] = {1L , 2L , 3L};
LongStream.of(longarr);/<code>
2.4 创建无限流
<code> //通过Random的 ints longs doubles 创建一个无限流 一般要限制个数 通过 limit是限制个数/<code>
<code> new Random().ints().limit(10).forEach((i) -> System.out.println(i));
new Random().longs();
new Random().doubles();/<code>
2.5 自己创建Stream
<code> 通过 Stream.generate(Supplier s) 自己去实现Supplier 函数式接口，去提供数据/<code>
<code> //如下 通过Random去提供
Random random = new Random();
Stream.generate(() -> random.nextInt()).limit(20).forEach((i) -> System.out.println(i));/<code>
<code> //通过 Stream的 of
Stream.of("Hello" , "Stream")
/<code>
3.Stream提供的常用的方法
Stream提供了一些便利的方法
<code> map() 映射
filter() 过滤/筛选
limit() 限制数量
skip() 跳过数量
reduce() 归约
distinct() 去重
sorted() 排序
collect() 收集 结合Collectors.toList()使用
forEach() 遍历
...
/<code>
4.Stream流的中间操作
Stream流的中间操作，就是这个操作返回还是一个Stream流，不是一个最终结果，中间操作比如要有一个终止操作的方法调用才会执行
Stream流的中间操作 分为2类 无状态操作：当前的操作和其元素的前后没有依赖关系
有状态操作：当前的操作的结果需要依赖其他的元素
5.Stream流的终止操作
Stream流的终止操作，会返回一个最终的结果，只有有终止操作 中间操作才会执行
Stream流的终止操作 分为2类非短路操作：当前操作中间是不会断的，也就是需要流中的数据全部执行完毕短路操作：当前操作不需要等待全部数据执行完毕，可能到某个数据执行完毕后就结束流
6.筛选和切片
<code>
/<code>
准备数据
<code> //id name age 对应属性
Student student = new Student(1, "johnny", 23);
Student student1 = new Student(2, "candy", 25);
Student student2 = new Student(2, "ruby", 25);
Student student3 = new Student(3, "lucy", 33);
Student student4 = new Student(4, "jack", 53);
/<code>
<code> List<student> studentList = new ArrayList<>();
studentList.add(student);
studentList.add(student1);
studentList.add(student2);
studentList.add(student3);
studentList.add(student4);
/<student>/<code>
6.1 谓词筛选 filter
Stream 接口支持 filter 方法，该操作会接受一个谓词（一个返回 boolean的函数）作为参数，并返回一个包括所有符合谓词的元素的流。
如下：这个谓语就是 age>25
<code> List<student> filterStudent = studentList.stream().filter(s -> s.getAge() > 25)
.collect(Collectors.toList());
/<student>/<code>
6.2 筛选重复 distinct
Stream 接口支持 distinct 的方法， 它会返回一个元素各异（根据流所生成元素的 hashCode和equals方法实现）的流
<code> //得到Student所有的年纪并且去重
List<integer> ageList = studentList.stream().map(s -> s.getAge())
.distinct()
.collect(Collectors.toList());
/<integer>/<code>
6.3 限制元素 limit
Stream 支持limit(n)方法，该方法会返回一个不超过给定长度的流。所需的长度作为参数传递 给limit。如果流是有序的，则最多会返回前n个元素
<code> List<integer> limitAgeList = studentList.stream().map(s -> s.getAge())
.limit(2)
.collect(Collectors.toList());
System.out.println(limitAgeList);/<integer>/<code>
6.4 跳过指定数量元素
Stream 支持 skip(n) 方法，返回一个扔掉了前n个元素的流。如果流中元素不足n个，则返回一 个空流。
<code> List<integer> skipAgeList = studentList.stream().map(s -> s.getAge())
.skip(2)
.collect(Collectors.toList());/<integer>/<code>
7.映射
7.1 map
Stream 支持 map 方法，它会接受一个函数作为参数。这个函数会被应用到每个元素上，并将其映 射成一个新的元素
<code> List<integer> mapAageList = studentList.stream().map(s -> s.getAge())
.collect(Collectors.toList());/<integer>/<code>
7.2 flatMap
Stream 流支持 flatmap 方法让你把一个流中的每个值都换成另一个流，然后把所有的流连接起来成为一个流
注意 chars()方法返回的是IntStream ，需要装箱 boxed，转换为Stream，因为IntStream并不是Stream的子类
下面的例子flatMap就是 分别把 前2个 student的name属性转换为一个流，并且将其合为一个流
<code> List<integer> flatMapList = studentList.stream()
.limit(2)
.flatMap(s -> s.getName().chars().boxed())
.collect(Collectors.toList());/<integer>/<code>
<code> flatMapList.stream().forEach(i -> System.out.println((char)i.intValue()));/<code>
打印
<code> j
o
h
n
n
y
c
a
n
d
y/<code>
8.查找和匹配
8.1 anyMatch
流中是否有一个元素能匹配给定的谓词，有则返回true 否则返回false。
<code> //anyMatch 查找流中是否有满足谓语的，存在就返回true 否则就返回false
boolean isExistAgeUp50 = studentList.stream()
.anyMatch(s -> s.getAge() > 50);/<code>
8.2 allMatch
流中是否有所有元素能匹配给定的谓词。
<code> boolean allMatchFlag = studentList.stream()
.allMatch(s -> s.getAge() > 10);/<code>
8.3 nonMatch
流中是否有没有任何元素能匹配给定的谓词。
<code> boolean noneMatchFlag = studentList.stream()
.noneMatch(s -> s.getAge() > 100);/<code>
8.4 findAny
findAny 方法将返回当前流中的任意一个元素。注意在非并行流下大多情况返回第一个元素，但是不保证
<code> Optional<student> studentOptional = studentList.parallelStream()
.findAny();/<student>/<code>
8.5 findFirst
findFirst 方法将返回当前流中的第一个元素。
<code> studentList.stream()
.map(s->s.getAge() * 2)
.filter(i -> i % 2==0)
.findFirst().ifPresent(i -> System.out.println(i));
/<code>
9.归约
就是把一个流中的元素 经过lambda反复进行操作，指到流被归约成一个值
reduce方法有3种形式：
把一个流中的元素组合起来，使用 reduce 操作来表达更复杂的查 询，比如“计算菜单中的总卡路里”或“菜单中卡路里最高的菜是哪一个”。此类查询需要将流中所有元素反复结合起来，得到一个值，比如一个Integer。这样的查询可以被归类为归约操作 （将流归约成一个值）。
reduce方法接受两个参数：一个初始值，这里是0；一个 BinaryOperator 来将两个元素结合起来产生一个新值， 这里我们用的是 lambda (a, b) -> a + b。
<code> List<integer> nums = Arrays.asList(3, 4, 5, 6, 7);
int sum = nums.stream().reduce(0, (a, b) -> a + b);
/<integer>/<code>
10.排序
下面代码以自然序排序一个list
<code> list.stream().sorted()
/<code>
自然序逆序元素，使用Comparator 提供的reverseOrder() 方法,前提是流中的元素要实现了Comparator接口，比如Integer 这种
<code> list.stream().sorted(Comparator.reverseOrder())
/<code>
使用Comparator 来排序一个list
<code> list.stream().sorted(Comparator.comparing(Student::getAge))
/<code>
把上面的元素逆序
<code> list.stream().sorted(Comparator.comparing(Student::getAge).reversed())/<code>
案例：将按照学生的Age属性排序 和 倒序
<code> studentList.stream()
.sorted(Comparator.comparing(Student::getAge))
.forEach(System.out::println);/<code>
<code> studentList.stream()
.sorted(Comparator.comparing(Student::getAge).reversed())
.forEach(System.out::println);
/<code>
11.收集
将流元素进行中间操作后进行收集到一个List 或者Set 中去,结合Collectors的方法
<code> studentList.stream()
.map(Student::getAge)
.collect(Collectors.toList());/<code>
<code> studentList.stream()
.map(Student::getAge)
.collect(Collectors.toSet());
/<code>
12.总结
本篇主要讲解JDK8中 Stream流的使用，流是什么 如何创建 以及常用方法 包括如何 筛选 、切片、映射 、查找、匹配 、归约 等等 每个类型都会有对应的案例 简单易懂。
个人博客网站 https://www.askajohnny.com 欢迎访问！
本文由博客一文多发平台 https://openwrite.cn?from=article_bottom 发布！