前言
Stream 是 Java8 中处理集合的关键抽象概念，它可以指定你希望对集合进行的操作，可以执行非常复杂的查找、过滤和映射数据等操作。使用Stream API 对集合数据进行操作，就类似于使用 SQL 执行的数据库查询。也可以使用 Stream API 来并行执行操作。简而言之，Stream API 提供了一种高效且易于使用的处理数据的方式。让程序员写出高效率、干净、简洁的代码。
什么是 Stream？
Stream（流）是一个来自数据源的元素队列并支持聚合操作,流在管道中传输， 并且可以在管道的节点上进行处理， 比如筛选， 排序，聚合等。 Stream（流）的组成包含:元素、数据源、聚合操作、内部迭代、Pipelining等。
- 元素：特定类型的对象
- 数据源：流的来源，元素的集合，数组等。
- 聚合操作：类似SQL语句一样的操作， 比如filter, map, reduce, find, match, sorted等。
- 内部迭代：在流中内部迭代，与for外部处理不同。
- Pipelining: 中间操作都会返回流对象本身。
Stream 基本操作
初始化两组数据
List<String> stringList = Arrays.asList("juejin", "zijie", "toutiao", "feidian", "join","", "juelimanman");
List<Integer> integerList = Arrays.asList(0, 1, 2, 3, 4, 5, 6, 7,8, 9, 10,11,12);Stream 创建
stream()
使用stream()创建串行流。
Stream<String> stream = stringList.stream();parallelStream()
parallelStream() 方法创建并行流
Stream<String> stringStream = stringList.parallelStream();Arrays.stream()
使用Arrays 中的 stream() 方法
Stream<String> stream1 = Arrays.stream(new String[10]);Stream.of
Stream.of创建流,创建的是有限流
Stream<String> streamOf = Stream.of("juejin", "zijie", "toutiao", "feidian", "join","", "juelimanman");Stream.iterate
Stream.iterate创建流，创建一个有序无限的数据流
Stream<Integer> stream2 = Stream.iterate(0, (x) -> x + 3).limit(5);Stream.generate
Stream.generate创建流，创建一个无限数据流
Stream<Double> stream3 = Stream.generate(Math::random).limit(2);reader.lines
使用 BufferedReader.lines() 方法，将每行内容转成流
Stream<String> lineStream = reader.lines();Stream 操作
forEach
forEach来迭代流中的每个数据,输出所有元素
stringList.forEach(System.out::println);map
map 方法用于映射每个元素到对应的结果
stringList.stream().map(i->i.equals("juejin"));flatMap
flatMap：将流中的每个值都换成另一个流，然后把所有流连接成一个流。
stream.flatMap(String::toUpperCase).collect(Collectors.toList());filter
filter 方法用于通过设置的条件过滤出元素,过滤流中的某些元素
stringList.stream().filter(i->i.equals("juejin"));peek
如同于map，能得到流中的每一个元素。但map接收的是一个Function表达式，有返回值；而peek接收的是Consumer表达式，没有返回值。
stream.peek(s -> s.equals("juejin"));limit
limit(n) 方法用于获取指定数量的流。例如：limit(n)：获取n个元素
integerList.stream().limit(3);skip
skip(n)：跳过n元素，配合limit(n)可实现分页
integerList.stream().skip(5).limit(3);distinct
distinct：通过流中元素的 hashCode() 和 equals() 去除重复元素
integerList.stream().distinct().collect(Collectors.toList());sorted
sorted sorted 方法用于对流进行排序,自然排序。
integerList.stream().sorted();sorted(Comparator com)
sorted(Comparator com)：定制排序，自定义Comparator排序器
integerList.stream().sorted(Comparator.comparing(Integer::intValue));parallel
parallelStream 是流并行处理程序的代替方法。
integerList.parallelStream().sorted();Collectors
Collectors 类实现了很多归约操作，例如将流转换成集合和聚合元素。
stringList.stream().filter(s -> s.equals("juejin")).collect(Collectors.toList());count
count 统计结果的收集器也非常有用,流的终止操作，用在流的最后。
integerList.stream().count();allMatch
allMatch：接收一个函数，当流中每个元素都符合该断言时才返回true，否则返回false,流的终止操作，用在流的最后
integerList.stream().allMatch(integer -> integer>0);noneMatch
noneMatch：接收一个函数，当流中每个元素都不符合该断言时才返回true，否则返回false,流的终止操作，用在流的最后。
integerList.stream().noneMatch(integer -> integer>100);anyMatch
anyMatch：接收一个函数，只要流中有一个元素满足该断言则返回true，否则返回false,流的终止操作，用在流的最后。
integerList.stream().anyMatch(integer -> integer>2);findFirst
findFirst：返回流中第一个元素,流的终止操作，用在流的最后。
stringList.stream().findFirst();findAny
findAny：返回流中的任意元素,流的终止操作，用在流的最后。
stringList.stream().findAny();max
max：返回流中元素最大值,流的终止操作，用在流的最后。
userList.stream().max(Comparator.comparingInt(user::score));min
min：返回流中元素最小值,流的终止操作，用在流的最后。
userList.stream().min(Comparator.comparingInt(user::score));collect
collect：接收一个Collector实例，将流中元素收集成另外一个数据结构。
integerList.stream().filter(u->user.getScore>60).collect(Collectors.toList());总结
Stream API 提供了一种高效且易于使用的处理数据的方式。让程序员写出高效率、干净、简洁的代码。在Stream流中都是使用复杂的表达式去处理数据逻辑，当然大家可以先了解这些方法，在项目中使用到的时候，再进行深入了解，进行更复杂的组合操作。