一、Java Stream API简单介绍
Java8的两个重大改变，一个是Lambda表达式，另一个就是Java Stream函数式编程接口。
Java Stream就是一个数据流经的管道，并且在管道中对数据进行操作，然后流入下一个管道。
在没有Java Stram之前，对于集合类的操作，更多的是通过for循环。
使用Java Stram后，对于集合进行非常复杂的查找、过滤、筛选等操作将更加简洁、快捷，同时它提供串行和并行两种模式进行汇聚操作，能够充分利用多核cpu的优势
Java Stream流程图
举例代码：
- 没有Stream时的取值，排序
List<Employee> employees = Arrays.asList(e1, e2, e3, e4, e5, e6, e7, e8, e9, e10);
List<Employee> employees1 = new ArrayList<>();
//过滤出性别为男的
for (Employee employee : employees) {
if ("M".equals(employee.getGender())) {
employees1.add(employee);
}
}
//排序
employees1.sort(new Comparator<Employee>() {
@Override
public int compare(Employee o1, Employee o2) {
return o2.getAge().compareTo(o1.getAge());
}
});
System.out.println("for循环：");
System.out.println(employees1);
- 使用Stream进行上面操作
List<Employee> m = employees.stream()
.filter(e -> "M".equals(e.getGender())) // //过滤出性别为男的
.sorted(Comparator.comparing(Employee::getAge).reversed()) //按年龄的倒序排序
.collect(Collectors.toList());
System.out.println("使用Stream：");
System.out.println(m);
- 最终输出结果
for循环：
[Employee(id=8, age=99, gender=M, firstName=ya, lastName=se), Employee(id=6, age=77, gender=M, firstName=li, lastName=bai), Employee(id=5, age=66, gender=M, firstName=chen, lastName=yaojin), Employee(id=3, age=44, gender=M, firstName=zhao, lastName=yun), Employee(id=1, age=23, gender=M, firstName=lv, lastName=bu)]
使用Stream：
[Employee(id=8, age=99, gender=M, firstName=ya, lastName=se), Employee(id=6, age=77, gender=M, firstName=li, lastName=bai), Employee(id=5, age=66, gender=M, firstName=chen, lastName=yaojin), Employee(id=3, age=44, gender=M, firstName=zhao, lastName=yun), Employee(id=1, age=23, gender=M, firstName=lv, lastName=bu)]
二、数据转换成Stream流
- 数组转换成Stream流
方法：Arrays.stream(T array) or Stream.of(T array)
String[] array = {"aa", "bb", "cc", "dd", "ee"};
Stream<String> stream1 = Stream.of(array); //通过Stream.of
Stream<String> stream2 = Arrays.stream(array);//通过Arrays.stream
- 将集合类对象转换为Stream流
方法：Collection.stream() or Collection.parallelStream()
List<String> lists= Arrays.asList(array);
Stream<String> stream1 = lists.stream();//list转Stream
Stream<String> stream2 = lists.parallelStream();//转parallelStream
HashSet hashSet = new HashSet<>(lists);
Stream stream3 = hashSet.stream();
Stream stream4 = hashSet.parallelStream();
- 将文本文件转换为Stream流
方法： java.io.BufferedReader.lines()
Stream<String> fileName = lines(Paths.get("fileName"));
- 基本数值型转换成Stream流，目前有三种对应的包装类型 Stream：
IntStream、LongStream、DoubleStream。
当然我们也可以用 Stream<Integer>、Stream<Long> >、Stream<Double>，但是 boxing 和 unboxing 会很耗时，所以特别为这三种基本数值型提供了对应的 Stream。
Java 8 中还没有提供其它数值型 Stream，因为这将导致扩增的内容较多。而常规的数值型聚合运算可以通过上面三种 Stream 进行。
IntStream intStream = IntStream.of(new int[]{1, 2, 3, 4, 5, 6, 7, 8});
三、Stream的三个操作步骤
1.创建Stream： 从数据源（如集合、数组）中获取流。
2.聚合操作：对数据源的数据进行操作。
3.终止操作：将流转换成集合或者输出。
四、聚合操作
- filter：接收Lambda，从流进行过滤操作。
- map (mapToInt, flatMap 等):映射，将元素转换成其他形式或提取信息。
- limit(n)：截断流，使其元素不超过给定对象。
- skip(n)：跳过元素，返回一个扔掉了前n个元素的流，若流中元素不足n个，则返回一个空流，与limit(n)互补。
- distinct：筛选，通过流所生成元素的hashCode()和equals()去除重复元素。
- flatMap：将流中的每个值都换成另一个流，然后把所有流连接成一个流。
五、聚合操作
- allMatch：检查是否匹配所有元素
- anyMatch：检查是否至少匹配一个元素
- noneMatch：检查是否没有匹配所有元素
- findFirst：返回第一个元素
- findAny：返回当前流中的任意元素
- count：返回流中元素的总个数
- max：返回流中最大值
- min：返回流中最小值
