JAVA8的新特性——Stream

JAVA8的新特性——Stream

在这个深夜写下这篇笔记，窗外很安静，耳机里是《季节更替》，我感触还不是很多，当我选择封面图片的时候才发现我们已经渐渐远去，我们都已经奔赴生活，都在拼命想着去换一个活法，六月就要真的结束这段关系，好怀念校园的那段日子，我们不用去思考以后，在这个象牙塔里幻想一份感情，互相玩笑，走出来了，就真的远去！愿我们所得皆所愿，不被生活磨平了棱角，聪哥，腿哥，伟哥，吕子，帆子，还有此刻读到文章的你，加油，我们一起向前冲！
——2023年5月15日凌晨 IT小辉同学

Java 8中引入的Stream是一种全新的数据处理方式，它使用简单而高效的方法对集合数据进行操作。下面对Stream进行详细介绍

什么是 Stream(引用菜鸟教程)

Stream（流）是一个来自数据源的元素队列并支持聚合操作

• 元素是特定类型的对象，形成一个队列。 Java中的Stream并不会存储元素，而是按需计算。
• 数据源 流的来源。 可以是集合，数组，I/O channel， 产生器generator 等。
• 聚合操作 类似SQL语句一样的操作， 比如filter, map, reduce, find, match, sorted等。

和以前的Collection操作不同， Stream操作还有两个基础的特征：

• Pipelining: 中间操作都会返回流对象本身。 这样多个操作可以串联成一个管道， 如同流式风格（fluent style）。 这样做可以对操作进行优化， 比如延迟执行(laziness)和短路( short-circuiting)。
• 内部迭代： 以前对集合遍历都是通过Iterator或者For-Each的方式, 显式的在集合外部进行迭代， 这叫做外部迭代。 Stream提供了内部迭代的方式， 通过访问者模式(Visitor)实现

Stream的用法

Stream是Java 8中针对集合数据的一种新的操作方式，使用了类似于SQL语句的流式操作方式。Stream由三部分构成：源、零个或多个中间操作、终止操作。
源是指Stream要处理的原始数据源，可以是Collection、Array、I/O资源等；
中间操作用来对数据进行转化、过滤、排序等操作，其中每一个中间操作都会返回一个新的Stream对象；
终止操作用来获取Stream处理结果。

Stream的特点

（1）流式操作：Stream提供了一种流式的操作方式，方便数据处理和转换；
（2）惰性求值：Stream使用惰性求值方式进行计算，只有在被终止操作时才会进行计算；
（3）并行处理：Stream支持并行处理，提高了处理大数据集的效率。

Stream的优缺点

优点：
（1）简洁：使用Stream可以让代码更加简洁易懂；
（2）高效：Stream支持惰性求值和并发处理，提高了处理效率；
（3）灵活：Stream提供了多种操作方式，可以适应不同的数据处理需求。

缺点：
（1）学习成本：Stream需要掌握一些新的操作方式，需要一定的学习成本；
（2）线程安全：并行处理时需要注意线程安全问题。

Stream的使用场景

Stream适用于处理大数据集和需要频繁进行转换、过滤、排序等操作的场景。例如，对于需要筛选和排序的订单列表或者用户列表等数据集合，Stream可以极大地提高处理效率和代码简洁度。

Stream的发展趋势

随着Java生态系统的不断发展，Stream也在不断完善和优化中。未来Stream可能会增加更多的功能和特性，同时也会进一步提升处理效率和优化用户体验。

总之，Stream是Java 8中非常重要的一个新特性，它为集合数据的处理提供了一种全新的方式，具有很多优点和适用场景。因此，熟练掌握Stream的各种用法和特点对Java开发者来说是非常重要的。

Java生成Stream

Java中可以通过多种方式来生成Stream，包括：

1. 从集合中生成Stream：

可以使用Collection接口提供的stream()方法或parallelStream()方法来生成Stream对象。例如：

List<String> list = Arrays.asList("apple", "banana", "orange");
Stream<String> stream = list.stream();

2. 从数组中生成Stream：

可以使用Arrays类提供的stream()方法或parallelStream()方法来生成Stream对象。例如：

int[] arr = new int[]{1, 2, 3, 4, 5};
IntStream stream = Arrays.stream(arr);

3. 使用Stream.of()方法生成Stream：

可以使用Stream类提供的of()方法来生成Stream对象。例如：

Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5);

4. 使用Stream.iterate()方法生成Stream：

