Stream流对使用Java开发的伙计来说都不陌生，有了它从此就告别了繁琐的for循环😎。说实话作为开发，我对使用Stream流的掌握情况还不是很好🤷‍♂️，所以学习JDK中的API同时记录相应的API操作，并通过相应的实例快速掌握Stream的使用🐱‍🏍。

  老规矩，先了解什么是什么？（一到学习看英文文档我就头大！😒）

Stream 是什么？

  JDK文档中原述是这样的支持顺序和并行聚合操作的一系列元素，从文档中就能看出Stream 流管线 由源（其可以是阵列，集合，生成函数，I / O通道等）组成,零个或多个中间操作 （其将流转换成另一个流，例如filter(Predicate) ）以及终端操作 （产生结果或副作用，如count()或forEach(Consumer) ）， 流懒惰 源数据上的计算仅在终端操作启动时执行，源元素仅在需要时才被使用（这可以理解为，取值是不会像普通集合一样立即获取值，当真正需要结果是才会执行）。 从Stream的实现中也能看到Stream实现了Collection接口，但Stream做了更高效的处理能 让代码更加简洁，极大地简化了集合的处理操作，提高了开发的效率和生产力。你可以使用相应的API对数据进行查找、过滤、组合、计算、操作、分组等过程。

Stream API接口

Stream 操作（仅仅介绍常用API）

anyMatch() - 其中有一个元素满足条件则为true

/**
 * anyMatch
 * 其中有一个元素大于满足条件则为true
 */
public static void anyMatch(ArrayList<Integer> list){
    boolean b = list.stream().anyMatch(p -> p > 3);
    System.out.println(b);
}

allMatch() - 所有元素必须满足条件才能为true，否则为false。

/**
 * 所有元素必须满足条件才能为true，否则为false。
 * allMatch
 */
public static void allMatch(ArrayList<Integer> list){
    boolean b = list.stream().allMatch(p -> p > 0);
    System.out.println(b);
}

concat() - 进行两个流的连接

/**
 * 进行两个流的连接
 * concat
 */
public static void concat(Stream<Integer> s1,Stream<Integer> s2){
    Stream<Integer> concat = Stream.concat(s1, s2);
    System.out.println(Arrays.toString(concat.toArray()));
}

count() - 统计流中的元素数

/**
 * count
 * 统计流中的元素数
 */
public static void count(Stream<Integer> stream){
    System.out.println(stream.count());
}

distinct() - 返回由该流的不同元素

 ArrayList<Integer> arr1 = new ArrayList<>();
        arr1.add(1);
        arr1.add(1);
        arr1.add(3);
        arr1.add(4);
        distinct(arr1.stream());
/**
 * distinct
 * 返回不同的元素
 */
public static void distinct(Stream<Integer> stream){
    System.out.println(Arrays.toString(stream.distinct().toArray()));
}

filter() - 返回由与此给定谓词匹配的此流的元素组成的流

/**
 * filter
 * 根据条件过滤
 */
public static void filter(Stream<Integer> stream){
    List<Integer> collect = stream.filter(p -> p > 0)
            .collect(Collectors.toList());
    System.out.println(collect);
}

map() - 返回由给定函数应用于此流的元素的结果组成的流。

/**
 * map
 * 给定函数返回，返回组成新的流
 */
public static void map(Stream<Employee> s1) {
    s1.map(Employee::getName)
            .forEach(System.out::println);
}

　Stream.of－用于给定元素返回元素顺序流，可以传递一个或者多个。

　flatMap －返回由通过将提供的映射函数应用于每个元素而产生的映射流的内容来替换该流的每个元素的结果的流。

/**
 * flatMap
 * 给定流，返回按指定值的顺序排序的流
 */
public static void flatMap(List<Employee> s1) {
    List<Employee> newList = new ArrayList<>();
    newList.add(new Employee("新人", 18, "女",
            5000.7D, "浙江金华", "浙江金华", "售前", null));

    Stream.of(s1,newList)
            .flatMap(employee -> employee.stream().filter(f -> f.getAge()  == 18))
            .forEach(System.out::println);
}

除此之外，使用Stream有原型链，可以使用原型链的特性，自由进行发挥，使Stream流应用更加扎实。