【Java】Stream流是什么，如何使用Stream流？-蒲公英云

【Java】Stream流是什么，如何使用Stream流？

在这里插入图片描述

个人简介：Java领域新星创作者；阿里云技术博主、星级博主、专家博主；正在Java学习的路上摸爬滚打，记录学习的过程~
个人主页：.29.的博客
学习社区：进去逛一逛~

Stream流

Stream流：

Stream流结合了Lambda表达式，简化了集合、数组的操作。
①使用步骤：

①得到一条Stream流，并将数据放上去。
②使用中间方法对流水线上的数据进行操作。
③使用终结方法对流水线上的数据进行操作。
小案例：

import java.util.ArrayList;

public class StreamDemo {

public static void main(String[] args) {
    /*
     * 创建集合、添加元素，使用Stream流，
     * ①将开头为“张”的元素添加进新集合
     * ②之后将长度为3的元素添加进新集合
     * ③遍历
     */
    ArrayList<String> list = new ArrayList<>();
    list.add("张三丰");
    list.add("张无忌");
    list.add("张强");
    list.add("王麻子");
    list.add("小李");
    //获取对象stream流，添加过滤条件，遍历
    list.stream()
        .filter(name -> name.startsWith("张"))
        .filter(name -> name.length() == 3)
        .forEach(name -> System.out.println(name));
}

}

②获取Stream流：
- default Stream<E> stream()：单列集合获取Stream流（Collection的默认方法）
- public static <T> Stream<T> stream(T[] array)：数组获取Stream流（Arrays工具类中的静态方法）
- public static <T> stream<T> of(T... values)：获取一堆零散数据的Stream流（Stream接口中的静态方法，数据需要统一类型）
- 双列集合无法直接获取Stream流，需要先使用keySet() / entrySet()再对获取到的集合使用stream()获取。
③Stream流中间方法：
- Stream<T> filter(Predicate<? super T> predicate)：过滤
- Stream<T> limit(long maxSize):Stream流获取前maxSize个元素
- Stream<T> skip(long n)：跳过前n个元素获取元素
- Stream<T> distance()：元素去重，依赖HashCode() 和 equals()
- static <T> Stream<T> concat(Stream a,Stream b)：将两个流合并为一个流
- Stream<R> map(Function<T,R> mapper)：转换流中的数据类型，参数是函数式的，需重写其方法以设置转换规则，泛型依次是原本类型，转换的类型。
- - 中间方法、返回新的Stream流，流只能使用一次，建议链式编程。
  - 修改Stream流中的数据，原本集合或数组的数据不变。
④Stream流的终结方法：
- void forEach(Consumer action)：遍历
- long count()：统计
- toArray()：将流中的数据放入数组
- collect(Collector collector)：将流中的数据放入集合
- - Collectors.toList()
  - Collectors.toSet()
  - Collectors.toMap(a,b)：a，b两个函数式接口，需要编写匿名内部类，重写方法，指定数据转换规则。
- 案例：
- import java.util.ArrayList;
  import java.util.Collections;
  import java.util.HashMap;
  import java.util.Map;
  import java.util.stream.Collector;
  import java.util.stream.Collectors;
  
  public class StreamDemo {
```
public static void main(String[] args) {
```

                /*定义集合，添加数据，留下偶数*/
                ArrayList<Integer> listInt = new ArrayList<>();
                Collections.addAll(listInt, 1,2,3,4,5,6,7,8,9,10);
                listInt.stream().filter(s -> s.intValue() % 2 == 0).forEach(i -> System.out.println(i));
                System.out.println("-------------------------------");
                /*定义集合，添加姓名，年龄数据，保留年龄大于24的人，数据存入Map集合*/
                ArrayList<String> listName = new ArrayList<>();
                Collections.addAll(listName, "张三,18","李四,24","小品,24","小豪,29","张无忌,16","脉哦,22");
                Map<String,Integer> mapName = listName.stream()
                        .filter(s -> Integer.parseInt(s.split(",")[1]) >= 24)
                        .collect(Collectors.toMap(
                                s -> s.split(",")[0] ,
                                s -> Integer.parseInt(s.split(",")[1])));
                mapName.entrySet().forEach(s -> System.out.println(s.getKey() + "--" + s.getValue()));
            }
        }
 *  ![在这里插入图片描述][020d26ed8e334b85a302a8bb0a7f9fd7.png_pic_center]