可以使用Stream类提供的iterate()方法来生成Stream对象。该方法需要传入一个初始值和一个函数接口，用来生成无限长度的Stream。例如：

Stream<Integer> stream = Stream.iterate(1, n -> n + 1);

5. 使用Stream.generate()方法生成Stream：

可以使用Stream类提供的generate()方法来生成Stream对象。该方法需要传入一个函数接口，用来生成无限长度的Stream。例如：

Stream<Double> stream = Stream.generate(Math::random);

总之，Java中可以通过多种方式来生成Stream对象，可以根据不同的需求选择不同的方式来生成Stream。

Stream中的filter过滤

filter()方法可以用于过滤出满足特定条件的元素。

具体来说，filter()方法会接收一个函数式接口Predicate<T>,该接口只有一个方法test(T t),该方法接受一个参数t,返回一个布尔值。当test()方法的返回值为true时，表示当前元素应该被保留；当返回值为false时，表示当前元素应该被过滤掉。

	/*** @Description 过滤掉apple这个字符串* @Author IT小辉同学* @Date 2023/05/14*/@Testpublic void test1() {List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");Stream<String> stream = list.stream();//过滤掉apple这个字符串List<String> stringList =stream.filter(s -> !s.equals("apple")).collect(Collectors.toList());System.out.println("过滤掉apple这个字符串:"+stringList);}/*** @Description 过滤掉含字母a的字符串* @Author IT小辉同学* @Date 2023/05/14*/@Testpublic void test2() {List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");Stream<String> stream = list.stream();//过滤掉含字母a的字符串List<String> stringList1=stream.filter(s -> !s.contains("a")).collect(Collectors.toList());System.out.println("过滤掉含字母a的字符串:"+stringList1);}/*** @Description 过滤掉含字母a和i的字符串* @Author IT小辉同学* @Date 2023/05/14*/@Testpublic void test3() {List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");Stream<String> stream = list.stream();//过滤掉含字母a和i的字符串List<String> stringList1=stream.filter(s -> !s.contains("a")&&!s.contains("i")).collect(Collectors.toList());System.out.println("过滤掉含字母a和i的字符串:"+stringList1);}

注意：同一个Stream不可进行多次操作，否则报错

错误示例

List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");Stream<String> stream = list.stream();//过滤掉apple这个字符串List<String> stringList =stream.filter(s -> !s.equals("apple")).collect(Collectors.toList());System.out.println("过滤掉apple这个字符串:"+stringList);//过滤掉含字母a和i的字符串List<String> stringList1=stream.filter(s -> !s.contains("a")&&!s.contains("i")).collect(Collectors.toList());System.out.println("过滤掉含字母a和i的字符串:"+stringList1);

报错情况

Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closedat java.util.stream.AbstractPipeline.<init>(AbstractPipeline.java:203)at java.util.stream.ReferencePipeline.<init>(ReferencePipeline.java:94)at java.util.stream.ReferencePipeline$StatelessOp.<init>(ReferencePipeline.java:618)at java.util.stream.ReferencePipeline$2.<init>(ReferencePipeline.java:163)at java.util.stream.ReferencePipeline.filter(ReferencePipeline.java:162)at com.demo.example.StreamDemo.main(StreamDemo.java:20)什么原因

详细解释

这个异常通常是因为对一个已经被操作或关闭的Stream进行了再次操作或关闭，导致Stream状态不正确，从而抛出IllegalStateException异常。解决这个问题的方法通常有以下几种：

1. 避免在同一个Stream上进行多个终止操作：

即使多个终止操作被串联在一起，也只会执行最后一个终止操作。因此，在一个Stream对象上执行多个终止操作会导致Stream被关闭，从而引发IllegalStateException异常。如果需要对同一个Stream进行多个操作，可以将其保存到一个中间变量中，并对该中间变量进行操作。例如：

Stream<String> stream = list.stream();
stream = stream.filter(s -> s.length() > 5);
stream.forEach(System.out::println);

2. 使用新建的Stream对象进行操作：

对于Stream对象的所有操作都会返回一个新的Stream对象，因此可以通过使用新建的Stream对象来避免对已经被操作或关闭的Stream进行操作。例如：

Stream<String> stream1 = list.stream();
Stream<String> stream2 = stream1.filter(s -> s.length() > 5);
stream2.forEach(System.out::println);

3. 改用Stream.peek()方法：

peek()方法是一种类似于forEach()方法但不会关闭Stream的中间操作。可以通过使用peek()方法来进行调试和测试操作。例如：

