​

一、了解Stream

Stream是Java8中处理集合的关键抽象概念，对集合进行的操作，可以指定非常复杂的查找、过滤和映射数据等操作。

二、流(stream)到底是什么？

流是数据渠道，用于操作数据源(集合、数组等)所生成的元素序列

【注意】
①、Stream 自己不会存储元素
②、Stream不会改变源对象。相反，他们会返回一个持有结果的新Stream
③、Stream操作是延迟执行的。这意味着它们会等到需要结果的时候才执行

三、Stream操作的三个步骤

1. 创建Stream
   一个数据源(如：集合，数组)，获取一个流

2)中间操作
一个中间操作链，对数据源的数据进行处理

3)终止操作
一个终止操作，执行中间操作链，并产生结果

四、创建Stream的四种方式

1、可以通过Collection系列集合提供的stream()或 parallelStram() 创建流

  List<String> list = new ArrayList<>();Stream<String> stream1 = list.stream();

2、通过Arrays中的静态方法stream()来获取数组流

  Employee[] emps = new Employee[10];Stream<Employee> stream2 = Arrays.stream(emps);

3、通过Stream中的静态方法 of() 创建流

 Stream<String> stream3 =  Stream.of("aa","bb","cc");

4、由函数创建流：创建无限流

Stream<Integer> stream4 = Stream.iterate(0, (x) -> x + 2);
stream4.limit(10).forEach(System.out::println);Stream<Double> s = Stream.generate(() -> Math.random());
s.limit(10).forEach(System.out::println);

五、Stream 的中间操作

【注意】多个中间操作可以连接起来形成一个流水线，除非流水线上触发终止操作，否则中间操作不会执行任何的
处理！，而是在终止操作时一次性处理，称为“惰性求值”

1、筛选和切片

• filter - 接受Lambda，从流中排除某些元素
• limit - 截断流，使其元素不超过给定数量
• skip - 跳过元素，返回一个扔掉了前 n 个元素的流。若流中元素不足n，则返回一个空流。
• distinct - 筛选，通过流所生成元素的hashCode()和equals()去除重复元素

public class TestStream2 {List<Employee> employees = Arrays.asList(new Employee("张三",18,3000),new Employee("李四",45,4000),new Employee("王五",37,3000),new Employee("赵六",18,6000),new Employee("田七",40,10000),new Employee("田七",40,10000));//filter//内部迭代：迭代操作由Stream API完成@Testpublic void test1(){//中间操作不会不会有任何结果Stream<Employee> sm = employees.stream().filter((e) -> e.getAge() > 25);//终止操作//sm.forEach((e) -> System.out.println(e));sm.forEach(System.out::println);}//limit@Testpublic void test2(){employees.stream().filter((e) -> e.getAge() > 25).limit(2).forEach(System.out::println);}//skip@Testpublic void test3(){employees.stream().filter((e) -> e.getAge() > 25).skip(2).forEach(System.out::println);}//distinct() 【注意】比较的元素需要equals()方法@Testpublic void test4(){employees.stream().filter((e) -> e.getAge() > 25).skip(2).distinct().forEach(System.out::println);}
}

2、map 映射

• map：接收一个函数作为参数，该函数会被用到每个元素上，并将其映射成一个新的元素
• flatMap： 接收一个函数作为参数，将流中的每个值都换成另一个流，然后把所有流连接成一个流

@Testpublic void test5(){List<String> list = Arrays.asList("aaa","bb","ccc");list.stream().map((str) -> str.toUpperCase()).forEach(System.out::println);System.out.println("-----------------------------------");employees.stream().map(Employee::getName).forEach(System.out::println);System.out.println("------------------------------------");Stream<Stream<Character>> sm = list.stream().map(TestStream2::filterCharacter);sm.forEach((stm) -> stm.forEach(System.out::println));System.out.println("------------------------------------");System.out.println("上述代码优化");list.stream().flatMap(TestStream2::filterCharacter).forEach(System.out::println);}//方法：将字符串转换成一个流
public static Stream<Character> filterCharacter(String str){List<Character> list = new ArrayList<>();for(Character c: str.toCharArray()){list.add(c);}return list.stream();
}

3、排序

• sorted() : 自然排序
• sorted(Comparator com) ： 定制排序

 @Testpublic void test6(){List<String> list = Arrays.asList("aaa","bb","ccc");list.stream().sorted().forEach(System.out::println);System.out.println("------------------------------------");list.stream().sorted((x,y) -> -x.compareTo(y)).forEach(System.out::println);}

​

六、Stream 的终止操作

1、查找和匹配

allMatch - 检查是否匹配所有元素
anyMatch - 检查是否至少匹配一个元素
noneMatch - 检查是否没有匹配所有元素
findFirst - 返回第一个元素
FindAny - 返回当前流中的任意元素
count - 返回当前流中元素的总个数
max - 返回流中的最大值
min - 返回流中的最小值

2、归约

reduce(T identity,BinaryOperater) / reduce(BinaryOperater)： 可以将流中元素反复结合起来，得到一个值。返回 T

public void test(){List<Integer> list = Arrays.asList(1,2,3,4,5);//0称之为起始元素，将0作为x，在流中取出一个元素作为y,//然后将相加的结果作为x,再从流中取出一个元素作为y相加...//一直到流中的元素全部加完Integer sum = list.stream().reduce(0, (x, y) -> x + y);System.out.println(sum);System.out.println("------------------------------");//获取当前公司中，工资的总和Double sumSalary = employees.stream().map(Employee::getSalary).reduce(0d, (x, y) -> x + y);System.out.println(sumSalary);}

3、收集

• collect：将流转换为其他形式。接收一个 Collector接口的实现