什么是 Stream API？

Stream API 是 Java 8 中引入的一项新特性，它提供了一种函数式的、流式处理集合数据的方式。Stream API 可以让我们以更简洁、更易读的方式处理集合数据，同时还可以充分利用多核 CPU 的并行处理能力，提高程序的执行效率。

在 Stream API 中，我们可以通过一系列的操作对集合数据进行处理，这些操作可以分为中间操作和终止操作。中间操作是对流的数据进行处理和转换，但不会产生最终的结果；终止操作是产生最终结果的操作，它会触发流的处理，并将结果返回。

Stream API 主要包含以下几个部分：

• 流的创建：通过集合、数组、文件等方式创建流。
• 操作流：对流进行过滤、映射、排序、去重等操作。
• 终止流：将流转换为集合、数组、汇总统计、匹配检查等。

下面我们将详细介绍 Java 中如何使用 Stream API。

Java 中如何使用 Stream API？

流的创建

在 Java 中，我们可以通过多种方式创建流。以下是一些常用的流的创建方式：

从集合创建流

List<String> list = Arrays.asList("a", "b", "c", "d");
Stream<String> stream = list.stream();

从数组创建流

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

从文件创建流

Path path = Paths.get("file.txt");
Stream<String> stream = Files.lines(path);

从函数创建流

Stream.generate(() -> "hello")
      .limit(5)
      .forEach(System.out::println);

在上面的代码中，我们使用 Stream.generate() 方法创建了一个无限流，该流会不断生成字符串 “hello”，然后使用 limit() 方法对流进行截取，最终输出前 5 个元素。

操作流

在创建了流之后，我们可以对流进行一系列的操作，以实现数据的处理和转换。以下是一些常用的流操作：

filter() 方法

filter() 方法可以对流中的数据进行过滤，只保留符合条件的数据，从而得到一个新的流。

List<String> list = Arrays.asList("a", "b", "c", "d");
Stream<String> stream = list.stream().filter(s -> s.startsWith("a"));

上面的代码中，我们使用 filter() 方法过滤出以 “a” 开头的字符串，得到一个新的流。

map() 方法

map() 方法可以对流中的数据进行转换，从而得到一个新的流。

List<String> list = Arrays.asList("a", "b", "c", "d");
Stream<String> stream = list.stream().map(String::toUpperCase);

上面的代码中，我们使用 map() 方法将字符串转换成大写形式，得到一个新的流。

sorted() 方法

sorted() 方法可以对流中的数据进行排序，从而得到一个新的流。

List<String> list = Arrays.asList("b", "a", "d", "c");
Stream<String> stream = list.stream().sorted();

上面的代码中，我们使用 sorted() 方法对字符串进行排序，得到一个新的流。

distinct() 方法

distinct() 方法可以对流中的数据进行去重，从而得到一个新的流。

List<String> list = Arrays.asList("a", "b", "a", "c");
Stream<String> stream = list.stream().distinct();

上面的代码中，我们使用 distinct() 方法对字符串进行去重，得到一个新的流。

peek() 方法

peek() 方法可以对流中的数据进行操作，不会改变流中的数据，但可以在操作过程中输出一些信息。

List<String> list = Arrays.asList("a", "b", "c", "d");
Stream<String> stream = list.stream().peek(System.out::println);

上面的代码中，我们使用 peek() 方法对字符串进行操作，并输出字符串的值，但不会改变流中的数据。

终止流

在对流进行了操作之后，我们可以通过终止操作将流转换为最终的结果。以下是一些常用的终止操作：

collect() 方法

collect() 方法可以将流中的元素收集到一个集合中，如 List、Set、Map 等。

List<String> list = Arrays.asList("a", "b", "c", "d");
List<String> result = list.stream().collect(Collectors.toList());

上面的代码中，我们使用 collect() 方法将流中的元素收集到一个 List 中。

reduce() 方法

reduce() 方法可以对流中的元素进行累加、求和等操作，得到一个最终的结果。

List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);
int sum = list.stream().reduce(0, Integer::sum);

上面的代码中，我们使用 reduce() 方法对整数进行求和操作，并得到最终的结果。

count() 方法

count() 方法可以统计流中的元素个数。

List<String> list = Arrays.asList("a", "b", "c", "d");
long count = list.stream().count();

上面的代码中，我们使用 count() 方法统计了流中的元素个数。

forEach() 方法

forEach() 方法可以对流中的每个元素进行操作，如输出到控制台等。

List<String> list = Arrays.asList("a", "b", "c", "d");
list.stream().forEach(System.out::println);

上面的代码中，我们使用 forEach() 方法输出了流中的每个元素。

完整示例代码

下面是一个完整的示例代码，演示了如何使用 Stream API 对集合中的数据进行操作。

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class StreamDemo {
    public static void main(String[] args) {
        List<String> list = Arrays.asList("hello", "world", "java", "stream", "api");
        // 过滤出长度大于 4 的字符串，并将其转换成大写形式
        List<String> result = list.stream()
                .filter(s -> s.length() > 4)
                .map(String::toUpperCase)
                .collect(Collectors.toList());
        System.out.println(result);
        // 统计字符串的个数
        long count = list.stream().count();
        System.out.println(count);
        // 对字符串进行排序，并输出到控制台
        list.stream().sorted().forEach(System.out::println);
        // 对字符串进行去重，并输出到控制台
        list.stream().distinct().forEach(System.out::println);
        // 对字符串进行操作，并输出到控制台
        list.stream().peek(System.out::println).collect(Collectors.toList());
    }
}

以上代码演示了如何使用 Stream API 对集合中的数据进行操作，并输出结果到控制台。

总结

Stream API 是 Java 8 中引入的一项新特性，它提供了一种函数式的、流式处理集合数据的方式。Stream API 可以让我们以更简洁、更易读的方式处理集合数据，同时还可以充分利用多核 CPU 的并行处理能力，提高程序的执行效率。在使用 Stream API 时，我们可以通过一系列的操作对集合数据进行处理，这些操作可以分为中间操作和终止操作。中间操作是对流的数据进行处理和转换，但不会产生最终的结果；终止操作是产生最终结果的操作，它会触发流的处理，并将结果返回。通过使用 Stream API，我们可以更方便地进行集合数据的处理和转换，提高程序的可读性和可维护性。