Stream<String> stream = list.stream();
stream = stream.filter(s -> s.length() > 5).peek(System.out::println);
stream.forEach(System.out::println);

总之，如果出现了IllegalStateException异常，通常是因为对一个已经被操作或关闭的Stream进行了再次操作或关闭。可以通过避免在同一个Stream对象上进行多个终止操作、使用新建的Stream对象进行操作或改用Stream.peek()方法来解决这个问题。

Stream中的forEach遍历

forEach()方法是一种用于遍历Stream元素并对每个元素进行指定操作的终止操作方法。

forEach()方法接收一个Lambda表达式作为参数，该表达式会被应用到Stream中的每个元素上，用来执行指定的操作。该方法不返回任何值，只是将Lambda表达式应用到Stream中的每个元素上，从而实现对Stream的遍历操作。

 /*** @Description 简单遍历* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test4(){List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");Stream<String> stream = list.stream();stream.forEach(System.out::println);}/*** @Description 遍历去除含有字母b的字符串* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test5(){List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");Stream<String> stream = list.stream();stream.filter(s -> !s.contains("b")).forEach(System.out::println);}/*** @Description 遍历去除含有字母b和i的字符串并且添加到arrayList* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test6(){List<String> list = Arrays.asList("apple", "banana", "orange","cherry","Hami");ArrayList<String> arrayList=new ArrayList<>();Stream<String> stream = list.stream();stream.filter(s -> !s.contains("b")).forEach(arrayList::add);System.out.println(arrayList);}

Stream中的map映射

map操作可以将Stream中的每个元素映射到另一个元素上，并返回一个新的Stream。

map操作的语法如下：

Stream<T> map(Function<? super T, ? extends U> mapper)

其中，T是Stream中的元素类型，U是映射后的元素类型。mapper是一个函数式接口，它接受一个元素作为输入，并返回一个新的元素作为输出。

map操作的作用是将Stream中的每个元素映射到另一个元素上，并返回一个新的Stream。这个操作非常灵活，可以用于很多不同的场景。

   /*** @Description 使用 map 输出了元素对应的平方数* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test7() {List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);// 获取对应的平方数List<Integer> squaresList = numbers.stream().map(i -> i * i).collect(Collectors.toList());System.out.println(squaresList);}/*** @Description 使用 map 输出了元素对应的平方数(去重)* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test8() {List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);// 获取对应的平方数List<Integer> squaresList = numbers.stream().map(i -> i * i).distinct().collect(Collectors.toList());System.out.println(squaresList);}/*** @Description 使用 map 输出了元素对应的平方数(去重并且排序)* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test9() {List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);// 获取对应的平方数List<Integer> squaresList = numbers.stream().map(i -> i * i).distinct().sorted().collect(Collectors.toList());System.out.println(squaresList);}/*** @Description 使用 map 输出了元素对应的平方数(去重并且排序,限制个数)* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test10() {List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);// 获取对应的平方数List<Integer> squaresList = numbers.stream().map(i -> i * i).distinct().sorted().limit(3).collect(Collectors.toList());System.out.println(squaresList);}

Stream中的parallel并行程序

parallel操作可以将Stream中的每个元素并行处理，并返回一个新的Stream。

parallel操作的语法如下：

Stream<T> parallel()

其中，T是Stream中的元素类型。

parallel操作的作用是将Stream中的每个元素并行处理，并返回一个新的Stream。这个操作可以用于处理大量数据，提高处理效率。

需要注意的是，parallel操作会创建一个新的线程来处理每个元素，这可能会导致性能开销。因此，在使用parallel操作时，需要根据具体的情况来评估其性能开销，并进行适当的优化。

    /*** @Description 获取空字符串的数量* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test11() {List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl");// 获取空字符串的数量long count = strings.parallelStream().filter(string -> string.isEmpty()).count();System.out.println(count);}/*** @Description 去除空字符串转换为数组* @Author IT小辉同学* @Date 2023/05/15*/@Testpublic void test12() {List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl");// 获取空字符串的数量List<String> stringList = strings.parallelStream().filter(string ->!string.isEmpty()).collect(Collectors.toList());System.out.println(stringList);}

Stream中的Collectors聚合操作

Stream中的Collectors聚合操作是一种用于对流数据进行处理的方法，它可以将流中的元素按照指定的规则进行分组、过滤、映射等操作，最终生成一个新的流。

以下是一些常见的聚合操作：

1. toList():将流中的元素收集到一个List中。

List<Integer> list = stream.collect(Collectors.toList());

2. toSet():将流中的元素收集到一个Set中，去重。

Set<Integer> set = stream.collect(Collectors.toSet());

3. toMap():将流中的元素按照指定的键值对进行分组，并返回一个Map对象。

Map<String, Integer> map = stream.collect(Collectors.toMap(Function.identity(), Function.identity()));

4. maxBy():按照指定的属性或方法对流中的元素进行比较，返回最大值。

Optional<Integer> max = stream.max(Comparator.comparingInt(i -> i));

5. minBy():按照指定的属性或方法对流中的元素进行比较，返回最小值。

Optional<Integer> min = stream.min(Comparator.comparingInt(i -> i));

6. sum():对流中的数字类型元素进行求和。

long sum = stream.mapToLong(i -> i).sum();

7. count():统计流中元素的数量。

long count = stream.count();

8. average():计算流中数字类型元素的平均值。

double average = stream.mapToDouble(i -> i).average().orElse(0d);

9. filter():根据指定的条件过滤流中的元素。

stream.filter(i -> i > 10).forEach(System.out::println); // 输出大于 10 的元素

10. distinct():去重操作，返回不同的元素组成的流。

List<Integer> distinctList = stream.distinct().collect(Collectors.toList()); // 去重后生成 List 集合

使用Collectors可以简化代码，提高开发效率，同时也可以实现更加灵活的数据处理方式。

Stream中的统计函数

另外，一些产生统计结果的收集器也非常有用。它们主要用于int、double、long等基本类型上，它们可以用来产生类似如下的统计结果。

好的，以下是Stream中的统计函数介绍：

1. count():统计流中元素的数量。

long count = stream.count();

2. min():返回流中最小的元素。

Optional<T> min = stream.min(Comparator.comparing(i -> i));

3. max():返回流中最大的元素。

Optional<T> max = stream.max(Comparator.comparing(i -> i));

4. sum():对流中的元素进行求和。

long sum = stream.mapToLong(i -> i).sum();

5. average():计算流中元素的平均值。

double average = stream.mapToDouble(i -> i).average().orElse(0d);

6. distinct():返回去重后的元素列表。

List<T> distinctList = stream.distinct().collect(Collectors.toList()); // 去重后生成 List 集合

7. anyMatch():判断流中是否存在至少一个满足条件的元素。

boolean anyMatch = stream.anyMatch(i -> i > 10); // 判断是否存在大于 10 的元素

8. allMatch():判断流中的所有元素是否都满足条件。

boolean allMatch = stream.allMatch(i -> i > 10); // 判断所有元素是否都大于 10

9. noneMatch():判断流中是否不存在满足条件的元素。

boolean noneMatch = stream.noneMatch(i -> i < 10); // 判断是否不存在小于 10 的元素

一个小例子结束学习之旅

数字平方排序（倒叙）输出

字符串转 map 输出

public static void main(String[] args) {List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);// 获取对应的平方数// List<Integer> squaresList = numbers.stream().map( i -> i*i).distinct().collect(Collectors.toList());List<Integer> squaresList = numbers.stream().map(i -> i * i).sorted((x, y) -> y - x).collect(Collectors.toList());// squaresList.forEach(System.out::println);squaresList.forEach(num -> {num++;System.out.println(num);});List<String> strList = Arrays.asList("a", "ba", "bb", "abc", "cbb", "bba", "cab");Map<Integer, String> strMap = new HashMap<Integer, String>();strMap = strList.stream().collect( Collectors.toMap( str -> strList.indexOf(str), str -> str ) );strMap.forEach((key, value) -> {System.out.println(key+"::"+value);});}

sorted()方法的第二个参数是一个比较器(Comparator),用于指定排序规则。比较器的逻辑接受两个参数，分别代表要比较的两个元素，返回一个负数、零或正数，表示第一个参数小于、等于或大于第二个参数。
在sorted((x, y) -> y - x)中，括号内的第一个参数x和第二个参数y分别代表要比较的两个元素。比较器的逻辑是按照从每个元素到自身的降序差值进行比较，即用第二个元素减去第一个元素，得到的结果就是它们之间的大小关系。如果结果为负数，则说明第一个元素小于第二个元素；如果结果为0,则说明它们相等；如果结果为正数，则说明第一个元素大于第二个元素。
因此，sorted((x, y) -> y - x)实际上定义了一个从每个元素到自身的降序差值的比较器，用于对列表进行排序操作。

前辈的文章推荐（如果感觉对于个人这篇文章已经透彻，可以看看前辈的文章，本人学习之后，方知自我之浅薄）